From 0a0baee45ebcff44635907d457c4ff6810b09c87 Mon Sep 17 00:00:00 2001 From: Alex Rudyy Date: Wed, 15 Apr 2015 09:47:28 +0000 Subject: QPID-6481: Move java source tree to top level git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1673693 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/java/client/README.txt | 49 - qpid/java/client/example/README.txt | 17 - qpid/java/client/example/pom.xml | 66 - .../main/java/org/apache/qpid/example/Drain.java | 103 - .../main/java/org/apache/qpid/example/Hello.java | 83 - .../java/org/apache/qpid/example/ListReceiver.java | 101 - .../java/org/apache/qpid/example/ListSender.java | 86 - .../java/org/apache/qpid/example/MapReceiver.java | 52 - .../java/org/apache/qpid/example/MapSender.java | 83 - .../java/org/apache/qpid/example/OptionParser.java | 351 -- .../main/java/org/apache/qpid/example/Spout.java | 149 - .../java/org/apache/qpid/example/hello.properties | 27 - qpid/java/client/pom.xml | 126 - qpid/java/client/src/main/assembly/LICENSE | 234 -- qpid/java/client/src/main/assembly/NOTICE | 10 - qpid/java/client/src/main/assembly/README.txt | 3 - .../dependency-verification/DEPENDENCIES_REFERENCE | 36 - .../client/src/main/assembly/qpid-client-bin.xml | 69 - qpid/java/client/src/main/java/client.bnd | 27 - qpid/java/client/src/main/java/client.log4j | 33 - .../org/apache/qpid/client/AMQAnyDestination.java | 95 - .../qpid/client/AMQAuthenticationException.java | 37 - .../org/apache/qpid/client/AMQBrokerDetails.java | 507 --- .../java/org/apache/qpid/client/AMQConnection.java | 1694 --------- .../apache/qpid/client/AMQConnectionDelegate.java | 86 - .../qpid/client/AMQConnectionDelegate_0_10.java | 633 ---- .../qpid/client/AMQConnectionDelegate_0_9.java | 40 - .../qpid/client/AMQConnectionDelegate_8_0.java | 579 --- .../qpid/client/AMQConnectionDelegate_9_1.java | 39 - .../apache/qpid/client/AMQConnectionFactory.java | 456 --- .../org/apache/qpid/client/AMQConnectionURL.java | 389 --- .../org/apache/qpid/client/AMQDestination.java | 1078 ------ .../org/apache/qpid/client/AMQHeadersExchange.java | 56 - .../qpid/client/AMQNoConsumersException.java | 35 - .../apache/qpid/client/AMQNoRouteException.java | 35 - .../main/java/org/apache/qpid/client/AMQQueue.java | 188 - .../org/apache/qpid/client/AMQQueueBrowser.java | 223 -- .../apache/qpid/client/AMQQueueSessionAdaptor.java | 83 - .../java/org/apache/qpid/client/AMQSession.java | 3678 -------------------- .../org/apache/qpid/client/AMQSessionAdapter.java | 191 - .../qpid/client/AMQSessionDirtyException.java | 37 - .../org/apache/qpid/client/AMQSession_0_10.java | 1487 -------- .../org/apache/qpid/client/AMQSession_0_8.java | 1565 --------- .../org/apache/qpid/client/AMQTemporaryQueue.java | 70 - .../org/apache/qpid/client/AMQTemporaryTopic.java | 77 - .../main/java/org/apache/qpid/client/AMQTopic.java | 255 -- .../apache/qpid/client/AMQTopicSessionAdaptor.java | 70 - .../qpid/client/AMQUndefinedDestination.java | 47 - .../java/org/apache/qpid/client/AMQXAResource.java | 32 - .../apache/qpid/client/BasicMessageConsumer.java | 1094 ------ .../qpid/client/BasicMessageConsumer_0_10.java | 621 ---- .../qpid/client/BasicMessageConsumer_0_8.java | 239 -- .../apache/qpid/client/BasicMessageProducer.java | 736 ---- .../qpid/client/BasicMessageProducer_0_10.java | 282 -- .../qpid/client/BasicMessageProducer_0_8.java | 389 --- .../apache/qpid/client/ChannelToSessionMap.java | 103 - .../java/org/apache/qpid/client/Closeable.java | 107 - .../qpid/client/ConnectionTuneParameters.java | 73 - .../org/apache/qpid/client/CustomJMSXProperty.java | 67 - .../org/apache/qpid/client/HeartbeatListener.java | 37 - .../org/apache/qpid/client/JMSAMQException.java | 62 - .../qpid/client/JmsNotImplementedException.java | 31 - .../apache/qpid/client/MessageConsumerPair.java | 43 - .../apache/qpid/client/QpidConnectionMetaData.java | 97 - .../apache/qpid/client/QueueReceiverAdaptor.java | 115 - .../org/apache/qpid/client/QueueSenderAdapter.java | 227 -- .../org/apache/qpid/client/RejectBehaviour.java | 32 - .../apache/qpid/client/TemporaryDestination.java | 41 - .../apache/qpid/client/TopicPublisherAdapter.java | 205 -- .../apache/qpid/client/TopicSubscriberAdaptor.java | 133 - .../client/UnsupportedAddressSyntaxException.java | 32 - .../org/apache/qpid/client/XAConnectionImpl.java | 91 - .../org/apache/qpid/client/XAResourceImpl.java | 602 ---- .../java/org/apache/qpid/client/XASessionImpl.java | 205 -- .../failover/ConnectionRedirectException.java | 46 - .../qpid/client/failover/FailoverException.java | 44 - .../qpid/client/failover/FailoverHandler.java | 257 -- .../qpid/client/failover/FailoverNoopSupport.java | 75 - .../failover/FailoverProtectedOperation.java | 44 - .../qpid/client/failover/FailoverRetrySupport.java | 92 - .../apache/qpid/client/failover/FailoverState.java | 59 - .../qpid/client/failover/FailoverSupport.java | 42 - .../qpid/client/filter/JMSSelectorFilter.java | 213 -- .../apache/qpid/client/filter/MessageFilter.java | 27 - .../handler/AccessRequestOkMethodHandler.java | 50 - .../client/handler/BasicCancelOkMethodHandler.java | 55 - .../client/handler/BasicDeliverMethodHandler.java | 58 - .../client/handler/BasicReturnMethodHandler.java | 58 - .../client/handler/ChannelCloseMethodHandler.java | 120 - .../handler/ChannelCloseOkMethodHandler.java | 50 - .../client/handler/ChannelFlowMethodHandler.java | 52 - .../client/handler/ChannelFlowOkMethodHandler.java | 52 - .../client/handler/ClientMethodDispatcherImpl.java | 466 --- .../handler/ClientMethodDispatcherImpl_0_9.java | 67 - .../handler/ClientMethodDispatcherImpl_0_91.java | 67 - .../handler/ClientMethodDispatcherImpl_8_0.java | 70 - .../handler/CloseWhenNoRouteSettingsHelper.java | 75 - .../handler/ConnectionCloseMethodHandler.java | 117 - .../handler/ConnectionOpenOkMethodHandler.java | 47 - .../handler/ConnectionRedirectMethodHandler.java | 90 - .../handler/ConnectionSecureMethodHandler.java | 70 - .../handler/ConnectionStartMethodHandler.java | 227 -- .../handler/ConnectionTuneMethodHandler.java | 90 - .../handler/ExchangeBoundOkMethodHandler.java | 57 - .../client/handler/QueueDeleteOkMethodHandler.java | 57 - .../qpid/client/message/AMQMessageDelegate.java | 137 - .../client/message/AMQMessageDelegateFactory.java | 49 - .../client/message/AMQMessageDelegate_0_10.java | 1002 ------ .../client/message/AMQMessageDelegate_0_8.java | 683 ---- .../client/message/AMQPEncodedListMessage.java | 935 ----- .../message/AMQPEncodedListMessageFactory.java | 44 - .../qpid/client/message/AMQPEncodedMapMessage.java | 110 - .../message/AMQPEncodedMapMessageFactory.java | 46 - .../client/message/AbstractAMQMessageDelegate.java | 347 -- .../client/message/AbstractBytesTypedMessage.java | 115 - .../qpid/client/message/AbstractJMSMessage.java | 463 --- .../client/message/AbstractJMSMessageFactory.java | 247 -- .../qpid/client/message/CloseConsumerMessage.java | 43 - .../qpid/client/message/FieldTableSupport.java | 61 - .../qpid/client/message/JMSBytesMessage.java | 369 -- .../client/message/JMSBytesMessageFactory.java | 42 - .../qpid/client/message/JMSHeaderAdapter.java | 476 --- .../apache/qpid/client/message/JMSMapMessage.java | 518 --- .../qpid/client/message/JMSMapMessageFactory.java | 40 - .../qpid/client/message/JMSObjectMessage.java | 210 -- .../client/message/JMSObjectMessageFactory.java | 39 - .../qpid/client/message/JMSStreamMessage.java | 378 -- .../client/message/JMSStreamMessageFactory.java | 38 - .../apache/qpid/client/message/JMSTextMessage.java | 161 - .../qpid/client/message/JMSTextMessageFactory.java | 40 - .../qpid/client/message/MessageConverter.java | 202 -- .../apache/qpid/client/message/MessageFactory.java | 57 - .../client/message/MessageFactoryRegistry.java | 185 - .../qpid/client/message/QpidMessageProperties.java | 39 - .../apache/qpid/client/message/ReturnMessage.java | 47 - .../qpid/client/message/UnprocessedMessage.java | 57 - .../client/message/UnprocessedMessage_0_10.java | 53 - .../client/message/UnprocessedMessage_0_8.java | 163 - .../client/messaging/address/AddressHelper.java | 307 -- .../apache/qpid/client/messaging/address/Link.java | 231 -- .../apache/qpid/client/messaging/address/Node.java | 133 - .../messaging/address/QpidExchangeOptions.java | 45 - .../client/messaging/address/QpidQueueOptions.java | 85 - .../qpid/client/protocol/AMQProtocolHandler.java | 964 ----- .../qpid/client/protocol/AMQProtocolSession.java | 555 --- .../protocol/BlockingMethodFrameListener.java | 124 - .../qpid/client/security/AMQCallbackHandler.java | 30 - .../client/security/CallbackHandlerRegistry.java | 315 -- .../security/CallbackHandlerRegistry.properties | 36 - .../qpid/client/security/DynamicSaslRegistrar.java | 219 -- .../security/DynamicSaslRegistrar.properties | 23 - .../apache/qpid/client/security/JCAProvider.java | 73 - .../UsernameHashedPasswordCallbackHandler.java | 101 - .../security/UsernamePasswordCallbackHandler.java | 64 - .../security/amqplain/AmqPlainSaslClient.java | 105 - .../amqplain/AmqPlainSaslClientFactory.java | 62 - .../security/anonymous/AnonymousSaslClient.java | 52 - .../anonymous/AnonymousSaslClientFactory.java | 50 - .../crammd5hashed/CRAMMD5HashedSaslClient.java | 91 - .../CRAMMD5HashedSaslClientFactory.java | 68 - .../security/scram/AbstractScramSaslClient.java | 350 -- .../client/security/scram/ScramSHA1SaslClient.java | 34 - .../security/scram/ScramSHA1SaslClientFactory.java | 60 - .../security/scram/ScramSHA256SaslClient.java | 34 - .../scram/ScramSHA256SaslClientFactory.java | 61 - .../state/AMQMethodNotImplementedException.java | 32 - .../org/apache/qpid/client/state/AMQState.java | 60 - .../qpid/client/state/AMQStateChangedEvent.java | 48 - .../apache/qpid/client/state/AMQStateListener.java | 26 - .../apache/qpid/client/state/AMQStateManager.java | 228 -- .../client/state/StateAwareMethodListener.java | 37 - .../org/apache/qpid/client/state/StateWaiter.java | 132 - .../listener/SpecificMethodFrameListener.java | 41 - .../client/transport/ClientConnectionDelegate.java | 199 -- .../java/org/apache/qpid/client/url/URLParser.java | 249 -- .../org/apache/qpid/client/url/URLParser_0_10.java | 424 --- .../apache/qpid/client/util/BlockingWaiter.java | 336 -- .../util/ClassLoadingAwareObjectInputStream.java | 134 - .../client/util/FlowControllingBlockingQueue.java | 185 - .../java/org/apache/qpid/jms/BrokerDetails.java | 108 - .../qpid/jms/ChannelLimitReachedException.java | 46 - .../main/java/org/apache/qpid/jms/Connection.java | 69 - .../org/apache/qpid/jms/ConnectionListener.java | 58 - .../java/org/apache/qpid/jms/ConnectionURL.java | 131 - .../java/org/apache/qpid/jms/FailoverPolicy.java | 316 -- .../main/java/org/apache/qpid/jms/ListMessage.java | 55 - .../src/main/java/org/apache/qpid/jms/Message.java | 30 - .../java/org/apache/qpid/jms/MessageConsumer.java | 27 - .../java/org/apache/qpid/jms/MessageProducer.java | 39 - .../src/main/java/org/apache/qpid/jms/Session.java | 106 - .../java/org/apache/qpid/jms/TopicSubscriber.java | 32 - .../qpid/jms/failover/FailoverExchangeMethod.java | 317 -- .../apache/qpid/jms/failover/FailoverMethod.java | 79 - .../jms/failover/FailoverRoundRobinServers.java | 250 -- .../qpid/jms/failover/FailoverSingleServer.java | 177 - .../org/apache/qpid/jms/failover/NoFailover.java | 62 - .../java/org/apache/qpid/jndi/Example.properties | 40 - .../java/org/apache/qpid/jndi/NameParserImpl.java | 37 - .../jndi/PropertiesFileInitialContextFactory.java | 380 -- .../java/org/apache/qpid/jndi/ReadOnlyContext.java | 521 --- .../apache/qpid/nclient/MessagePartListener.java | 43 - .../qpid/nclient/util/ByteBufferMessage.java | 193 - .../apache/qpid/nclient/util/MessageListener.java | 34 - .../nclient/util/MessagePartListenerAdapter.java | 79 - .../qpid/client/AMQConnectionFactoryTest.java | 106 - .../apache/qpid/client/AMQConnectionUnitTest.java | 118 - .../org/apache/qpid/client/AMQDestinationTest.java | 230 -- .../java/org/apache/qpid/client/AMQQueueTest.java | 42 - .../apache/qpid/client/AMQSession_0_10Test.java | 697 ---- .../org/apache/qpid/client/AMQSession_0_8Test.java | 73 - .../qpid/client/BasicMessageConsumer_0_8_Test.java | 107 - .../qpid/client/ConnectionListenerSupport.java | 55 - .../apache/qpid/client/DispatcherDaemonTest.java | 67 - .../org/apache/qpid/client/MockAMQConnection.java | 69 - .../CloseWhenNoRouteSettingsHelperTest.java | 77 - .../message/AMQMessageDelegate_0_10Test.java | 140 - .../message/AMQPEncodedListMessageUnitTest.java | 153 - .../client/message/AbstractJMSMessageTest.java | 57 - .../qpid/client/message/TestMessageHelper.java | 51 - .../messaging/address/AddressHelperTest.java | 146 - .../client/protocol/AMQProtocolHandlerTest.java | 291 -- .../security/CallbackHandlerRegistryTest.java | 184 - .../client/security/DynamicSaslRegistrarTest.java | 140 - .../UsernameHashedPasswordCallbackHandlerTest.java | 94 - .../UsernamePasswordCallbackHandlerTest.java | 74 - .../apache/qpid/client/transport/MockSender.java | 44 - .../client/transport/TestNetworkConnection.java | 158 - .../ClassLoadingAwareObjectInputStreamTest.java | 86 - .../apache/qpid/filter/JMSSelectorFilterTest.java | 110 - .../org/apache/qpid/jms/FailoverPolicyTest.java | 338 -- .../java/org/apache/qpid/jndi/JNDITest.properties | 28 - .../PropertiesFileInitialContextFactoryTest.java | 137 - .../unit/basic/FieldTableKeyEnumeratorTest.java | 95 - .../test/unit/basic/FieldTablePropertyTest.java | 61 - .../client/BrokerDetails/BrokerDetailsTest.java | 227 -- .../ChannelCloseMethodHandlerNoCloseOk.java | 97 - .../client/channelclose/NoCloseOKStateManager.java | 36 - .../client/connectionurl/ConnectionURLTest.java | 654 ---- .../client/destinationurl/DestinationURLTest.java | 410 --- .../test/unit/client/message/BytesMessageTest.java | 568 --- .../test/unit/client/message/MapMessageTest.java | 383 -- .../unit/client/message/ObjectMessageUnitTest.java | 105 - .../unit/client/message/StreamMessageTest.java | 622 ---- .../test/unit/client/message/TextMessageTest.java | 300 -- .../test/unit/message/MessageConverterTest.java | 151 - .../qpid/test/unit/message/NonQpidMessage.java | 419 --- .../qpid/test/unit/message/TestAMQSession.java | 208 -- .../org/apache/qpid/test/unit/tests.properties | 45 - 248 files changed, 49306 deletions(-) delete mode 100644 qpid/java/client/README.txt delete mode 100644 qpid/java/client/example/README.txt delete mode 100644 qpid/java/client/example/pom.xml delete mode 100644 qpid/java/client/example/src/main/java/org/apache/qpid/example/Drain.java delete mode 100644 qpid/java/client/example/src/main/java/org/apache/qpid/example/Hello.java delete mode 100644 qpid/java/client/example/src/main/java/org/apache/qpid/example/ListReceiver.java delete mode 100644 qpid/java/client/example/src/main/java/org/apache/qpid/example/ListSender.java delete mode 100644 qpid/java/client/example/src/main/java/org/apache/qpid/example/MapReceiver.java delete mode 100644 qpid/java/client/example/src/main/java/org/apache/qpid/example/MapSender.java delete mode 100644 qpid/java/client/example/src/main/java/org/apache/qpid/example/OptionParser.java delete mode 100644 qpid/java/client/example/src/main/java/org/apache/qpid/example/Spout.java delete mode 100644 qpid/java/client/example/src/main/java/org/apache/qpid/example/hello.properties delete mode 100644 qpid/java/client/pom.xml delete mode 100644 qpid/java/client/src/main/assembly/LICENSE delete mode 100644 qpid/java/client/src/main/assembly/NOTICE delete mode 100644 qpid/java/client/src/main/assembly/README.txt delete mode 100644 qpid/java/client/src/main/assembly/dependency-verification/DEPENDENCIES_REFERENCE delete mode 100644 qpid/java/client/src/main/assembly/qpid-client-bin.xml delete mode 100755 qpid/java/client/src/main/java/client.bnd delete mode 100644 qpid/java/client/src/main/java/client.log4j delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/AMQAnyDestination.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/AMQAuthenticationException.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/AMQBrokerDetails.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java delete mode 100755 qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_9.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_8_0.java delete mode 100755 qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_9_1.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionFactory.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnectionURL.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/AMQDestination.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/AMQHeadersExchange.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/AMQNoConsumersException.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/AMQNoRouteException.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/AMQQueue.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/AMQQueueBrowser.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/AMQQueueSessionAdaptor.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/AMQSessionAdapter.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/AMQSessionDirtyException.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_8.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/AMQTemporaryQueue.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/AMQTemporaryTopic.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/AMQTopic.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/AMQTopicSessionAdaptor.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/AMQUndefinedDestination.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/AMQXAResource.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_8.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_8.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/ChannelToSessionMap.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/Closeable.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/ConnectionTuneParameters.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/CustomJMSXProperty.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/HeartbeatListener.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/JMSAMQException.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/JmsNotImplementedException.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/MessageConsumerPair.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/QpidConnectionMetaData.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/QueueReceiverAdaptor.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/QueueSenderAdapter.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/RejectBehaviour.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/TemporaryDestination.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/TopicPublisherAdapter.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/TopicSubscriberAdaptor.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/UnsupportedAddressSyntaxException.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/XAConnectionImpl.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/XAResourceImpl.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/XASessionImpl.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/failover/ConnectionRedirectException.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/failover/FailoverException.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/failover/FailoverHandler.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/failover/FailoverNoopSupport.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/failover/FailoverProtectedOperation.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/failover/FailoverRetrySupport.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/failover/FailoverState.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/failover/FailoverSupport.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/filter/JMSSelectorFilter.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/filter/MessageFilter.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/handler/AccessRequestOkMethodHandler.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/handler/BasicCancelOkMethodHandler.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/handler/BasicDeliverMethodHandler.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/handler/BasicReturnMethodHandler.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/handler/ChannelCloseMethodHandler.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/handler/ChannelCloseOkMethodHandler.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/handler/ChannelFlowMethodHandler.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/handler/ChannelFlowOkMethodHandler.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/handler/ClientMethodDispatcherImpl.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/handler/ClientMethodDispatcherImpl_0_9.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/handler/ClientMethodDispatcherImpl_0_91.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/handler/ClientMethodDispatcherImpl_8_0.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/handler/CloseWhenNoRouteSettingsHelper.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/handler/ConnectionCloseMethodHandler.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/handler/ConnectionOpenOkMethodHandler.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/handler/ConnectionRedirectMethodHandler.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/handler/ConnectionSecureMethodHandler.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/handler/ConnectionStartMethodHandler.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/handler/ConnectionTuneMethodHandler.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/handler/ExchangeBoundOkMethodHandler.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/handler/QueueDeleteOkMethodHandler.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/AMQMessageDelegate.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/AMQMessageDelegateFactory.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/AMQMessageDelegate_0_10.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/AMQMessageDelegate_0_8.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/AMQPEncodedListMessage.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/AMQPEncodedListMessageFactory.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/AMQPEncodedMapMessage.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/AMQPEncodedMapMessageFactory.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/AbstractAMQMessageDelegate.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/AbstractBytesTypedMessage.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessage.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/AbstractJMSMessageFactory.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/CloseConsumerMessage.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/FieldTableSupport.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/JMSBytesMessage.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/JMSBytesMessageFactory.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/JMSHeaderAdapter.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/JMSMapMessage.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/JMSMapMessageFactory.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/JMSObjectMessage.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/JMSObjectMessageFactory.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/JMSStreamMessage.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/JMSStreamMessageFactory.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/JMSTextMessage.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/JMSTextMessageFactory.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/MessageConverter.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/MessageFactory.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/MessageFactoryRegistry.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/QpidMessageProperties.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/ReturnMessage.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/UnprocessedMessage.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/UnprocessedMessage_0_10.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/message/UnprocessedMessage_0_8.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/messaging/address/AddressHelper.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/messaging/address/Link.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/messaging/address/Node.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/messaging/address/QpidExchangeOptions.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/messaging/address/QpidQueueOptions.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/protocol/BlockingMethodFrameListener.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/security/AMQCallbackHandler.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/security/CallbackHandlerRegistry.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/security/CallbackHandlerRegistry.properties delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/security/DynamicSaslRegistrar.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/security/DynamicSaslRegistrar.properties delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/security/JCAProvider.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/security/UsernameHashedPasswordCallbackHandler.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/security/UsernamePasswordCallbackHandler.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/security/amqplain/AmqPlainSaslClient.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/security/amqplain/AmqPlainSaslClientFactory.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/security/anonymous/AnonymousSaslClient.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/security/anonymous/AnonymousSaslClientFactory.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/security/crammd5hashed/CRAMMD5HashedSaslClient.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/security/crammd5hashed/CRAMMD5HashedSaslClientFactory.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/security/scram/AbstractScramSaslClient.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/security/scram/ScramSHA1SaslClient.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/security/scram/ScramSHA1SaslClientFactory.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/security/scram/ScramSHA256SaslClient.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/security/scram/ScramSHA256SaslClientFactory.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/state/AMQMethodNotImplementedException.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/state/AMQState.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/state/AMQStateChangedEvent.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/state/AMQStateListener.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/state/AMQStateManager.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/state/StateAwareMethodListener.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/state/StateWaiter.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/state/listener/SpecificMethodFrameListener.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/transport/ClientConnectionDelegate.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/url/URLParser.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/url/URLParser_0_10.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/util/BlockingWaiter.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/util/ClassLoadingAwareObjectInputStream.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/client/util/FlowControllingBlockingQueue.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/jms/BrokerDetails.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/jms/ChannelLimitReachedException.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/jms/Connection.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/jms/ConnectionListener.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/jms/ConnectionURL.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/jms/FailoverPolicy.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/jms/ListMessage.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/jms/Message.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/jms/MessageConsumer.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/jms/MessageProducer.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/jms/Session.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/jms/TopicSubscriber.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/jms/failover/FailoverExchangeMethod.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/jms/failover/FailoverMethod.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/jms/failover/FailoverRoundRobinServers.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/jms/failover/FailoverSingleServer.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/jms/failover/NoFailover.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/jndi/Example.properties delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/jndi/NameParserImpl.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/jndi/PropertiesFileInitialContextFactory.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/jndi/ReadOnlyContext.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/nclient/MessagePartListener.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/nclient/util/ByteBufferMessage.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/nclient/util/MessageListener.java delete mode 100644 qpid/java/client/src/main/java/org/apache/qpid/nclient/util/MessagePartListenerAdapter.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/client/AMQConnectionFactoryTest.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/client/AMQConnectionUnitTest.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/client/AMQDestinationTest.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/client/AMQQueueTest.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/client/AMQSession_0_10Test.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/client/AMQSession_0_8Test.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/client/BasicMessageConsumer_0_8_Test.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/client/ConnectionListenerSupport.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/client/DispatcherDaemonTest.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/client/MockAMQConnection.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/client/handler/CloseWhenNoRouteSettingsHelperTest.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/client/message/AMQMessageDelegate_0_10Test.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/client/message/AMQPEncodedListMessageUnitTest.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/client/message/AbstractJMSMessageTest.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/client/message/TestMessageHelper.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/client/messaging/address/AddressHelperTest.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/client/protocol/AMQProtocolHandlerTest.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/client/security/CallbackHandlerRegistryTest.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/client/security/DynamicSaslRegistrarTest.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/client/security/UsernameHashedPasswordCallbackHandlerTest.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/client/security/UsernamePasswordCallbackHandlerTest.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/client/transport/MockSender.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/client/transport/TestNetworkConnection.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/client/util/ClassLoadingAwareObjectInputStreamTest.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/filter/JMSSelectorFilterTest.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/jms/FailoverPolicyTest.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/jndi/JNDITest.properties delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/jndi/PropertiesFileInitialContextFactoryTest.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/test/unit/basic/FieldTableKeyEnumeratorTest.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/test/unit/basic/FieldTablePropertyTest.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/BrokerDetails/BrokerDetailsTest.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/channelclose/ChannelCloseMethodHandlerNoCloseOk.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/channelclose/NoCloseOKStateManager.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/connectionurl/ConnectionURLTest.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/destinationurl/DestinationURLTest.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/message/BytesMessageTest.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/message/MapMessageTest.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/message/ObjectMessageUnitTest.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/message/StreamMessageTest.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/test/unit/client/message/TextMessageTest.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/test/unit/message/MessageConverterTest.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/test/unit/message/NonQpidMessage.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/test/unit/message/TestAMQSession.java delete mode 100644 qpid/java/client/src/test/java/org/apache/qpid/test/unit/tests.properties (limited to 'qpid/java/client') diff --git a/qpid/java/client/README.txt b/qpid/java/client/README.txt deleted file mode 100644 index a8c7da32c5..0000000000 --- a/qpid/java/client/README.txt +++ /dev/null @@ -1,49 +0,0 @@ -Documentation -============= - -You can access documentation for the client via our website at: -http://qpid.apache.org/documentation - -and via our wiki at: -http://cwiki.apache.org/confluence/display/qpid/Qpid+Java+Documentation - -The client uses the Java Message Service (JMS) 1.1 API, information on which is -widely available using your favoured search engine. - - -Running the Examples: -===================== - -1. From the client Binary distribution: - -From the /qpid-client- directory, there are examples -provided in source form in the example/src sub-directory. These are also -provided in binary form in the example/lib directory in order that they can be -run more easily. - -E.g, in order to run the Hello example, you would add the client+example library -files to the java classpath and launch the example like follows: - -java -cp "lib/qpid-all.jar:example/lib/qpid-client-example-.jar" \ - org.apache.qpid.example.Hello - -NOTE: The client uses the SL4FJ API for its logging. You must supply a logging -implementation of your choice (eg Log4J) and its associated SLF4J binding, by -also adding them to the Java classpath as well as the client libraries -themselves. Failure to do so will result in a warning being output and use of -NoOp logging by the client. - -More information on using SLF4J is available at http://www.slf4j.org/manual.html -which details some of the supported logging implementations and their -associated SLF4 bindings as available in the SLF4J distribution. - - - -2. From the Source distribution / repository: - -Run 'ant build' in the parent directory from where this file is stored, ie: -/qpid/java - -This will build the various Java modules, leaving binary .jar files output in: -/qpid/java/build/lib - diff --git a/qpid/java/client/example/README.txt b/qpid/java/client/example/README.txt deleted file mode 100644 index 36e4351a51..0000000000 --- a/qpid/java/client/example/README.txt +++ /dev/null @@ -1,17 +0,0 @@ -=========================== -Running the client examples -=========================== - -Use maven to build the module, and additionally copy the dependencies -alongside their output: - - mvn clean package dependency:copy-dependencies -DincludeScope=runtime -DskipTests - -Now you can run the examples using commands of the format: - - java -cp "target/classes/:target/dependency/*" org.apache.qpid.example.Hello - - -NOTE: The earlier build command will cause Maven to resolve the client artifact -dependencies against its local and remote repositories. If you wish to use a -locally-built client, ensure to install it in your local maven repo first. diff --git a/qpid/java/client/example/pom.xml b/qpid/java/client/example/pom.xml deleted file mode 100644 index 8015f94624..0000000000 --- a/qpid/java/client/example/pom.xml +++ /dev/null @@ -1,66 +0,0 @@ - - - - 4.0.0 - - - org.apache.qpid - qpid-java-build - 0.32-SNAPSHOT - ../../pom.xml - - - qpid-client-examples - Qpid AMQP 0-x JMS Client Examples - JMS client examples. - - - - org.apache.qpid - qpid-client - ${project.version} - - - - org.apache.geronimo.specs - geronimo-jms_1.1_spec - ${geronimo-jms-1-1-version} - - - - org.slf4j - slf4j-api - ${slf4j-version} - - - - - - - src/main/resources - - - src/main/java - - **/*.java - - - - - - diff --git a/qpid/java/client/example/src/main/java/org/apache/qpid/example/Drain.java b/qpid/java/client/example/src/main/java/org/apache/qpid/example/Drain.java deleted file mode 100644 index f0eb83ad24..0000000000 --- a/qpid/java/client/example/src/main/java/org/apache/qpid/example/Drain.java +++ /dev/null @@ -1,103 +0,0 @@ -/* - * - * 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.example; - -import javax.jms.Connection; -import javax.jms.Destination; -import javax.jms.Message; -import javax.jms.MessageConsumer; -import javax.jms.Session; - -import org.apache.qpid.client.AMQAnyDestination; - -public class Drain extends OptionParser -{ - - static final Option FOREVER = new Option("f", - "forever", - "ignore timeout and wait forever", - null, - null, - Boolean.class); - - static final Option COUNT = new Option ("c", - "count", - "read c messages, then exit", - "COUNT", - "0", - Integer.class); - - - static - { - addOption(BROKER); - addOption(HELP); - addOption(TIMEOUT); - addOption(FOREVER); - addOption(COUNT); - addOption(CON_OPTIONS); - addOption(BROKER_OPTIONS); - } - - public Drain(String[] args, String usage, String desc) throws Exception - { - super(args, usage, desc); - - Connection con = createConnection(); - con.start(); - Session ssn = con.createSession(false,Session.AUTO_ACKNOWLEDGE); - Destination dest = new AMQAnyDestination(getAddress()); - MessageConsumer consumer = ssn.createConsumer(dest); - Message msg; - - long timeout = -1; - int count = 0; - int i = 0; - - if (containsOp(TIMEOUT)) { timeout = Integer.parseInt(getOp(TIMEOUT))*1000; } - if (containsOp(FOREVER)) { timeout = 0; } - if (containsOp(COUNT)) { count = Integer.parseInt(getOp(COUNT)); } - - while ((msg = consumer.receive(timeout)) != null) - { - System.out.println("\n------------- Msg -------------"); - System.out.println(msg); - System.out.println("-------------------------------\n"); - - if (count > 0) { - if (++i == count) { - break; - } - } - } - consumer.close(); - ssn.close(); - con.close(); - } - - public static void main(String[] args) throws Exception - { - String u = "Usage: drain [OPTIONS] 'ADDRESS'"; - String d = "Drains messages from the specified address."; - - new Drain(args,u,d); - } -} diff --git a/qpid/java/client/example/src/main/java/org/apache/qpid/example/Hello.java b/qpid/java/client/example/src/main/java/org/apache/qpid/example/Hello.java deleted file mode 100644 index 109a72bcbf..0000000000 --- a/qpid/java/client/example/src/main/java/org/apache/qpid/example/Hello.java +++ /dev/null @@ -1,83 +0,0 @@ -/* - * - * 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.example; - -import java.io.InputStream; -import java.util.Properties; - -import javax.jms.Connection; -import javax.jms.ConnectionFactory; -import javax.jms.Destination; -import javax.jms.MessageConsumer; -import javax.jms.MessageProducer; -import javax.jms.Session; -import javax.jms.TextMessage; -import javax.naming.Context; -import javax.naming.InitialContext; - - -public class Hello -{ - - public Hello() - { - } - - public static void main(String[] args) - { - Hello hello = new Hello(); - hello.runTest(); - } - - private void runTest() - { - try (InputStream resourceAsStream = this.getClass().getResourceAsStream("hello.properties")) - { - Properties properties = new Properties(); - properties.load(resourceAsStream); - Context context = new InitialContext(properties); - - ConnectionFactory connectionFactory = (ConnectionFactory) context.lookup("qpidConnectionfactory"); - Connection connection = connectionFactory.createConnection(); - connection.start(); - - Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); - Destination destination = (Destination) context.lookup("topicExchange"); - - MessageProducer messageProducer = session.createProducer(destination); - MessageConsumer messageConsumer = session.createConsumer(destination); - - TextMessage message = session.createTextMessage("Hello world!"); - messageProducer.send(message); - - message = (TextMessage)messageConsumer.receive(); - System.out.println(message.getText()); - - connection.close(); - context.close(); - } - catch (Exception exp) - { - exp.printStackTrace(); - } - } -} diff --git a/qpid/java/client/example/src/main/java/org/apache/qpid/example/ListReceiver.java b/qpid/java/client/example/src/main/java/org/apache/qpid/example/ListReceiver.java deleted file mode 100644 index b12cfab9de..0000000000 --- a/qpid/java/client/example/src/main/java/org/apache/qpid/example/ListReceiver.java +++ /dev/null @@ -1,101 +0,0 @@ -/* - * - * 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.example; - -import javax.jms.Connection; -import javax.jms.Destination; -import javax.jms.MapMessage; -import javax.jms.StreamMessage; -import javax.jms.MessageConsumer; -import javax.jms.Session; -import javax.jms.MessageEOFException; - -import org.apache.qpid.client.AMQAnyDestination; -import org.apache.qpid.client.AMQConnection; - -import org.apache.qpid.jms.ListMessage; - -import java.util.Enumeration; -import java.util.Iterator; - -public class ListReceiver { - - public static void main(String[] args) throws Exception - { - if (args.length != 1) { - System.out.println("Usage: java org.apache.qpid.example.ListReceiver <-l | -m | -s>"); - System.out.println("where:"); - System.out.println("\t-l\tAccept ListMessage and print it"); - System.out.println("\t-m\tAccept ListMessage as a MapMessage"); - System.out.println("\t-s\tAccept ListMessage as a StreamMessage"); - return; - } - - Connection connection = - new AMQConnection("amqp://guest:guest@test/?brokerlist='tcp://localhost:5672'"); - - connection.start(); - - Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); - Destination queue = new AMQAnyDestination("ADDR:message_queue; {create: always}"); - MessageConsumer consumer = session.createConsumer(queue); - - if (args[0].equals("-l")) { - System.out.println("Receiving as ListMessage"); - ListMessage m = (ListMessage)consumer.receive(); - System.out.println(m); - System.out.println("=========================================="); - System.out.println("Printing list contents:"); - Iterator i = m.iterator(); - while(i.hasNext()) - System.out.println(i.next()); - } - else if (args[0].equals("-m")) { - System.out.println("Receiving as MapMessage"); - MapMessage m = (MapMessage)consumer.receive(); - System.out.println(m); - System.out.println("=========================================="); - System.out.println("Printing map contents:"); - Enumeration keys = m.getMapNames(); - while(keys.hasMoreElements()) { - String key = (String)keys.nextElement(); - System.out.println(key + " => " + m.getObject(key)); - } - } - else if (args[0].equals("-s")) { - System.out.println("Receiving as StreamMessage"); - StreamMessage m = (StreamMessage)consumer.receive(); - System.out.println(m); - System.out.println("=========================================="); - System.out.println("Printing stream contents:"); - try { - while(true) - System.out.println(m.readObject()); - } - catch (MessageEOFException e) { - // DONE - } - } - - connection.close(); - } -} diff --git a/qpid/java/client/example/src/main/java/org/apache/qpid/example/ListSender.java b/qpid/java/client/example/src/main/java/org/apache/qpid/example/ListSender.java deleted file mode 100644 index fe2c1ec472..0000000000 --- a/qpid/java/client/example/src/main/java/org/apache/qpid/example/ListSender.java +++ /dev/null @@ -1,86 +0,0 @@ -/* - * - * 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.example; - -import java.util.ArrayList; -import java.util.Arrays; -import java.util.HashMap; -import java.util.List; -import java.util.Map; - -import javax.jms.Connection; -import javax.jms.Destination; -import javax.jms.Message; -import javax.jms.MessageProducer; -import javax.jms.Session; - -import org.apache.qpid.client.AMQAnyDestination; -import org.apache.qpid.client.AMQConnection; - -import org.apache.qpid.jms.ListMessage; - - -public class ListSender { - - public static void main(String[] args) throws Exception - { - Connection connection = - new AMQConnection("amqp://guest:guest@test/?brokerlist='tcp://localhost:5672'"); - - Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); - Destination queue = new AMQAnyDestination("ADDR:message_queue; {create: always}"); - MessageProducer producer = session.createProducer(queue); - - ListMessage m = ((org.apache.qpid.jms.Session)session).createListMessage(); - m.setIntProperty("Id", 987654321); - m.setStringProperty("name", "Widget"); - m.setDoubleProperty("price", 0.99); - - List colors = new ArrayList(); - colors.add("red"); - colors.add("green"); - colors.add("white"); - m.add(colors); - - Map dimensions = new HashMap(); - dimensions.put("length",10.2); - dimensions.put("width",5.1); - dimensions.put("depth",2.0); - m.add(dimensions); - - List> parts = new ArrayList>(); - parts.add(Arrays.asList(new Integer[] {1,2,5})); - parts.add(Arrays.asList(new Integer[] {8,2,5})); - m.add(parts); - - Map specs = new HashMap(); - specs.put("colours", colors); - specs.put("dimensions", dimensions); - specs.put("parts", parts); - m.add(specs); - - producer.send((Message)m); - System.out.println("Sent: " + m); - connection.close(); - } - -} diff --git a/qpid/java/client/example/src/main/java/org/apache/qpid/example/MapReceiver.java b/qpid/java/client/example/src/main/java/org/apache/qpid/example/MapReceiver.java deleted file mode 100644 index 89db04f8d3..0000000000 --- a/qpid/java/client/example/src/main/java/org/apache/qpid/example/MapReceiver.java +++ /dev/null @@ -1,52 +0,0 @@ -/* - * - * 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.example; - -import javax.jms.Connection; -import javax.jms.Destination; -import javax.jms.MapMessage; -import javax.jms.MessageConsumer; -import javax.jms.Session; - -import org.apache.qpid.client.AMQAnyDestination; -import org.apache.qpid.client.AMQConnection; - - -public class MapReceiver { - - public static void main(String[] args) throws Exception - { - Connection connection = - new AMQConnection("amqp://guest:guest@test/?brokerlist='tcp://localhost:5672'"); - - connection.start(); - - Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); - Destination queue = new AMQAnyDestination("ADDR:message_queue; {create: always}"); - MessageConsumer consumer = session.createConsumer(queue); - - MapMessage m = (MapMessage)consumer.receive(); - System.out.println(m); - connection.close(); - } - -} \ No newline at end of file diff --git a/qpid/java/client/example/src/main/java/org/apache/qpid/example/MapSender.java b/qpid/java/client/example/src/main/java/org/apache/qpid/example/MapSender.java deleted file mode 100644 index 0ce9383add..0000000000 --- a/qpid/java/client/example/src/main/java/org/apache/qpid/example/MapSender.java +++ /dev/null @@ -1,83 +0,0 @@ -/* - * - * 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.example; - -import java.util.ArrayList; -import java.util.Arrays; -import java.util.HashMap; -import java.util.List; -import java.util.Map; - -import javax.jms.Connection; -import javax.jms.Destination; -import javax.jms.MapMessage; -import javax.jms.MessageProducer; -import javax.jms.Session; - -import org.apache.qpid.client.AMQAnyDestination; -import org.apache.qpid.client.AMQConnection; - - -public class MapSender { - - public static void main(String[] args) throws Exception - { - Connection connection = - new AMQConnection("amqp://guest:guest@test/?brokerlist='tcp://localhost:5672'"); - - Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); - Destination queue = new AMQAnyDestination("ADDR:message_queue; {create: always}"); - MessageProducer producer = session.createProducer(queue); - - MapMessage m = session.createMapMessage(); - m.setIntProperty("Id", 987654321); - m.setStringProperty("name", "Widget"); - m.setDoubleProperty("price", 0.99); - - List colors = new ArrayList(); - colors.add("red"); - colors.add("green"); - colors.add("white"); - m.setObject("colours", colors); - - Map dimensions = new HashMap(); - dimensions.put("length",10.2); - dimensions.put("width",5.1); - dimensions.put("depth",2.0); - m.setObject("dimensions",dimensions); - - List> parts = new ArrayList>(); - parts.add(Arrays.asList(new Integer[] {1,2,5})); - parts.add(Arrays.asList(new Integer[] {8,2,5})); - m.setObject("parts", parts); - - Map specs = new HashMap(); - specs.put("colours", colors); - specs.put("dimensions", dimensions); - specs.put("parts", parts); - m.setObject("specs",specs); - - producer.send(m); - connection.close(); - } - -} \ No newline at end of file diff --git a/qpid/java/client/example/src/main/java/org/apache/qpid/example/OptionParser.java b/qpid/java/client/example/src/main/java/org/apache/qpid/example/OptionParser.java deleted file mode 100644 index 9360be4106..0000000000 --- a/qpid/java/client/example/src/main/java/org/apache/qpid/example/OptionParser.java +++ /dev/null @@ -1,351 +0,0 @@ -/* - * - * 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.example; - -import java.util.ArrayList; -import java.util.HashMap; -import java.util.List; -import java.util.Map; - -import javax.jms.Connection; - -import org.apache.qpid.client.AMQConnection; - -public class OptionParser -{ - static final Option BROKER = new Option("b", - "broker", - "connect to specified broker", - "USER:PASS@HOST:PORT", - "guest:guest@localhost:5672", - String.class); - - static final Option HELP = new Option("h", - "help", - "show this help message and exit", - null, - null, - Boolean.class); - - static final Option TIMEOUT = new Option("t", - "timeout", - "timeout in seconds to wait before exiting", - "TIMEOUT", - "0", - Integer.class); - - static final Option CON_OPTIONS = new Option(null, - "con-option", - "JMS Connection URL options. Ex sync_ack=true sync_publish=all ", - "NAME=VALUE", - null, - String.class); - - - static final Option BROKER_OPTIONS = new Option(null, - "broker-option", - "JMS Broker URL options. Ex ssl=true sasl_mechs=GSSAPI ", - "NAME=VALUE", - null, - String.class); - - - private Map optMap = new HashMap(); - private static final List