Initial drop of donated AMQP Client Code. Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/e4decdc1 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/e4decdc1 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/e4decdc1
Branch: refs/heads/master Commit: e4decdc1e5df9797915b5a892f59bc20134c969c Parents: 99f60c2 Author: Timothy Bish <[email protected]> Authored: Tue Sep 23 14:09:26 2014 -0400 Committer: Timothy Bish <[email protected]> Committed: Tue Sep 23 14:09:26 2014 -0400 ---------------------------------------------------------------------- LICENSE | 202 ++++ README.md | 5 + pom.xml | 237 ++++ qpid-jms-client/.gitignore | 3 + qpid-jms-client/pom.xml | 173 +++ .../org/apache/qpid/jms/version.txt | 1 + .../apache/qpid/jms/JmsClientProperties.java | 36 + .../java/org/apache/qpid/jms/JmsConnection.java | 1128 +++++++++++++++++ .../apache/qpid/jms/JmsConnectionFactory.java | 664 ++++++++++ .../apache/qpid/jms/JmsConnectionListener.java | 62 + .../apache/qpid/jms/JmsConnectionMetaData.java | 164 +++ .../org/apache/qpid/jms/JmsDestination.java | 189 +++ .../qpid/jms/JmsDurableTopicSubscriber.java | 47 + .../qpid/jms/JmsLocalTransactionContext.java | 216 ++++ .../qpid/jms/JmsMessageAvailableConsumer.java | 45 + .../qpid/jms/JmsMessageAvailableListener.java | 35 + .../org/apache/qpid/jms/JmsMessageConsumer.java | 509 ++++++++ .../apache/qpid/jms/JmsMessageDispatcher.java | 31 + .../org/apache/qpid/jms/JmsMessageProducer.java | 334 ++++++ .../org/apache/qpid/jms/JmsPrefetchPolicy.java | 181 +++ .../main/java/org/apache/qpid/jms/JmsQueue.java | 49 + .../org/apache/qpid/jms/JmsQueueBrowser.java | 264 ++++ .../org/apache/qpid/jms/JmsQueueConnection.java | 48 + .../org/apache/qpid/jms/JmsQueueReceiver.java | 59 + .../org/apache/qpid/jms/JmsQueueSender.java | 78 ++ .../org/apache/qpid/jms/JmsQueueSession.java | 187 +++ .../java/org/apache/qpid/jms/JmsSession.java | 1002 ++++++++++++++++ .../qpid/jms/JmsSslConnectionFactory.java | 93 ++ .../java/org/apache/qpid/jms/JmsSslContext.java | 100 ++ .../org/apache/qpid/jms/JmsTemporaryQueue.java | 62 + .../org/apache/qpid/jms/JmsTemporaryTopic.java | 62 + .../main/java/org/apache/qpid/jms/JmsTopic.java | 49 + .../org/apache/qpid/jms/JmsTopicConnection.java | 43 + .../org/apache/qpid/jms/JmsTopicPublisher.java | 100 ++ .../org/apache/qpid/jms/JmsTopicSession.java | 163 +++ .../org/apache/qpid/jms/JmsTopicSubscriber.java | 70 ++ .../apache/qpid/jms/JmsTransactionListener.java | 31 + .../apache/qpid/jms/JmsTxSynchronization.java | 47 + .../jms/exceptions/IdConversionException.java | 36 + .../JmsConnectionClosedException.java | 47 + .../JmsConnectionFailedException.java | 47 + .../jms/exceptions/JmsExceptionSupport.java | 103 ++ .../qpid/jms/exceptions/QpidJmsException.java | 43 + .../qpid/jms/jndi/JNDIReferenceFactory.java | 125 ++ .../org/apache/qpid/jms/jndi/JNDIStorable.java | 119 ++ .../qpid/jms/jndi/JmsInitialContextFactory.java | 197 +++ .../apache/qpid/jms/jndi/LazyCreateContext.java | 46 + .../apache/qpid/jms/jndi/NameParserImpl.java | 35 + .../apache/qpid/jms/jndi/ReadOnlyContext.java | 465 +++++++ .../qpid/jms/message/JmsBytesMessage.java | 831 +++++++++++++ .../jms/message/JmsDefaultMessageFactory.java | 94 ++ .../jms/message/JmsInboundMessageDispatch.java | 57 + .../apache/qpid/jms/message/JmsMapMessage.java | 320 +++++ .../org/apache/qpid/jms/message/JmsMessage.java | 643 ++++++++++ .../qpid/jms/message/JmsMessageFactory.java | 133 ++ .../message/JmsMessagePropertyIntercepter.java | 622 ++++++++++ .../jms/message/JmsMessageTransformation.java | 198 +++ .../qpid/jms/message/JmsObjectMessage.java | 111 ++ .../jms/message/JmsOutboundMessageDispatch.java | 63 + .../qpid/jms/message/JmsStreamMessage.java | 485 ++++++++ .../apache/qpid/jms/message/JmsTextMessage.java | 68 ++ .../message/facade/JmsBytesMessageFacade.java | 54 + .../jms/message/facade/JmsMapMessageFacade.java | 90 ++ .../jms/message/facade/JmsMessageFacade.java | 357 ++++++ .../message/facade/JmsObjectMessageFacade.java | 67 ++ .../message/facade/JmsStreamMessageFacade.java | 76 ++ .../message/facade/JmsTextMessageFacade.java | 53 + .../defaults/JmsDefaultBytesMessageFacade.java | 68 ++ .../defaults/JmsDefaultMapMessageFacade.java | 75 ++ .../defaults/JmsDefaultMessageFacade.java | 316 +++++ .../defaults/JmsDefaultObjectMessageFacade.java | 105 ++ .../defaults/JmsDefaultStreamMessageFacade.java | 85 ++ .../defaults/JmsDefaultTextMessageFacade.java | 62 + .../qpid/jms/meta/JmsAbstractResourceId.java | 47 + .../apache/qpid/jms/meta/JmsConnectionId.java | 76 ++ .../apache/qpid/jms/meta/JmsConnectionInfo.java | 251 ++++ .../org/apache/qpid/jms/meta/JmsConsumerId.java | 121 ++ .../apache/qpid/jms/meta/JmsConsumerInfo.java | 187 +++ .../jms/meta/JmsDefaultResourceVisitor.java | 51 + .../org/apache/qpid/jms/meta/JmsMessageId.java | 109 ++ .../org/apache/qpid/jms/meta/JmsProducerId.java | 123 ++ .../apache/qpid/jms/meta/JmsProducerInfo.java | 103 ++ .../org/apache/qpid/jms/meta/JmsResource.java | 35 + .../org/apache/qpid/jms/meta/JmsResourceId.java | 56 + .../apache/qpid/jms/meta/JmsResourceVistor.java | 38 + .../org/apache/qpid/jms/meta/JmsSessionId.java | 100 ++ .../apache/qpid/jms/meta/JmsSessionInfo.java | 63 + .../apache/qpid/jms/meta/JmsTransactionId.java | 81 ++ .../qpid/jms/meta/JmsTransactionInfo.java | 90 ++ .../main/java/org/apache/qpid/jms/package.html | 25 + .../qpid/jms/provider/AbstractProvider.java | 93 ++ .../apache/qpid/jms/provider/AsyncResult.java | 47 + .../jms/provider/DefaultProviderListener.java | 52 + .../org/apache/qpid/jms/provider/Provider.java | 292 +++++ .../jms/provider/ProviderClosedException.java | 28 + .../qpid/jms/provider/ProviderConstants.java | 43 + .../qpid/jms/provider/ProviderFactory.java | 110 ++ .../qpid/jms/provider/ProviderFuture.java | 109 ++ .../qpid/jms/provider/ProviderListener.java | 103 ++ .../qpid/jms/provider/ProviderWrapper.java | 179 +++ .../jms/provider/amqp/AbstractAmqpResource.java | 242 ++++ .../provider/amqp/AmqpAnonymousProducer.java | 192 +++ .../qpid/jms/provider/amqp/AmqpConnection.java | 285 +++++ .../qpid/jms/provider/amqp/AmqpConsumer.java | 461 +++++++ .../jms/provider/amqp/AmqpFixedProducer.java | 351 ++++++ .../qpid/jms/provider/amqp/AmqpJMSVendor.java | 159 +++ .../jms/provider/amqp/AmqpJmsNoLocalType.java | 44 + .../jms/provider/amqp/AmqpJmsSelectorType.java | 42 + .../qpid/jms/provider/amqp/AmqpProducer.java | 93 ++ .../qpid/jms/provider/amqp/AmqpProvider.java | 821 +++++++++++++ .../jms/provider/amqp/AmqpProviderFactory.java | 57 + .../jms/provider/amqp/AmqpQueueBrowser.java | 127 ++ .../qpid/jms/provider/amqp/AmqpResource.java | 130 ++ .../provider/amqp/AmqpSaslAuthenticator.java | 127 ++ .../qpid/jms/provider/amqp/AmqpSession.java | 281 +++++ .../qpid/jms/provider/amqp/AmqpSslProvider.java | 47 + .../provider/amqp/AmqpSslProviderFactory.java | 32 + .../provider/amqp/AmqpTemporaryDestination.java | 132 ++ .../provider/amqp/AmqpTransactionContext.java | 269 +++++ .../provider/amqp/AmqpTransferTagGenerator.java | 103 ++ .../amqp/message/AmqpJmsBytesMessageFacade.java | 144 +++ .../amqp/message/AmqpJmsMapMessageFacade.java | 154 +++ .../amqp/message/AmqpJmsMessageBuilder.java | 107 ++ .../amqp/message/AmqpJmsMessageFacade.java | 674 +++++++++++ .../amqp/message/AmqpJmsMessageFactory.java | 130 ++ .../AmqpJmsMessagePropertyIntercepter.java | 377 ++++++ .../message/AmqpJmsObjectMessageFacade.java | 124 ++ .../message/AmqpJmsStreamMessageFacade.java | 163 +++ .../amqp/message/AmqpJmsTextMessageFacade.java | 156 +++ .../amqp/message/AmqpMessageIdHelper.java | 270 +++++ .../amqp/message/AmqpMessageSupport.java | 169 +++ .../amqp/message/AmqpObjectTypeDelegate.java | 50 + .../message/AmqpSerializedObjectDelegate.java | 101 ++ .../amqp/message/AmqpTypedObjectDelegate.java | 103 ++ .../jms/provider/failover/FailoverProvider.java | 857 +++++++++++++ .../failover/FailoverProviderFactory.java | 56 + .../jms/provider/failover/FailoverUriPool.java | 196 +++ .../apache/qpid/jms/sasl/AbstractMechanism.java | 75 ++ .../qpid/jms/sasl/AnonymousMechanism.java | 43 + .../jms/sasl/AnonymousMechanismFactory.java | 28 + .../apache/qpid/jms/sasl/CramMD5Mechanism.java | 86 ++ .../qpid/jms/sasl/CramMD5MechanismFactory.java | 28 + .../org/apache/qpid/jms/sasl/Mechanism.java | 125 ++ .../apache/qpid/jms/sasl/MechanismFactory.java | 31 + .../apache/qpid/jms/sasl/PlainMechanism.java | 62 + .../qpid/jms/sasl/PlainMechanismFactory.java | 28 + .../qpid/jms/sasl/SaslMechanismFinder.java | 108 ++ .../qpid/jms/transports/RawTcpTransport.java | 383 ++++++ .../qpid/jms/transports/SslTransport.java | 59 + .../jms/transports/TcpBufferedInputStream.java | 139 +++ .../jms/transports/TcpBufferedOutputStream.java | 126 ++ .../qpid/jms/transports/TcpTransport.java | 270 +++++ .../apache/qpid/jms/transports/Transport.java | 87 ++ .../qpid/jms/transports/TransportListener.java | 48 + .../qpid/jms/util/AbstractMessageQueue.java | 129 ++ .../ClassLoadingAwareObjectInputStream.java | 150 +++ .../org/apache/qpid/jms/util/FactoryFinder.java | 210 ++++ .../apache/qpid/jms/util/FifoMessageQueue.java | 97 ++ .../qpid/jms/util/IOExceptionSupport.java | 47 + .../org/apache/qpid/jms/util/IdGenerator.java | 228 ++++ .../apache/qpid/jms/util/InetAddressUtil.java | 57 + .../org/apache/qpid/jms/util/MessageQueue.java | 131 ++ .../qpid/jms/util/PriorityMessageQueue.java | 144 +++ .../org/apache/qpid/jms/util/PropertyUtil.java | 486 ++++++++ .../org/apache/qpid/jms/util/StopWatch.java | 79 ++ .../apache/qpid/jms/util/ThreadPoolUtils.java | 190 +++ .../org/apache/qpid/jms/util/TimeUtils.java | 73 ++ .../apache/qpid/jms/util/ToStringSupport.java | 125 ++ .../qpid/jms/util/TypeConversionSupport.java | 180 +++ .../org/apache/qpid/jms/util/URISupport.java | 430 +++++++ .../services/org/apache/qpid/jms/provider/amqp | 17 + .../org/apache/qpid/jms/provider/amqp+nio | 17 + .../org/apache/qpid/jms/provider/amqp+nio+ssl | 17 + .../org/apache/qpid/jms/provider/amqp+ssl | 17 + .../services/org/apache/qpid/jms/provider/amqps | 17 + .../org/apache/qpid/jms/provider/failover | 17 + .../services/org/apache/qpid/jms/sasl/ANONYMOUS | 17 + .../services/org/apache/qpid/jms/sasl/CRAM-MD5 | 17 + .../services/org/apache/qpid/jms/sasl/PLAIN | 17 + .../integration/ConnectionIntegrationTest.java | 66 + .../jms/integration/IntegrationTestFixture.java | 48 + .../jms/integration/MessageIntegrationTest.java | 957 +++++++++++++++ .../jms/integration/SenderIntegrationTest.java | 379 ++++++ .../qpid/jms/message/JmsBytesMessageTest.java | 666 ++++++++++ .../qpid/jms/message/JmsMapMessageTest.java | 911 ++++++++++++++ .../apache/qpid/jms/message/JmsMessageTest.java | 944 +++++++++++++++ .../qpid/jms/message/JmsObjectMessageTest.java | 260 ++++ .../qpid/jms/message/JmsStreamMessageTest.java | 1133 ++++++++++++++++++ .../qpid/jms/message/JmsTextMessageTest.java | 138 +++ .../amqp/message/AmqpMessageIdHelperTest.java | 496 ++++++++ .../apache/qpid/jms/test/QpidJmsTestCase.java | 98 ++ ...ractFrameFieldAndPayloadMatchingHandler.java | 112 ++ .../qpid/jms/test/testpeer/AmqpDataFramer.java | 64 + .../jms/test/testpeer/AmqpPeerRunnable.java | 25 + .../testpeer/CompositeAmqpPeerRunnable.java | 49 + .../jms/test/testpeer/DescriptorMatcher.java | 53 + .../qpid/jms/test/testpeer/FrameHandler.java | 27 + .../jms/test/testpeer/FrameMatchingHandler.java | 146 +++ .../qpid/jms/test/testpeer/FrameSender.java | 63 + .../qpid/jms/test/testpeer/FrameType.java | 22 + .../FrameWithNoPayloadMatchingHandler.java | 49 + .../FrameWithPayloadMatchingHandler.java | 64 + .../apache/qpid/jms/test/testpeer/Handler.java | 28 + .../qpid/jms/test/testpeer/HeaderHandler.java | 24 + .../jms/test/testpeer/HeaderHandlerImpl.java | 74 ++ .../jms/test/testpeer/ListDescribedType.java | 66 + .../jms/test/testpeer/MapDescribedType.java | 46 + .../qpid/jms/test/testpeer/TestAmqpPeer.java | 621 ++++++++++ .../jms/test/testpeer/TestAmqpPeerRunner.java | 153 +++ .../qpid/jms/test/testpeer/TestFrameParser.java | 375 ++++++ .../qpid/jms/test/testpeer/ValueProvider.java | 28 + .../test/testpeer/describedtypes/Accepted.java | 54 + .../testpeer/describedtypes/AttachFrame.java | 152 +++ .../testpeer/describedtypes/BeginFrame.java | 110 ++ .../testpeer/describedtypes/CloseFrame.java | 61 + .../testpeer/describedtypes/DetachFrame.java | 75 ++ .../describedtypes/DispositionFrame.java | 96 ++ .../test/testpeer/describedtypes/EndFrame.java | 61 + .../test/testpeer/describedtypes/FlowFrame.java | 131 ++ .../test/testpeer/describedtypes/Modified.java | 75 ++ .../test/testpeer/describedtypes/OpenFrame.java | 124 ++ .../test/testpeer/describedtypes/Rejected.java | 61 + .../test/testpeer/describedtypes/Released.java | 54 + .../describedtypes/SaslChallengeFrame.java | 61 + .../testpeer/describedtypes/SaslInitFrame.java | 75 ++ .../describedtypes/SaslMechanismsFrame.java | 61 + .../describedtypes/SaslOutcomeFrame.java | 68 ++ .../describedtypes/SaslResponseFrame.java | 61 + .../test/testpeer/describedtypes/Source.java | 131 ++ .../test/testpeer/describedtypes/Target.java | 103 ++ .../testpeer/describedtypes/TransferFrame.java | 131 ++ .../testpeer/describedtypes/generate-frames.xsl | 154 +++ .../sections/AmqpValueDescribedType.java | 48 + .../ApplicationPropertiesDescribedType.java | 45 + .../sections/DataDescribedType.java | 54 + .../sections/HeaderDescribedType.java | 89 ++ .../MessageAnnotationsDescribedType.java | 46 + .../sections/PropertiesDescribedType.java | 145 +++ .../sections/generate-list-sections.xsl | 146 +++ .../test/testpeer/matchers/AttachMatcher.java | 231 ++++ .../test/testpeer/matchers/BeginMatcher.java | 159 +++ .../test/testpeer/matchers/CloseMatcher.java | 75 ++ .../test/testpeer/matchers/DetachMatcher.java | 99 ++ .../testpeer/matchers/DispositionMatcher.java | 135 +++ .../jms/test/testpeer/matchers/EndMatcher.java | 75 ++ .../jms/test/testpeer/matchers/FlowMatcher.java | 195 +++ .../jms/test/testpeer/matchers/OpenMatcher.java | 183 +++ .../testpeer/matchers/SaslChallengeMatcher.java | 75 ++ .../test/testpeer/matchers/SaslInitMatcher.java | 99 ++ .../matchers/SaslMechanismsMatcher.java | 75 ++ .../testpeer/matchers/SaslOutcomeMatcher.java | 87 ++ .../testpeer/matchers/SaslResponseMatcher.java | 75 ++ .../test/testpeer/matchers/TransferMatcher.java | 195 +++ .../testpeer/matchers/generate-matchers.xsl | 169 +++ .../sections/AbstractMessageSectionMatcher.java | 138 +++ .../ApplicationPropertiesSectionMatcher.java | 53 + .../MessageAnnotationsSectionMatcher.java | 75 ++ .../sections/MessageHeaderSectionMatcher.java | 118 ++ .../sections/MessageListSectionMatcher.java | 58 + .../sections/MessageMapSectionMatcher.java | 55 + .../MessagePropertiesSectionMatcher.java | 214 ++++ .../TransferPayloadCompositeMatcher.java | 224 ++++ .../generate-message-section-matchers.xsl | 166 +++ .../matchers/types/EncodedAmqpTypeMatcher.java | 114 ++ .../matchers/types/EncodedAmqpValueMatcher.java | 56 + .../matchers/types/EncodedDataMatcher.java | 58 + .../apache/qpid/jms/util/URISupportTest.java | 216 ++++ qpid-jms-client/src/test/resources/keystore | Bin 0 -> 3705 bytes .../src/test/resources/log4j.properties | 38 + qpid-jms-discovery/.gitignore | 1 + qpid-jms-discovery/pom.xml | 93 ++ .../jms/provider/discovery/DiscoveryAgent.java | 63 + .../discovery/DiscoveryAgentFactory.java | 112 ++ .../jms/provider/discovery/DiscoveryEvent.java | 45 + .../provider/discovery/DiscoveryListener.java | 40 + .../provider/discovery/DiscoveryProvider.java | 139 +++ .../discovery/DiscoveryProviderFactory.java | 65 + .../multicast/MulticastDiscoveryAgent.java | 391 ++++++ .../MulticastDiscoveryAgentFactory.java | 57 + .../discovery/multicast/PacketParser.java | 55 + .../multicast/PacketParserFactory.java | 110 ++ .../multicast/parsers/ActiveMQPacketParser.java | 77 ++ .../parsers/ActiveMQPacketParserFactory.java | 42 + .../apache/qpid/jms/provider/agents/multicast | 17 + .../provider/agents/multicast-parsers/activemq | 17 + .../org/apache/qpid/jms/provider/discovery | 17 + qpid-jms-examples/.gitignore | 1 + qpid-jms-examples/pom.xml | 37 + .../java/org/apache/qpid/jms/example/Drain.java | 139 +++ .../java/org/apache/qpid/jms/example/Spout.java | 132 ++ qpid-jms-interop-tests/.gitignore | 1 + qpid-jms-interop-tests/README.md | 3 + qpid-jms-interop-tests/pom.xml | 37 + .../qpid-jms-activemq-tests/.gitignore | 1 + .../qpid-jms-activemq-tests/pom.xml | 116 ++ .../jms/JmsConnectionCloseVariationsTest.java | 68 ++ .../qpid/jms/JmsConnectionClosedTest.java | 103 ++ .../JmsConnectionConcurrentCloseCallsTest.java | 95 ++ .../qpid/jms/JmsConnectionFactoryTest.java | 118 ++ .../qpid/jms/JmsConnectionFailedTest.java | 60 + .../org/apache/qpid/jms/JmsConnectionTest.java | 144 +++ .../qpid/jms/JmsMessageIntegrityTest.java | 497 ++++++++ .../apache/qpid/jms/JmsQueueConnectionTest.java | 81 ++ .../apache/qpid/jms/JmsSSLConnectionTest.java | 92 ++ .../apache/qpid/jms/JmsSessionClosedTest.java | 243 ++++ .../apache/qpid/jms/JmsSessionFailedTest.java | 62 + .../org/apache/qpid/jms/JmsSessionTest.java | 82 ++ .../apache/qpid/jms/JmsTopicConnectionTest.java | 81 ++ .../qpid/jms/bench/ConsumeFromAMQPTest.java | 236 ++++ .../qpid/jms/bench/ProduceToAMQPTest.java | 169 +++ .../qpid/jms/bench/ProduceToOpenWireTest.java | 129 ++ .../jms/bench/ProducerAndConsumerBench.java | 202 ++++ .../qpid/jms/consumer/JmsAutoAckTest.java | 100 ++ .../qpid/jms/consumer/JmsClientAckTest.java | 361 ++++++ .../JmsConsumerPriorityDispatchTest.java | 123 ++ .../JmsCreateResourcesInOnMessageTest.java | 94 ++ .../jms/consumer/JmsDurableSubscriberTest.java | 143 +++ .../consumer/JmsMessageConsumerClosedTest.java | 89 ++ .../consumer/JmsMessageConsumerFailedTest.java | 65 + .../jms/consumer/JmsMessageConsumerTest.java | 467 ++++++++ .../qpid/jms/consumer/JmsMessageGroupTest.java | 89 ++ .../qpid/jms/consumer/JmsQueueBrowserTest.java | 140 +++ .../qpid/jms/consumer/JmsZeroPrefetchTest.java | 110 ++ .../jms/destinations/JmsTemporaryQueueTest.java | 49 + .../jms/destinations/JmsTemporaryTopicTest.java | 52 + .../jms/discovery/JmsAmqpDiscoveryTest.java | 165 +++ .../jms/discovery/JmsDiscoveryProviderTest.java | 107 ++ .../qpid/jms/failover/FailoverProviderTest.java | 92 ++ .../qpid/jms/failover/JmsFailoverTest.java | 283 +++++ .../jms/failover/JmsOfflineBehaviorTests.java | 196 +++ .../apache/qpid/jms/joram/ActiveMQAdmin.java | 179 +++ .../org/apache/qpid/jms/joram/JoramJmsTest.java | 71 ++ .../jms/producer/JmsAnonymousProducerTest.java | 93 ++ .../producer/JmsMessageProducerClosedTest.java | 133 ++ .../producer/JmsMessageProducerFailedTest.java | 65 + .../jms/producer/JmsMessageProducerTest.java | 193 +++ .../producer/JmsProduceMessageTypesTest.java | 171 +++ .../qpid/jms/producer/JmsQueueSenderTest.java | 54 + .../jms/producer/JmsTopicPublisherTest.java | 54 + .../qpid/jms/support/AmqpTestSupport.java | 145 +++ .../qpid/jms/support/QpidJmsTestSupport.java | 447 +++++++ .../java/org/apache/qpid/jms/support/Wait.java | 48 + .../transactions/JmsTransactedConsumerTest.java | 208 ++++ .../transactions/JmsTransactedProducerTest.java | 94 ++ .../transactions/JmsTransactedSessionTest.java | 98 ++ .../JmsLargeMessageSendRecvTimedTest.java | 114 ++ .../src/test/resources/keystore | Bin 0 -> 3705 bytes .../src/test/resources/log4j.properties | 41 + .../src/test/resources/provider.properties | 20 + .../src/test/resources/test.properties | 17 + 350 files changed, 51545 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/e4decdc1/LICENSE ---------------------------------------------------------------------- diff --git a/LICENSE b/LICENSE new file mode 100644 index 0000000..e06d208 --- /dev/null +++ b/LICENSE @@ -0,0 +1,202 @@ +Apache License + Version 2.0, January 2004 + http://www.apache.org/licenses/ + + TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION + + 1. Definitions. + + "License" shall mean the terms and conditions for use, reproduction, + and distribution as defined by Sections 1 through 9 of this document. + + "Licensor" shall mean the copyright owner or entity authorized by + the copyright owner that is granting the License. + + "Legal Entity" shall mean the union of the acting entity and all + other entities that control, are controlled by, or are under common + control with that entity. For the purposes of this definition, + "control" means (i) the power, direct or indirect, to cause the + direction or management of such entity, whether by contract or + otherwise, or (ii) ownership of fifty percent (50%) or more of the + outstanding shares, or (iii) beneficial ownership of such entity. + + "You" (or "Your") shall mean an individual or Legal Entity + exercising permissions granted by this License. + + "Source" form shall mean the preferred form for making modifications, + including but not limited to software source code, documentation + source, and configuration files. + + "Object" form shall mean any form resulting from mechanical + transformation or translation of a Source form, including but + not limited to compiled object code, generated documentation, + and conversions to other media types. + + "Work" shall mean the work of authorship, whether in Source or + Object form, made available under the License, as indicated by a + copyright notice that is included in or attached to the work + (an example is provided in the Appendix below). + + "Derivative Works" shall mean any work, whether in Source or Object + form, that is based on (or derived from) the Work and for which the + editorial revisions, annotations, elaborations, or other modifications + represent, as a whole, an original work of authorship. For the purposes + of this License, Derivative Works shall not include works that remain + separable from, or merely link (or bind by name) to the interfaces of, + the Work and Derivative Works thereof. + + "Contribution" shall mean any work of authorship, including + the original version of the Work and any modifications or additions + to that Work or Derivative Works thereof, that is intentionally + submitted to Licensor for inclusion in the Work by the copyright owner + or by an individual or Legal Entity authorized to submit on behalf of + the copyright owner. For the purposes of this definition, "submitted" + means any form of electronic, verbal, or written communication sent + to the Licensor or its representatives, including but not limited to + communication on electronic mailing lists, source code control systems, + and issue tracking systems that are managed by, or on behalf of, the + Licensor for the purpose of discussing and improving the Work, but + excluding communication that is conspicuously marked or otherwise + designated in writing by the copyright owner as "Not a Contribution." + + "Contributor" shall mean Licensor and any individual or Legal Entity + on behalf of whom a Contribution has been received by Licensor and + subsequently incorporated within the Work. + + 2. Grant of Copyright License. Subject to the terms and conditions of + this License, each Contributor hereby grants to You a perpetual, + worldwide, non-exclusive, no-charge, royalty-free, irrevocable + copyright license to reproduce, prepare Derivative Works of, + publicly display, publicly perform, sublicense, and distribute the + Work and such Derivative Works in Source or Object form. + + 3. Grant of Patent License. Subject to the terms and conditions of + this License, each Contributor hereby grants to You a perpetual, + worldwide, non-exclusive, no-charge, royalty-free, irrevocable + (except as stated in this section) patent license to make, have made, + use, offer to sell, sell, import, and otherwise transfer the Work, + where such license applies only to those patent claims licensable + by such Contributor that are necessarily infringed by their + Contribution(s) alone or by combination of their Contribution(s) + with the Work to which such Contribution(s) was submitted. If You + institute patent litigation against any entity (including a + cross-claim or counterclaim in a lawsuit) alleging that the Work + or a Contribution incorporated within the Work constitutes direct + or contributory patent infringement, then any patent licenses + granted to You under this License for that Work shall terminate + as of the date such litigation is filed. + + 4. Redistribution. You may reproduce and distribute copies of the + Work or Derivative Works thereof in any medium, with or without + modifications, and in Source or Object form, provided that You + meet the following conditions: + + (a) You must give any other recipients of the Work or + Derivative Works a copy of this License; and + + (b) You must cause any modified files to carry prominent notices + stating that You changed the files; and + + (c) You must retain, in the Source form of any Derivative Works + that You distribute, all copyright, patent, trademark, and + attribution notices from the Source form of the Work, + excluding those notices that do not pertain to any part of + the Derivative Works; and + + (d) If the Work includes a "NOTICE" text file as part of its + distribution, then any Derivative Works that You distribute must + include a readable copy of the attribution notices contained + within such NOTICE file, excluding those notices that do not + pertain to any part of the Derivative Works, in at least one + of the following places: within a NOTICE text file distributed + as part of the Derivative Works; within the Source form or + documentation, if provided along with the Derivative Works; or, + within a display generated by the Derivative Works, if and + wherever such third-party notices normally appear. The contents + of the NOTICE file are for informational purposes only and + do not modify the License. You may add Your own attribution + notices within Derivative Works that You distribute, alongside + or as an addendum to the NOTICE text from the Work, provided + that such additional attribution notices cannot be construed + as modifying the License. + + You may add Your own copyright statement to Your modifications and + may provide additional or different license terms and conditions + for use, reproduction, or distribution of Your modifications, or + for any such Derivative Works as a whole, provided Your use, + reproduction, and distribution of the Work otherwise complies with + the conditions stated in this License. + + 5. Submission of Contributions. Unless You explicitly state otherwise, + any Contribution intentionally submitted for inclusion in the Work + by You to the Licensor shall be under the terms and conditions of + this License, without any additional terms or conditions. + Notwithstanding the above, nothing herein shall supersede or modify + the terms of any separate license agreement you may have executed + with Licensor regarding such Contributions. + + 6. Trademarks. This License does not grant permission to use the trade + names, trademarks, service marks, or product names of the Licensor, + except as required for reasonable and customary use in describing the + origin of the Work and reproducing the content of the NOTICE file. + + 7. Disclaimer of Warranty. Unless required by applicable law or + agreed to in writing, Licensor provides the Work (and each + Contributor provides its Contributions) on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or + implied, including, without limitation, any warranties or conditions + of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A + PARTICULAR PURPOSE. You are solely responsible for determining the + appropriateness of using or redistributing the Work and assume any + risks associated with Your exercise of permissions under this License. + + 8. Limitation of Liability. In no event and under no legal theory, + whether in tort (including negligence), contract, or otherwise, + unless required by applicable law (such as deliberate and grossly + negligent acts) or agreed to in writing, shall any Contributor be + liable to You for damages, including any direct, indirect, special, + incidental, or consequential damages of any character arising as a + result of this License or out of the use or inability to use the + Work (including but not limited to damages for loss of goodwill, + work stoppage, computer failure or malfunction, or any and all + other commercial damages or losses), even if such Contributor + has been advised of the possibility of such damages. + + 9. Accepting Warranty or Additional Liability. While redistributing + the Work or Derivative Works thereof, You may choose to offer, + and charge a fee for, acceptance of support, warranty, indemnity, + or other liability obligations and/or rights consistent with this + License. However, in accepting such obligations, You may act only + on Your own behalf and on Your sole responsibility, not on behalf + of any other Contributor, and only if You agree to indemnify, + defend, and hold each Contributor harmless for any liability + incurred by, or claims asserted against, such Contributor by reason + of your accepting any such warranty or additional liability. + + END OF TERMS AND CONDITIONS + + APPENDIX: How to apply the Apache License to your work. + + To apply the Apache License to your work, attach the following + boilerplate notice, with the fields enclosed by brackets "{}" + replaced with your own identifying information. (Don't include + the brackets!) The text should be enclosed in the appropriate + comment syntax for the file format. We also recommend that a + file or class name and description of purpose be included on the + same "printed page" as the copyright notice for easier + identification within third-party archives. + + Copyright {yyyy} {name of copyright owner} + + Licensed under the Apache License, Version 2.0 (the "License"); + you may not use this file except in compliance with the License. + You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/e4decdc1/README.md ---------------------------------------------------------------------- diff --git a/README.md b/README.md new file mode 100644 index 0000000..48ddf56 --- /dev/null +++ b/README.md @@ -0,0 +1,5 @@ +QpidJMS +========== + +The QpidJMS project provides a JMS based client that uses the AMQP v1.0 protocol. + http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/e4decdc1/pom.xml ---------------------------------------------------------------------- diff --git a/pom.xml b/pom.xml new file mode 100644 index 0000000..2035569 --- /dev/null +++ b/pom.xml @@ -0,0 +1,237 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. +--> +<project xmlns="http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd";> + <parent> + <groupId>org.apache</groupId> + <artifactId>apache</artifactId> + <version>14</version> + </parent> + <modelVersion>4.0.0</modelVersion> + + <groupId>org.apache.qpid</groupId> + <artifactId>qpid-jms-parent</artifactId> + <version>1.0-SNAPSHOT</version> + <packaging>pom</packaging> + <name>QpidJMS</name> + <inceptionYear>2013</inceptionYear> + <url>https://qpid.apache.org</url> + + <description> + QpidJMS is a JMS framework featuring support for AMQP v1.0 + </description> + + <prerequisites> + <maven>3.0.4</maven> + </prerequisites> + + <properties> + <source-version>1.7</source-version> + <target-version>1.7</target-version> + + <!-- Dependency Versions for this Project --> + <junit-version>4.11</junit-version> + <slf4j-version>1.7.7</slf4j-version> + <hawtbuf-version>1.11</hawtbuf-version> + <activemq-version>5.11-SNAPSHOT</activemq-version> + <apollo-version>1.7</apollo-version> + <proton-version>1.0-SNAPSHOT</proton-version> + <fuse-joram-tests-version>1.0</fuse-joram-tests-version> + <jetty-version>8.1.15.v20140411</jetty-version> + <vertex-version>2.0.2-final</vertex-version> + <mockito-version>1.9.5</mockito-version> + <hamcrest-version>1.3</hamcrest-version> + + <!-- Maven Plugin Version for this Project --> + <maven-surefire-plugin-version>2.16</maven-surefire-plugin-version> + <maven-assembly-plugin-version>2.4</maven-assembly-plugin-version> + <maven-release-plugin-version>2.4.1</maven-release-plugin-version> + <maven-eclipse-plugin-version>2.9</maven-eclipse-plugin-version> + <maven-idea-plugin-version>2.5</maven-idea-plugin-version> + <maven-compiler-plugin-version>3.1</maven-compiler-plugin-version> + <findbugs-maven-plugin-version>3.0.0</findbugs-maven-plugin-version> + + <!-- Test properties --> + <maven.test.redirectTestOutputToFile>true</maven.test.redirectTestOutputToFile> + <proton.trace.frames>false</proton.trace.frames> + + <!-- surefire forked jvm arguments --> + <argLine>-Xmx2g -enableassertions</argLine> + </properties> + + <issueManagement> + <url>https://issues.apache.org/jira/browse/QPIDJMS</url> + <system>JIRA</system> + </issueManagement> + + <scm> + <connection>scm:git:http://git-wip-us.apache.org/repos/asf/qpid-jms.git</connection> + <developerConnection>scm:git:https://git-wip-us.apache.org/repos/asf/qpid-jms.git</developerConnection> + <url>https://git-wip-us.apache.org/repos/asf?p=qpid-jms.git</url> + <tag>HEAD</tag> + </scm> + + <modules> + <module>qpid-jms-client</module> + <module>qpid-jms-discovery</module> + <module>qpid-jms-interop-tests</module> + <module>qpid-jms-examples</module> + </modules> + + <dependencyManagement> + <dependencies> + <!-- =============================== --> + <!-- Internal QpidJMS Dependencies --> + <!-- =============================== --> + <dependency> + <groupId>org.apache.qpid</groupId> + <artifactId>qpid-jms-client</artifactId> + <version>${project.version}</version> + </dependency> + <dependency> + <groupId>org.apache.qpid</groupId> + <artifactId>qpid-jms-discovery</artifactId> + <version>${project.version}</version> + </dependency> + <dependency> + <groupId>org.apache.qpid</groupId> + <artifactId>proton-jms</artifactId> + <version>${proton-version}</version> + </dependency> + <dependency> + <groupId>org.apache.geronimo.specs</groupId> + <artifactId>geronimo-jms_1.1_spec</artifactId> + <version>1.1.1</version> + </dependency> + <dependency> + <groupId>org.apache.geronimo.specs</groupId> + <artifactId>geronimo-j2ee-management_1.1_spec</artifactId> + <version>1.0.1</version> + </dependency> + <dependency> + <groupId>junit</groupId> + <artifactId>junit</artifactId> + <version>${junit-version}</version> + <scope>test</scope> + </dependency> + <dependency> + <groupId>org.mockito</groupId> + <artifactId>mockito-all</artifactId> + <version>${mockito-version}</version> + <scope>test</scope> + </dependency> + <dependency> + <groupId>org.hamcrest</groupId> + <artifactId>hamcrest-all</artifactId> + <version>${hamcrest-version}</version> + <scope>test</scope> + </dependency> + <dependency> + <groupId>org.slf4j</groupId> + <artifactId>slf4j-api</artifactId> + <version>${slf4j-version}</version> + </dependency> + <dependency> + <groupId>org.slf4j</groupId> + <artifactId>slf4j-log4j12</artifactId> + <version>${slf4j-version}</version> + </dependency> + <dependency> + <groupId>org.fusesource.hawtbuf</groupId> + <artifactId>hawtbuf</artifactId> + <version>${hawtbuf-version}</version> + </dependency> + <dependency> + <groupId>org.apache.activemq</groupId> + <artifactId>apollo-selector</artifactId> + <version>${apollo-version}</version> + </dependency> + <dependency> + <groupId>io.vertx</groupId> + <artifactId>vertx-core</artifactId> + <version>${vertex-version}</version> + </dependency> + <dependency> + <groupId>io.vertx</groupId> + <artifactId>vertx-platform</artifactId> + <version>${vertex-version}</version> + </dependency> + </dependencies> + </dependencyManagement> + + <build> + <defaultGoal>install</defaultGoal> + <pluginManagement> + <plugins> + <plugin> + <groupId>org.apache.maven.plugins</groupId> + <artifactId>maven-surefire-plugin</artifactId> + <version>${maven-surefire-plugin-version}</version> + <configuration> + <redirectTestOutputToFile>${maven.test.redirectTestOutputToFile}</redirectTestOutputToFile> + <forkCount>1</forkCount> + <reuseForks>true</reuseForks> + <systemPropertyVariables> + <java.awt.headless>true</java.awt.headless> + </systemPropertyVariables> + <failIfNoTests>false</failIfNoTests> + <environmentVariables> + <PN_TRACE_FRM>${proton.trace.frames}</PN_TRACE_FRM> + </environmentVariables> + </configuration> + </plugin> + <plugin> + <groupId>org.apache.maven.plugins</groupId> + <artifactId>maven-eclipse-plugin</artifactId> + <version>${maven-eclipse-plugin-version}</version> + <configuration> + <downloadSources>true</downloadSources> + <downloadJavadocs>true</downloadJavadocs> + </configuration> + </plugin> + <plugin> + <groupId>org.apache.maven.plugins</groupId> + <artifactId>maven-idea-plugin</artifactId> + <version>${maven-idea-plugin-version}</version> + <configuration> + <downloadSources>true</downloadSources> + <downloadJavadocs>true</downloadJavadocs> + </configuration> + </plugin> + <plugin> + <groupId>org.apache.maven.plugins</groupId> + <artifactId>maven-compiler-plugin</artifactId> + <version>${maven-compiler-plugin-version}</version> + </plugin> + </plugins> + </pluginManagement> + <plugins> + <plugin> + <groupId>org.apache.maven.plugins</groupId> + <artifactId>maven-compiler-plugin</artifactId> + <configuration> + <source>${source-version}</source> + <target>${target-version}</target> + <optimize>true</optimize> + <debug>true</debug> + <showDeprecation>true</showDeprecation> + <showWarnings>true</showWarnings> + </configuration> + </plugin> + </plugins> + </build> +</project> http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/e4decdc1/qpid-jms-client/.gitignore ---------------------------------------------------------------------- diff --git a/qpid-jms-client/.gitignore b/qpid-jms-client/.gitignore new file mode 100644 index 0000000..073c9fa --- /dev/null +++ b/qpid-jms-client/.gitignore @@ -0,0 +1,3 @@ +/target +/target +/target http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/e4decdc1/qpid-jms-client/pom.xml ---------------------------------------------------------------------- diff --git a/qpid-jms-client/pom.xml b/qpid-jms-client/pom.xml new file mode 100644 index 0000000..54c605a --- /dev/null +++ b/qpid-jms-client/pom.xml @@ -0,0 +1,173 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. +--> +<project xmlns="http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd";> + <modelVersion>4.0.0</modelVersion> + <parent> + <groupId>org.apache.qpid</groupId> + <artifactId>qpid-jms-parent</artifactId> + <version>1.0-SNAPSHOT</version> + </parent> + + <artifactId>qpid-jms-client</artifactId> + <packaging>jar</packaging> + <name>QpidJMS Client</name> + <description>The core JMS Client implementation</description> + + <dependencies> + <!-- =================================== --> + <!-- Required Dependencies --> + <!-- =================================== --> + <dependency> + <groupId>org.slf4j</groupId> + <artifactId>slf4j-api</artifactId> + </dependency> + <dependency> + <groupId>org.apache.geronimo.specs</groupId> + <artifactId>geronimo-jms_1.1_spec</artifactId> + </dependency> + <dependency> + <groupId>org.fusesource.hawtbuf</groupId> + <artifactId>hawtbuf</artifactId> + </dependency> + <dependency> + <groupId>org.apache.activemq</groupId> + <artifactId>apollo-selector</artifactId> + <optional>true</optional> + </dependency> + <dependency> + <groupId>org.apache.qpid</groupId> + <artifactId>proton-jms</artifactId> + </dependency> + <dependency> + <groupId>io.vertx</groupId> + <artifactId>vertx-core</artifactId> + </dependency> + <dependency> + <groupId>io.vertx</groupId> + <artifactId>vertx-platform</artifactId> + </dependency> + + <!-- would be nice if we could make this dependency optional --> + <dependency> + <groupId>org.apache.geronimo.specs</groupId> + <artifactId>geronimo-j2ee-management_1.1_spec</artifactId> + </dependency> + + <!-- =================================== --> + <!-- Testing Dependencies --> + <!-- =================================== --> + <dependency> + <groupId>junit</groupId> + <artifactId>junit</artifactId> + <scope>test</scope> + </dependency> + <dependency> + <groupId>org.slf4j</groupId> + <artifactId>slf4j-log4j12</artifactId> + <scope>test</scope> + </dependency> + <dependency> + <groupId>org.mockito</groupId> + <artifactId>mockito-all</artifactId> + <scope>test</scope> + </dependency> + <dependency> + <groupId>org.hamcrest</groupId> + <artifactId>hamcrest-all</artifactId> + <scope>test</scope> + </dependency> + + <!-- Joram JMS conformance tests --> + <dependency> + <groupId>org.fusesource.joram-jms-tests</groupId> + <artifactId>joram-jms-tests</artifactId> + <version>${fuse-joram-tests-version}</version> + <scope>test</scope> + </dependency> + <dependency> + <!-- using it for Jetty's JNDI context to work /w Joram tests. --> + <groupId>org.eclipse.jetty.aggregate</groupId> + <artifactId>jetty-all-server</artifactId> + <version>${jetty-version}</version> + <scope>test</scope> + </dependency> + <dependency> + <groupId>org.apache.activemq</groupId> + <artifactId>activemq-broker</artifactId> + <version>${activemq-version}</version> + <scope>test</scope> + </dependency> + <dependency> + <groupId>org.apache.activemq</groupId> + <artifactId>activemq-kahadb-store</artifactId> + <version>${activemq-version}</version> + <scope>test</scope> + </dependency> + <dependency> + <groupId>org.apache.activemq</groupId> + <artifactId>activemq-amqp</artifactId> + <version>${activemq-version}</version> + <scope>test</scope> + </dependency> + <dependency> + <groupId>org.apache.activemq</groupId> + <artifactId>activemq-jaas</artifactId> + <version>${activemq-version}</version> + <scope>test</scope> + </dependency> + <dependency> + <groupId>org.apache.activemq</groupId> + <artifactId>activemq-spring</artifactId> + <version>${activemq-version}</version> + <scope>test</scope> + </dependency> + </dependencies> + + <build> + <resources> + <resource> + <directory>${project.basedir}/src/main/resources</directory> + <includes> + <include>**/*</include> + </includes> + </resource> + <resource> + <directory>${project.basedir}/src/main/filtered-resources</directory> + <filtering>true</filtering> + <includes> + <include>**/*</include> + </includes> + </resource> + </resources> + </build> + + <reporting> + <plugins> + <plugin> + <groupId>org.codehaus.mojo</groupId> + <artifactId>findbugs-maven-plugin</artifactId> + <version>${findbugs-maven-plugin-version}</version> + <configuration> + <threshold>Normal</threshold> + <effort>Default</effort> + </configuration> + </plugin> + </plugins> + </reporting> + +</project> http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/e4decdc1/qpid-jms-client/src/main/filtered-resources/org/apache/qpid/jms/version.txt ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/filtered-resources/org/apache/qpid/jms/version.txt b/qpid-jms-client/src/main/filtered-resources/org/apache/qpid/jms/version.txt new file mode 100644 index 0000000..f2ab45c --- /dev/null +++ b/qpid-jms-client/src/main/filtered-resources/org/apache/qpid/jms/version.txt @@ -0,0 +1 @@ +${project.version} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/e4decdc1/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsClientProperties.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsClientProperties.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsClientProperties.java new file mode 100644 index 0000000..496ffd0 --- /dev/null +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsClientProperties.java @@ -0,0 +1,36 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.apache.qpid.jms; + +public class JmsClientProperties { + + /** + * JMS-defined message property representing the user who sent a message. + */ + public static final String JMSXUSERID = "JMSXUserID"; + + /** + * JMS-defined message property representing the group a message belongs to. + */ + public static final String JMSXGROUPID = "JMSXGroupID"; + + /** + * JMS-defined message property representing the sequence number of a message within a group. + */ + public static final String JMSXGROUPSEQ = "JMSXGroupSeq"; + +} --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
