You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ta...@apache.org on 2014/09/23 20:20:51 UTC
[27/27] git commit: Initial drop of donated AMQP Client Code.
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 <ta...@gmail.com>
Authored: Tue Sep 23 14:09:26 2014 -0400
Committer: Timothy Bish <ta...@gmail.com>
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: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org