5958b9a588358c7efc9f9a50215161b9112af34f - qpid

commit	5958b9a588358c7efc9f9a50215161b9112af34f	[log] [tgz]
author	Rajith Muditha Attapattu <rajith@apache.org>	Fri Nov 10 18:20:13 2006 +0000
committer	Rajith Muditha Attapattu <rajith@apache.org>	Fri Nov 10 18:20:13 2006 +0000
tree	56a4059af1d6a800993a9efa4513bada47f3f482
parent	da8753529e167dca44dcd808d284d7e0c0556053 [diff]

Creating a SNAPSHOT so that Steve has room to merge his maven changes to trunk


git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/tags/pre-M1@473407 13f79535-47bb-0310-9956-ffa450edef68

java/java/Developing.txt[Added - diff]
java/java/LICENSE.txt[Added - diff]
java/java/NOTICE.txt[Added - diff]
java/java/README.txt[Added - diff]
java/java/broker/bin/qpid-server[Added - diff]
java/java/broker/bin/qpid-server.bat[Added - diff]
java/java/broker/bin/run.bat[Added - diff]
java/java/broker/bin/run.sh[Added - diff]
java/java/broker/bin/runAll[Added - diff]
java/java/broker/build-module.xml[Added - diff]
java/java/broker/build-old.xml[Added - diff]
java/java/broker/etc/config.xml[Added - diff]
java/java/broker/etc/log4j.xml[Added - diff]
java/java/broker/etc/passwd[Added - diff]
java/java/broker/etc/qpid-server.conf[Added - diff]
java/java/broker/etc/virtualhosts.xml[Added - diff]
java/java/broker/src/log4j.properties[Added - diff]
java/java/broker/src/org/apache/qpid/server/AMQChannel.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/ConsumerTagNotUniqueException.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/Main.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/ManagedChannel.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/RequiredDeliveryException.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/ack/TxAck.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/ack/UnacknowledgedMessage.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/ack/UnacknowledgedMessageMap.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/ack/UnacknowledgedMessageMapImpl.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/configuration/Configurator.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/configuration/VirtualHostConfiguration.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/exchange/AbstractExchange.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/exchange/DefaultExchangeFactory.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/exchange/DefaultExchangeRegistry.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/exchange/DestNameExchange.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/exchange/DestWildExchange.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/exchange/Exchange.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/exchange/ExchangeFactory.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/exchange/ExchangeInUseException.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/exchange/ExchangeRegistry.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/exchange/HeadersBinding.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/exchange/HeadersExchange.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/exchange/Index.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/exchange/ManagedExchange.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/exchange/MessageRouter.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/exchange/NoRouteException.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/handler/BasicAckMethodHandler.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/handler/BasicCancelMethodHandler.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/handler/BasicConsumeMethodHandler.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/handler/BasicPublishMethodHandler.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/handler/BasicQosHandler.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/handler/BasicRecoverMethodHandler.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/handler/ChannelCloseHandler.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/handler/ChannelCloseOkHandler.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/handler/ChannelFlowHandler.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/handler/ChannelOpenHandler.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/handler/ConnectionCloseMethodHandler.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/handler/ConnectionCloseOkMethodHandler.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/handler/ConnectionOpenMethodHandler.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/handler/ConnectionSecureOkMethodHandler.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/handler/ConnectionStartOkMethodHandler.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/handler/ConnectionTuneOkMethodHandler.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/handler/ExchangeDeclareHandler.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/handler/ExchangeDeleteHandler.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/handler/OnCurrentThreadExecutor.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/handler/QueueBindHandler.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/handler/QueueDeclareHandler.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/handler/QueueDeleteHandler.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/handler/TxCommitHandler.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/handler/TxRollbackHandler.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/handler/TxSelectHandler.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/jms/JmsConsumer.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/management/AMQManagedObject.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/management/DefaultManagedObject.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/management/JMXManagedObjectRegistry.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/management/MBeanAttribute.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/management/MBeanConstructor.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/management/MBeanDescription.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/management/MBeanIntrospector.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/management/MBeanOperation.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/management/MBeanOperationParameter.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/management/Managable.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/management/ManagedBroker.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/management/ManagedObject.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/management/ManagedObjectRegistry.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/management/ManagementConfiguration.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/management/NoopManagedObjectRegistry.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/protocol/AMQMethodEvent.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/protocol/AMQMethodListener.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/protocol/AMQPFastProtocolHandler.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/protocol/AMQPProtocolProvider.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/protocol/AMQProtocolSession.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/protocol/ExchangeInitialiser.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/protocol/HeartbeatConfig.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/protocol/ManagedConnection.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/queue/AMQMessage.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/queue/AMQQueue.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/queue/AsyncDeliveryConfig.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/queue/ConcurrentDeliveryManager.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/queue/DefaultQueueRegistry.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/queue/DeliveryManager.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/queue/ExchangeBindings.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/queue/FailedDequeueException.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/queue/ManagedQueue.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/queue/MessageCleanupException.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/queue/NoConsumersException.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/queue/QueueRegistry.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/queue/Subscription.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/queue/SubscriptionFactory.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/queue/SubscriptionImpl.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/queue/SubscriptionManager.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/queue/SubscriptionSet.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/queue/SynchronizedDeliveryManager.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/queue/WeightedSubscriptionManager.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/registry/ApplicationRegistry.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/registry/ConfigurationFileApplicationRegistry.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/registry/IApplicationRegistry.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/security/auth/AuthenticationManager.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/security/auth/AuthenticationProviderInitialiser.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/security/auth/AuthenticationResult.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/security/auth/CRAMMD5Initialiser.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/security/auth/JCAProvider.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/security/auth/NullAuthenticationManager.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/security/auth/PasswordFilePrincipalDatabase.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/security/auth/PrincipalDatabase.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/security/auth/SASLAuthenticationManager.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/security/auth/UsernamePasswordInitialiser.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/security/auth/UsernamePrincipal.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/security/auth/amqplain/AmqPlainInitialiser.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/security/auth/amqplain/AmqPlainSaslServer.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/security/auth/amqplain/AmqPlainSaslServerFactory.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/security/auth/plain/PlainInitialiser.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/security/auth/plain/PlainSaslServer.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/security/auth/plain/PlainSaslServerFactory.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/state/AMQState.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/state/AMQStateManager.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/state/IllegalStateTransitionException.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/state/StateAwareMethodListener.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/state/StateListener.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/store/MemoryMessageStore.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/store/MessageStore.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/transport/ConnectorConfiguration.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/transport/ThreadPoolFilter.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/txn/TxnBuffer.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/txn/TxnOp.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/util/CircularBuffer.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/util/ConcurrentLinkedQueueNoSize.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/util/LoggingProxy.java[Added - diff]
java/java/broker/src/org/apache/qpid/server/util/NullApplicationRegistry.java[Added - diff]
java/java/broker/test/build-module.xml[Added - diff]
java/java/broker/test/lib/README[Added - diff]
java/java/broker/test/lib/junit/junit-4.0.jar[Added - diff]
java/java/broker/test/lib/junit/junit.jar[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/UnitTests.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/ack/TxAckTest.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/ack/UnitTests.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/configuration/TestPropertyUtils.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/configuration/UnitTests.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/exchange/AbstractHeadersExchangeTest.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/exchange/HeadersBindingTest.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/exchange/HeadersExchangePerformanceTest.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/exchange/HeadersExchangeTest.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/exchange/UnitTests.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/protocol/MockIoSession.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/protocol/TestProtocolInitiation.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/protocol/UnitTests.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/queue/AckTest.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/queue/ConcurrencyTest.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/queue/ConcurrentDeliveryManagerTest.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/queue/DeliveryManagerTest.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/queue/MessageTestHelper.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/queue/MockProtocolSession.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/queue/QueueConcurrentPerfTest.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/queue/QueuePerfTest.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/queue/SendPerfTest.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/queue/SubscriptionManagerTest.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/queue/SubscriptionSetTest.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/queue/SynchronizedDeliveryManagerTest.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/queue/TestSubscription.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/queue/UnitTests.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/store/SkeletonMessageStore.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/store/TestReferenceCounting.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/store/TestableMemoryMessageStore.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/store/UnitTests.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/txn/TxnBufferTest.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/txn/UnitTests.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/util/AveragedRun.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/util/ConcurrentTest.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/util/LoggingProxyTest.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/util/RunStats.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/util/TestApplicationRegistry.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/util/TimedRun.java[Added - diff]
java/java/broker/test/src/org/apache/qpid/server/util/UnitTests.java[Added - diff]
java/java/build-old.xml[Added - diff]
java/java/build.properties[Added - diff]
java/java/build.xml[Added - diff]
java/java/client/build-module.xml[Added - diff]
java/java/client/build-old.xml[Added - diff]
java/java/client/dist/readme.txt[Added - diff]
java/java/client/lib/jms/geronimo-spec-jms-1.1-rc4.jar[Added - diff]
java/java/client/readme.txt[Added - diff]
java/java/client/src/log4j.properties[Added - diff]
java/java/client/src/org/apache/qpid/client/AMQAuthenticationException.java[Added - diff]
java/java/client/src/org/apache/qpid/client/AMQBrokerDetails.java[Added - diff]
java/java/client/src/org/apache/qpid/client/AMQConnection.java[Added - diff]
java/java/client/src/org/apache/qpid/client/AMQConnectionFactory.java[Added - diff]
java/java/client/src/org/apache/qpid/client/AMQConnectionURL.java[Added - diff]
java/java/client/src/org/apache/qpid/client/AMQDestination.java[Added - diff]
java/java/client/src/org/apache/qpid/client/AMQHeadersExchange.java[Added - diff]
java/java/client/src/org/apache/qpid/client/AMQNoConsumersException.java[Added - diff]
java/java/client/src/org/apache/qpid/client/AMQNoRouteException.java[Added - diff]
java/java/client/src/org/apache/qpid/client/AMQQueue.java[Added - diff]
java/java/client/src/org/apache/qpid/client/AMQQueueSessionAdaptor.java[Added - diff]
java/java/client/src/org/apache/qpid/client/AMQSession.java[Added - diff]
java/java/client/src/org/apache/qpid/client/AMQTemporaryQueue.java[Added - diff]
java/java/client/src/org/apache/qpid/client/AMQTemporaryTopic.java[Added - diff]
java/java/client/src/org/apache/qpid/client/AMQTopic.java[Added - diff]
java/java/client/src/org/apache/qpid/client/AMQTopicSessionAdaptor.java[Added - diff]
java/java/client/src/org/apache/qpid/client/BasicMessageConsumer.java[Added - diff]
java/java/client/src/org/apache/qpid/client/BasicMessageProducer.java[Added - diff]
java/java/client/src/org/apache/qpid/client/Closeable.java[Added - diff]
java/java/client/src/org/apache/qpid/client/ConnectionTuneParameters.java[Added - diff]
java/java/client/src/org/apache/qpid/client/JmsNotImplementedException.java[Added - diff]
java/java/client/src/org/apache/qpid/client/QueueReceiverAdaptor.java[Added - diff]
java/java/client/src/org/apache/qpid/client/TopicSubscriberAdaptor.java[Added - diff]
java/java/client/src/org/apache/qpid/client/failover/FailoverException.java[Added - diff]
java/java/client/src/org/apache/qpid/client/failover/FailoverHandler.java[Added - diff]
java/java/client/src/org/apache/qpid/client/failover/FailoverState.java[Added - diff]
java/java/client/src/org/apache/qpid/client/failover/FailoverSupport.java[Added - diff]
java/java/client/src/org/apache/qpid/client/handler/BasicDeliverMethodHandler.java[Added - diff]
java/java/client/src/org/apache/qpid/client/handler/BasicReturnMethodHandler.java[Added - diff]
java/java/client/src/org/apache/qpid/client/handler/ChannelCloseMethodHandler.java[Added - diff]
java/java/client/src/org/apache/qpid/client/handler/ChannelCloseOkMethodHandler.java[Added - diff]
java/java/client/src/org/apache/qpid/client/handler/ChannelFlowOkMethodHandler.java[Added - diff]
java/java/client/src/org/apache/qpid/client/handler/ConnectionCloseMethodHandler.java[Added - diff]
java/java/client/src/org/apache/qpid/client/handler/ConnectionOpenOkMethodHandler.java[Added - diff]
java/java/client/src/org/apache/qpid/client/handler/ConnectionRedirectMethodHandler.java[Added - diff]
java/java/client/src/org/apache/qpid/client/handler/ConnectionSecureMethodHandler.java[Added - diff]
java/java/client/src/org/apache/qpid/client/handler/ConnectionStartMethodHandler.java[Added - diff]
java/java/client/src/org/apache/qpid/client/handler/ConnectionTuneMethodHandler.java[Added - diff]
java/java/client/src/org/apache/qpid/client/message/AMQMessage.java[Added - diff]
java/java/client/src/org/apache/qpid/client/message/AbstractJMSMessage.java[Added - diff]
java/java/client/src/org/apache/qpid/client/message/AbstractJMSMessageFactory.java[Added - diff]
java/java/client/src/org/apache/qpid/client/message/JMSBytesMessage.java[Added - diff]
java/java/client/src/org/apache/qpid/client/message/JMSBytesMessageFactory.java[Added - diff]
java/java/client/src/org/apache/qpid/client/message/JMSObjectMessage.java[Added - diff]
java/java/client/src/org/apache/qpid/client/message/JMSObjectMessageFactory.java[Added - diff]
java/java/client/src/org/apache/qpid/client/message/JMSTextMessage.java[Added - diff]
java/java/client/src/org/apache/qpid/client/message/JMSTextMessageFactory.java[Added - diff]
java/java/client/src/org/apache/qpid/client/message/MessageFactory.java[Added - diff]
java/java/client/src/org/apache/qpid/client/message/MessageFactoryRegistry.java[Added - diff]
java/java/client/src/org/apache/qpid/client/message/UnexpectedBodyReceivedException.java[Added - diff]
java/java/client/src/org/apache/qpid/client/message/UnprocessedMessage.java[Added - diff]
java/java/client/src/org/apache/qpid/client/protocol/AMQMethodEvent.java[Added - diff]
java/java/client/src/org/apache/qpid/client/protocol/AMQMethodListener.java[Added - diff]
java/java/client/src/org/apache/qpid/client/protocol/AMQProtocolHandler.java[Added - diff]
java/java/client/src/org/apache/qpid/client/protocol/AMQProtocolSession.java[Added - diff]
java/java/client/src/org/apache/qpid/client/protocol/BlockingMethodFrameListener.java[Added - diff]
java/java/client/src/org/apache/qpid/client/protocol/HeartbeatConfig.java[Added - diff]
java/java/client/src/org/apache/qpid/client/protocol/HeartbeatDiagnostics.java[Added - diff]
java/java/client/src/org/apache/qpid/client/protocol/ProtocolBufferMonitorFilter.java[Added - diff]
java/java/client/src/org/apache/qpid/client/security/AMQCallbackHandler.java[Added - diff]
java/java/client/src/org/apache/qpid/client/security/CallbackHandlerRegistry.java[Added - diff]
java/java/client/src/org/apache/qpid/client/security/CallbackHandlerRegistry.properties[Added - diff]
java/java/client/src/org/apache/qpid/client/security/DynamicSaslRegistrar.java[Added - diff]
java/java/client/src/org/apache/qpid/client/security/DynamicSaslRegistrar.properties[Added - diff]
java/java/client/src/org/apache/qpid/client/security/JCAProvider.java[Added - diff]
java/java/client/src/org/apache/qpid/client/security/UsernamePasswordCallbackHandler.java[Added - diff]
java/java/client/src/org/apache/qpid/client/security/amqplain/AmqPlainSaslClient.java[Added - diff]
java/java/client/src/org/apache/qpid/client/security/amqplain/AmqPlainSaslClientFactory.java[Added - diff]
java/java/client/src/org/apache/qpid/client/state/AMQState.java[Added - diff]
java/java/client/src/org/apache/qpid/client/state/AMQStateChangedEvent.java[Added - diff]
java/java/client/src/org/apache/qpid/client/state/AMQStateListener.java[Added - diff]
java/java/client/src/org/apache/qpid/client/state/AMQStateManager.java[Added - diff]
java/java/client/src/org/apache/qpid/client/state/IllegalStateTransitionException.java[Added - diff]
java/java/client/src/org/apache/qpid/client/state/StateAwareMethodListener.java[Added - diff]
java/java/client/src/org/apache/qpid/client/state/StateListener.java[Added - diff]
java/java/client/src/org/apache/qpid/client/state/StateWaiter.java[Added - diff]
java/java/client/src/org/apache/qpid/client/state/listener/SpecificMethodFrameListener.java[Added - diff]
java/java/client/src/org/apache/qpid/client/transport/AMQNoTransportForProtocolException.java[Added - diff]
java/java/client/src/org/apache/qpid/client/transport/AMQTransportConnectionException.java[Added - diff]
java/java/client/src/org/apache/qpid/client/transport/ITransportConnection.java[Added - diff]
java/java/client/src/org/apache/qpid/client/transport/SocketTransportConnection.java[Added - diff]
java/java/client/src/org/apache/qpid/client/transport/TransportConnection.java[Added - diff]
java/java/client/src/org/apache/qpid/client/transport/VmPipeTransportConnection.java[Added - diff]
java/java/client/src/org/apache/qpid/client/util/FlowControllingBlockingQueue.java[Added - diff]
java/java/client/src/org/apache/qpid/client/vmbroker/AMQVMBrokerCreationException.java[Added - diff]
java/java/client/src/org/apache/qpid/jms/BrokerDetails.java[Added - diff]
java/java/client/src/org/apache/qpid/jms/ChannelLimitReachedException.java[Added - diff]
java/java/client/src/org/apache/qpid/jms/Connection.java[Added - diff]
java/java/client/src/org/apache/qpid/jms/ConnectionListener.java[Added - diff]
java/java/client/src/org/apache/qpid/jms/ConnectionURL.java[Added - diff]
java/java/client/src/org/apache/qpid/jms/FailoverPolicy.java[Added - diff]
java/java/client/src/org/apache/qpid/jms/MessageConsumer.java[Added - diff]
java/java/client/src/org/apache/qpid/jms/MessageProducer.java[Added - diff]
java/java/client/src/org/apache/qpid/jms/Session.java[Added - diff]
java/java/client/src/org/apache/qpid/jms/failover/FailoverMethod.java[Added - diff]
java/java/client/src/org/apache/qpid/jms/failover/FailoverRoundRobinServers.java[Added - diff]
java/java/client/src/org/apache/qpid/jms/failover/FailoverSingleServer.java[Added - diff]
java/java/client/src/org/apache/qpid/jndi/Example.properties[Added - diff]
java/java/client/src/org/apache/qpid/jndi/NameParserImpl.java[Added - diff]
java/java/client/src/org/apache/qpid/jndi/PropertiesFileInitialContextFactory.java[Added - diff]
java/java/client/src/org/apache/qpid/jndi/ReadOnlyContext.java[Added - diff]
java/java/client/test/bin/IBM-JNDI-Setup.bat[Added - diff]
java/java/client/test/bin/IBM-JNDI-Setup.sh[Added - diff]
java/java/client/test/bin/IBM-Publisher.bat[Added - diff]
java/java/client/test/bin/IBM-Publisher.sh[Added - diff]
java/java/client/test/bin/IBM-PutGet.bat[Added - diff]
java/java/client/test/bin/IBM-PutGet.sh[Added - diff]
java/java/client/test/bin/IBM-README.txt[Added - diff]
java/java/client/test/bin/IBM-Receiver.bat[Added - diff]
java/java/client/test/bin/IBM-Receiver.sh[Added - diff]
java/java/client/test/bin/IBM-Sender.bat[Added - diff]
java/java/client/test/bin/IBM-Sender.sh[Added - diff]
java/java/client/test/bin/IBM-Subscriber.bat[Added - diff]
java/java/client/test/bin/IBM-Subscriber.sh[Added - diff]
java/java/client/test/bin/headersListener.sh[Added - diff]
java/java/client/test/bin/headersListenerGroup.sh[Added - diff]
java/java/client/test/bin/headersPublisher.sh[Added - diff]
java/java/client/test/bin/run_many.sh[Added - diff]
java/java/client/test/bin/serviceProvidingClient.sh[Added - diff]
java/java/client/test/bin/serviceRequestingClient.sh[Added - diff]
java/java/client/test/bin/testService.sh[Added - diff]
java/java/client/test/bin/topicListener.sh[Added - diff]
java/java/client/test/bin/topicPublisher.sh[Added - diff]
java/java/client/test/build-module.xml[Added - diff]
java/java/client/test/etc/ApacheDS.properties[Added - diff]
java/java/client/test/example_build.xml[Added - diff]
java/java/client/test/lib/activemq/geronimo-j2ee-management_1.0_spec-1.0.jar[Added - diff]
java/java/client/test/lib/jakarta-commons/commons-codec-1.3.jar[Added - diff]
java/java/client/test/lib/jmscts/jmscts-0.5-b2.jar[Added - diff]
java/java/client/test/lib/jmscts/license.jmscts.txt[Added - diff]
java/java/client/test/lib/spring-1.2.8/spring.jar[Added - diff]
java/java/client/test/src/org/apache/qpid/IBMPerfTest/JNDIBindConnectionFactory.java[Added - diff]
java/java/client/test/src/org/apache/qpid/IBMPerfTest/JNDIBindQueue.java[Added - diff]
java/java/client/test/src/org/apache/qpid/IBMPerfTest/JNDIBindTopic.java[Added - diff]
java/java/client/test/src/org/apache/qpid/IBMPerfTest/README.txt[Added - diff]
java/java/client/test/src/org/apache/qpid/client/message/TestMessageHelper.java[Added - diff]
java/java/client/test/src/org/apache/qpid/cluster/Client.java[Added - diff]
java/java/client/test/src/org/apache/qpid/codec/BasicDeliverTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/codec/Client.java[Added - diff]
java/java/client/test/src/org/apache/qpid/codec/Server.java[Added - diff]
java/java/client/test/src/org/apache/qpid/config/AMQConnectionFactoryInitialiser.java[Added - diff]
java/java/client/test/src/org/apache/qpid/config/AbstractConfig.java[Added - diff]
java/java/client/test/src/org/apache/qpid/config/ConnectionFactoryInitialiser.java[Added - diff]
java/java/client/test/src/org/apache/qpid/config/Connector.java[Added - diff]
java/java/client/test/src/org/apache/qpid/config/ConnectorConfig.java[Added - diff]
java/java/client/test/src/org/apache/qpid/config/JBossConnectionFactoryInitialiser.java[Added - diff]
java/java/client/test/src/org/apache/qpid/cts/bin/jmscts.sh[Added - diff]
java/java/client/test/src/org/apache/qpid/cts/bin/setenv.sh[Added - diff]
java/java/client/test/src/org/apache/qpid/cts/config/jmscts.policy[Added - diff]
java/java/client/test/src/org/apache/qpid/cts/config/jmscts.properties[Added - diff]
java/java/client/test/src/org/apache/qpid/cts/config/providers.xml[Added - diff]
java/java/client/test/src/org/apache/qpid/cts/readme.txt[Added - diff]
java/java/client/test/src/org/apache/qpid/cts/src/compile.sh[Added - diff]
java/java/client/test/src/org/apache/qpid/cts/src/providers/amqp/org/exolab/jmscts/amqp/AMQPAdministrator.java[Added - diff]
java/java/client/test/src/org/apache/qpid/cts/src/providers/amqp/org/exolab/jmscts/amqp/AMQPProvider.java[Added - diff]
java/java/client/test/src/org/apache/qpid/example/log4j.xml[Added - diff]
java/java/client/test/src/org/apache/qpid/example/publisher/FileMessageDispatcher.java[Added - diff]
java/java/client/test/src/org/apache/qpid/example/publisher/MessageFactory.java[Added - diff]
java/java/client/test/src/org/apache/qpid/example/publisher/MessageFactoryException.java[Added - diff]
java/java/client/test/src/org/apache/qpid/example/publisher/MonitorMessageDispatcher.java[Added - diff]
java/java/client/test/src/org/apache/qpid/example/publisher/MonitorPublisher.java[Added - diff]
java/java/client/test/src/org/apache/qpid/example/publisher/Publisher.java[Added - diff]
java/java/client/test/src/org/apache/qpid/example/publisher/UndeliveredMessageException.java[Added - diff]
java/java/client/test/src/org/apache/qpid/example/shared/ConnectionException.java[Added - diff]
java/java/client/test/src/org/apache/qpid/example/shared/FileUtils.java[Added - diff]
java/java/client/test/src/org/apache/qpid/example/shared/Statics.java[Added - diff]
java/java/client/test/src/org/apache/qpid/example/subscriber/MonitoredSubscriber.java[Added - diff]
java/java/client/test/src/org/apache/qpid/example/subscriber/MonitoredSubscriptionWrapper.java[Added - diff]
java/java/client/test/src/org/apache/qpid/example/subscriber/Subscriber.java[Added - diff]
java/java/client/test/src/org/apache/qpid/example/subscriber/SubscriptionWrapper.java[Added - diff]
java/java/client/test/src/org/apache/qpid/example/test/TestAMSPubSub.java[Added - diff]
java/java/client/test/src/org/apache/qpid/example/test/TestMultSubscribers.java[Added - diff]
java/java/client/test/src/org/apache/qpid/example/test/TestPublisher.java[Added - diff]
java/java/client/test/src/org/apache/qpid/example/test/TestSubscriber.java[Added - diff]
java/java/client/test/src/org/apache/qpid/flow/ChannelFlowTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/fragmentation/TestLargePublisher.java[Added - diff]
java/java/client/test/src/org/apache/qpid/fragmentation/TestLargeSubscriber.java[Added - diff]
java/java/client/test/src/org/apache/qpid/framing/FieldTableTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/framing/content.txt[Added - diff]
java/java/client/test/src/org/apache/qpid/headers/Listener.java[Added - diff]
java/java/client/test/src/org/apache/qpid/headers/MessageFactory.java[Added - diff]
java/java/client/test/src/org/apache/qpid/headers/Publisher.java[Added - diff]
java/java/client/test/src/org/apache/qpid/jndi/referenceable/Bind.java[Added - diff]
java/java/client/test/src/org/apache/qpid/jndi/referenceable/Lookup.java[Added - diff]
java/java/client/test/src/org/apache/qpid/jndi/referenceable/Unbind.java[Added - diff]
java/java/client/test/src/org/apache/qpid/latency/LatencyTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/mina/AcceptorTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/mina/BlockingAcceptorTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/mina/WriterTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/multiconsumer/AMQTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/ping/TestPingClient.java[Added - diff]
java/java/client/test/src/org/apache/qpid/ping/TestPingProducer.java[Added - diff]
java/java/client/test/src/org/apache/qpid/ping/TestPingPublisher.java[Added - diff]
java/java/client/test/src/org/apache/qpid/ping/TestPingSubscriber.java[Added - diff]
java/java/client/test/src/org/apache/qpid/pubsub1/TestPublisher.java[Added - diff]
java/java/client/test/src/org/apache/qpid/pubsub1/TestSubscriber.java[Added - diff]
java/java/client/test/src/org/apache/qpid/requestreply1/ServiceProvidingClient.java[Added - diff]
java/java/client/test/src/org/apache/qpid/requestreply1/ServiceRequestingClient.java[Added - diff]
java/java/client/test/src/org/apache/qpid/requestreply1/VmRequestReply.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/ack/DisconnectAndRedeliverTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/ack/RecoverTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/ack/UnitTests.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/basic/BytesMessageTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/basic/FieldTableKeyEnumeratorTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/basic/FieldTableMessageTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/basic/MultipleConnectionTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/basic/ObjectMessageTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/basic/ReceiveTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/basic/SessionStartTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/basic/TextMessageTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/basic/UnitTests.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/client/AMQConnectionTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/client/AMQSessionTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/client/AllClientUnitTests.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/client/channelclose/ChannelCloseOkTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/client/channelclose/UnitTests.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/client/connection/ConnectionTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/client/connection/TestManyConnections.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/client/connectionurl/ConnectionURLTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/client/connectionurl/UnitTests.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/client/destinationurl/DestinationURLTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/client/destinationurl/UnitTests.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/client/forwardall/Client.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/client/forwardall/CombinedTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/client/forwardall/Service.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/client/forwardall/ServiceCreator.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/client/forwardall/SpecialQueue.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/client/forwardall/UnitTests.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/client/message/BytesMessageTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/client/message/MessageUnitTests.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/client/message/ObjectMessageTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/client/message/TextMessageTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/client/protocol/AMQProtocolSessionTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/client/protocol/TestIoSession.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/jndi/PropertiesFileInitialContextFactoryTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/jndi/referenceabletest/Bind.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/jndi/referenceabletest/JNDIReferenceableTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/jndi/referenceabletest/Lookup.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/jndi/referenceabletest/Unbind.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/jndi/referenceabletest/UnitTests.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/topic/DurableSubscriptionTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/transacted/TransactedTest.java[Added - diff]
java/java/client/test/src/org/apache/qpid/test/unit/transacted/UnitTests.java[Added - diff]
java/java/client/test/src/org/apache/qpid/testutil/Config.java[Added - diff]
java/java/client/test/src/org/apache/qpid/topic/Config.java[Added - diff]
java/java/client/test/src/org/apache/qpid/topic/Listener.java[Added - diff]
java/java/client/test/src/org/apache/qpid/topic/MessageFactory.java[Added - diff]
java/java/client/test/src/org/apache/qpid/topic/Publisher.java[Added - diff]
java/java/client/test/src/org/apache/qpid/transacted/Config.java[Added - diff]
java/java/client/test/src/org/apache/qpid/transacted/Ping.java[Added - diff]
java/java/client/test/src/org/apache/qpid/transacted/Pong.java[Added - diff]
java/java/client/test/src/org/apache/qpid/transacted/Relay.java[Added - diff]
java/java/client/test/src/org/apache/qpid/transacted/Start.java[Added - diff]
java/java/client/test/src/org/apache/qpid/weblogic/ServiceProvider.java[Added - diff]
java/java/client/test/src/org/apache/qpid/weblogic/ServiceRequestingClient.java[Added - diff]
java/java/cluster/build-module.xml[Added - diff]
java/java/cluster/build-old.xml[Added - diff]
java/java/cluster/doc/design.doc[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/BlockingHandler.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/BroadcastPolicy.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/Broker.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/BrokerFactory.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/BrokerGroup.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/ClientAdapter.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/ClientHandlerRegistry.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/ClusterBuilder.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/ClusterCapability.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/ClusteredProtocolHandler.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/ClusteredProtocolSession.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/ConnectionStatusMonitor.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/DefaultGroupManager.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/GroupManager.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/GroupRequest.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/GroupResponseHandler.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/InductionBuffer.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/JoinState.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/LoadTable.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/Main.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/Member.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/MemberFailureListener.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/MemberHandle.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/MembershipChangeListener.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/MethodHandler.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/MethodHandlerFactory.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/MethodHandlerRegistry.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/MinaBrokerProxy.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/MinaBrokerProxyFactory.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/ResponseHandler.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/Sendable.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/ServerHandlerRegistry.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/SimpleMemberHandle.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/SimpleSendable.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/handler/ChainedClusterMethodHandler.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/handler/ChannelQueueManager.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/handler/ClusterMethodHandler.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/handler/ClusterMethodHandlerFactory.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/handler/ExtendedHandler.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/handler/HandlerUtils.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/handler/LocalQueueDeclareHandler.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/handler/NullListener.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/handler/PeerHandler.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/handler/QueueNameGenerator.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/handler/RemoteCancelHandler.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/handler/RemoteConsumeHandler.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/handler/ReplicatingConsumeHandler.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/handler/ReplicatingHandler.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/handler/WrappedListener.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/handler/WrappingMethodHandlerFactory.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/policy/AsynchBroadcastPolicy.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/policy/MajorityResponseBroadcastPolicy.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/policy/OneResponseBroadcastPolicy.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/policy/StandardPolicies.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/policy/SynchBroadcastPolicy.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/replay/ChainedMethodRecorder.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/replay/ConsumerCounts.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/replay/MethodRecorder.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/replay/RecordingMethodHandlerFactory.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/replay/ReplayManager.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/replay/ReplayStore.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/util/Bindings.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/util/InvokeMultiple.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/util/LogMessage.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/cluster/util/MultiValuedMap.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/queue/ClusteredQueue.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/queue/ClusteredSubscriptionManager.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/queue/NestedSubscriptionManager.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/queue/PrivateQueue.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/queue/ProxiedQueueCleanup.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/queue/RemoteQueueProxy.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/queue/RemoteSubscriptionImpl.java[Added - diff]
java/java/cluster/src/org/apache/qpid/server/queue/SubscriberCleanup.java[Added - diff]
java/java/cluster/test/org/apache/qpid/server/cluster/BrokerGroupTest.java[Added - diff]
java/java/cluster/test/org/apache/qpid/server/cluster/BrokerTest.java[Added - diff]
java/java/cluster/test/org/apache/qpid/server/cluster/ClusterCapabilityTest.java[Added - diff]
java/java/cluster/test/org/apache/qpid/server/cluster/InductionBufferTest.java[Added - diff]
java/java/cluster/test/org/apache/qpid/server/cluster/RecordingBroker.java[Added - diff]
java/java/cluster/test/org/apache/qpid/server/cluster/RecordingBrokerFactory.java[Added - diff]
java/java/cluster/test/org/apache/qpid/server/cluster/SimpleClusterTest.java[Added - diff]
java/java/cluster/test/org/apache/qpid/server/cluster/SimpleMemberHandleTest.java[Added - diff]
java/java/cluster/test/org/apache/qpid/server/cluster/TestBroker.java[Added - diff]
java/java/cluster/test/org/apache/qpid/server/cluster/TestBrokerFactory.java[Added - diff]
java/java/cluster/test/org/apache/qpid/server/cluster/TestReplayManager.java[Added - diff]
java/java/cluster/test/org/apache/qpid/server/cluster/TestSession.java[Added - diff]
java/java/common.xml[Added - diff]
java/java/common/bin/qpid-run[Added - diff]
java/java/common/build-module.xml[Added - diff]
java/java/common/build-old.xml[Added - diff]
java/java/common/etc/qpid-run.conf[Added - diff]
java/java/common/etc/qpid-run.conf.dev[Added - diff]
java/java/common/lib/backport-util-concurrent/LEGAL[Added - diff]
java/java/common/lib/backport-util-concurrent/README.html[Added - diff]
java/java/common/lib/backport-util-concurrent/backport-util-concurrent-2.2.jar[Added - diff]
java/java/common/lib/backport-util-concurrent/license.backport-util-concurrent.html[Added - diff]
java/java/common/lib/commons-cli/commons-cli-1.0.jar[Added - diff]
java/java/common/lib/commons-collections/commons-collections-3.1.jar[Added - diff]
java/java/common/lib/commons-configuration/commons-configuration-1.2.jar[Added - diff]
java/java/common/lib/commons-lang/commons-lang-2.1.jar[Added - diff]
java/java/common/lib/commons-logging/commons-logging-api.jar[Added - diff]
java/java/common/lib/commons-logging/commons-logging.jar[Added - diff]
java/java/common/lib/junit/junit-4.0.jar[Added - diff]
java/java/common/lib/junit/junit.jar[Added - diff]
java/java/common/lib/junit/license.junit.txt[Added - diff]
java/java/common/lib/logging-log4j/log4j-1.2.13.jar[Added - diff]
java/java/common/lib/mina/mina-core-1.1.0-SNAPSHOT.jar[Added - diff]
java/java/common/lib/mina/mina-filter-ssl-1.1.0-SNAPSHOT.jar[Added - diff]
java/java/common/lib/mina/mina-java5-1.1.0-SNAPSHOT.jar[Added - diff]
java/java/common/lib/saxon/license.saxon.txt[Added - diff]
java/java/common/lib/saxon/saxon8.jar[Added - diff]
java/java/common/lib/slf4j/license.slf4.txt[Added - diff]
java/java/common/lib/slf4j/slf4j-simple.jar[Added - diff]
java/java/common/readme.txt[Added - diff]
java/java/common/resources/ProtocolVersionList.java[Added - diff]
java/java/common/resources/cluster.asl[Added - diff]
java/java/common/resources/org/apache/qpid/ssl/qpid.cert[Added - diff]
java/java/common/resources/registry.template[Added - diff]
java/java/common/src/org/apache/qpid/AMQChannelClosedException.java[Added - diff]
java/java/common/src/org/apache/qpid/AMQChannelException.java[Added - diff]
java/java/common/src/org/apache/qpid/AMQConnectionClosedException.java[Added - diff]
java/java/common/src/org/apache/qpid/AMQConnectionException.java[Added - diff]
java/java/common/src/org/apache/qpid/AMQDisconnectedException.java[Added - diff]
java/java/common/src/org/apache/qpid/AMQException.java[Added - diff]
java/java/common/src/org/apache/qpid/AMQUndeliveredException.java[Added - diff]
java/java/common/src/org/apache/qpid/AMQUnresolvedAddressException.java[Added - diff]
java/java/common/src/org/apache/qpid/codec/AMQCodecFactory.java[Added - diff]
java/java/common/src/org/apache/qpid/codec/AMQDecoder.java[Added - diff]
java/java/common/src/org/apache/qpid/codec/AMQEncoder.java[Added - diff]
java/java/common/src/org/apache/qpid/configuration/Configured.java[Added - diff]
java/java/common/src/org/apache/qpid/configuration/PropertyException.java[Added - diff]
java/java/common/src/org/apache/qpid/configuration/PropertyUtils.java[Added - diff]
java/java/common/src/org/apache/qpid/exchange/ExchangeDefaults.java[Added - diff]
java/java/common/src/org/apache/qpid/framing/AMQBody.java[Added - diff]
java/java/common/src/org/apache/qpid/framing/AMQDataBlock.java[Added - diff]
java/java/common/src/org/apache/qpid/framing/AMQDataBlockDecoder.java[Added - diff]
java/java/common/src/org/apache/qpid/framing/AMQDataBlockEncoder.java[Added - diff]
java/java/common/src/org/apache/qpid/framing/AMQFrame.java[Added - diff]
java/java/common/src/org/apache/qpid/framing/AMQFrameDecodingException.java[Added - diff]
java/java/common/src/org/apache/qpid/framing/AMQMethodBody.java[Added - diff]
java/java/common/src/org/apache/qpid/framing/AMQMethodBodyFactory.java[Added - diff]
java/java/common/src/org/apache/qpid/framing/AMQProtocolClassException.java[Added - diff]
java/java/common/src/org/apache/qpid/framing/AMQProtocolHeaderException.java[Added - diff]
java/java/common/src/org/apache/qpid/framing/AMQProtocolInstanceException.java[Added - diff]
java/java/common/src/org/apache/qpid/framing/AMQProtocolVersionException.java[Added - diff]
java/java/common/src/org/apache/qpid/framing/BasicContentHeaderProperties.java[Added - diff]
java/java/common/src/org/apache/qpid/framing/BodyFactory.java[Added - diff]
java/java/common/src/org/apache/qpid/framing/CompositeAMQDataBlock.java[Added - diff]
java/java/common/src/org/apache/qpid/framing/ContentBody.java[Added - diff]
java/java/common/src/org/apache/qpid/framing/ContentBodyFactory.java[Added - diff]
java/java/common/src/org/apache/qpid/framing/ContentHeaderBody.java[Added - diff]
java/java/common/src/org/apache/qpid/framing/ContentHeaderBodyFactory.java[Added - diff]
java/java/common/src/org/apache/qpid/framing/ContentHeaderProperties.java[Added - diff]
java/java/common/src/org/apache/qpid/framing/ContentHeaderPropertiesFactory.java[Added - diff]
java/java/common/src/org/apache/qpid/framing/EncodableAMQDataBlock.java[Added - diff]
java/java/common/src/org/apache/qpid/framing/EncodingUtils.java[Added - diff]
java/java/common/src/org/apache/qpid/framing/FieldTable.java[Added - diff]
java/java/common/src/org/apache/qpid/framing/FieldTableKeyEnumeration.java[Added - diff]
java/java/common/src/org/apache/qpid/framing/HeartbeatBody.java[Added - diff]
java/java/common/src/org/apache/qpid/framing/HeartbeatBodyFactory.java[Added - diff]
java/java/common/src/org/apache/qpid/framing/ProtocolInitiation.java[Added - diff]
java/java/common/src/org/apache/qpid/pool/Event.java[Added - diff]
java/java/common/src/org/apache/qpid/pool/Job.java[Added - diff]
java/java/common/src/org/apache/qpid/pool/PoolingFilter.java[Added - diff]
java/java/common/src/org/apache/qpid/pool/ReadWriteThreadModel.java[Added - diff]
java/java/common/src/org/apache/qpid/pool/ReferenceCountingExecutorService.java[Added - diff]
java/java/common/src/org/apache/qpid/protocol/AMQConstant.java[Added - diff]
java/java/common/src/org/apache/qpid/ssl/BogusSSLContextFactory.java[Added - diff]
java/java/common/src/org/apache/qpid/ssl/BogusTrustManagerFactory.java[Added - diff]
java/java/common/src/org/apache/qpid/ssl/SSLServerSocketFactory.java[Added - diff]
java/java/common/src/org/apache/qpid/ssl/SSLSocketFactory.java[Added - diff]
java/java/common/src/org/apache/qpid/url/AMQBindingURL.java[Added - diff]
java/java/common/src/org/apache/qpid/url/BindingURL.java[Added - diff]
java/java/common/src/org/apache/qpid/url/URLHelper.java[Added - diff]
java/java/common/src/org/apache/qpid/url/URLSyntaxException.java[Added - diff]
java/java/common/src/org/apache/qpid/util/ConcurrentLinkedQueueAtomicSize.java[Added - diff]
java/java/common/src/org/apache/qpid/util/ConcurrentLinkedQueueNoSize.java[Added - diff]
java/java/common/stylesheets/framing.xsl[Added - diff]
java/java/common/stylesheets/java.xsl[Added - diff]
java/java/common/stylesheets/prepare1.xsl[Added - diff]
java/java/common/stylesheets/prepare2.xsl[Added - diff]
java/java/common/stylesheets/prepare3.xsl[Added - diff]
java/java/common/stylesheets/readme.txt[Added - diff]
java/java/common/stylesheets/registry.xsl[Added - diff]
java/java/common/stylesheets/utils.xsl[Added - diff]
java/java/doc/AMQBlazeDetailedDesign.vsd[Added - diff]
java/java/doc/FramingClassDiagram.vsd[Added - diff]
java/java/management/cli/bin/stac.bat[Added - diff]
java/java/management/cli/bin/stac.sh[Added - diff]
java/java/management/cli/bin/stacDEV.bat[Added - diff]
java/java/management/cli/build-module.xml[Added - diff]
java/java/management/cli/build-old.xml[Added - diff]
java/java/management/cli/lib/jython/jython.jar[Added - diff]
java/java/management/cli/lib/jython/license.jython.txt[Added - diff]
java/java/management/cli/src/org/apache/qpid/stac/Stac.java[Added - diff]
java/java/management/cli/src/org/apache/qpid/stac/StacInterpreter.java[Added - diff]
java/java/management/cli/src/org/apache/qpid/stac/commands/CdCommand.java[Added - diff]
java/java/management/cli/src/org/apache/qpid/stac/commands/InvokeCommand.java[Added - diff]
java/java/management/cli/src/org/apache/qpid/stac/commands/LsCommand.java[Added - diff]
java/java/management/cli/src/org/apache/qpid/stac/jmx/CurrentMBean.java[Added - diff]
java/java/management/cli/src/org/apache/qpid/stac/jmx/MBeanAttributeInfoComparator.java[Added - diff]
java/java/management/cli/src/org/apache/qpid/stac/jmx/MBeanOperationInfoComparator.java[Added - diff]
java/java/management/cli/src/org/apache/qpid/stac/jmx/MBeanServerConnectionContext.java[Added - diff]
java/java/management/cli/src/org/apache/qpid/stac/jmx/MBeanUtils.java[Added - diff]
java/java/management/cli/src/org/apache/qpid/stac/jmx/NotConnectedException.java[Added - diff]
java/java/management/cli/src/python/stac.py[Added - diff]
java/java/management/cli/test/org/apache/qpid/stac/ConnectionTest.java[Added - diff]
java/java/management/core/build-module.xml[Added - diff]
java/java/management/core/build-old.xml[Added - diff]
java/java/management/core/etc/cml-exampleschema.xml[Added - diff]
java/java/management/core/etc/cml.xsd[Added - diff]
java/java/management/core/lib/jakarta-commons/commons-attributes-api.jar[Added - diff]
java/java/management/core/lib/jakarta-commons/commons-attributes-compiler.jar[Added - diff]
java/java/management/core/lib/jakarta-commons/commons-beanutils.jar[Added - diff]
java/java/management/core/lib/jakarta-commons/commons-codec.jar[Added - diff]
java/java/management/core/lib/jakarta-commons/commons-collections.jar[Added - diff]
java/java/management/core/lib/jakarta-commons/commons-dbcp.jar[Added - diff]
java/java/management/core/lib/jakarta-commons/commons-digester.jar[Added - diff]
java/java/management/core/lib/jakarta-commons/commons-discovery.jar[Added - diff]
java/java/management/core/lib/jakarta-commons/commons-fileupload.jar[Added - diff]
java/java/management/core/lib/jakarta-commons/commons-httpclient.jar[Added - diff]
java/java/management/core/lib/jakarta-commons/commons-lang.jar[Added - diff]
java/java/management/core/lib/jakarta-commons/commons-logging.jar[Added - diff]
java/java/management/core/lib/jakarta-commons/commons-pool.jar[Added - diff]
java/java/management/core/lib/jakarta-commons/commons-validator.jar[Added - diff]
java/java/management/core/lib/spring/spring-beans.dtd[Added - diff]
java/java/management/core/lib/spring/spring.ftl[Added - diff]
java/java/management/core/lib/spring/spring.tld[Added - diff]
java/java/management/core/lib/spring/spring.vm[Added - diff]
java/java/management/core/lib/xmlbeans/jsr173_api.jar[Added - diff]
java/java/management/core/lib/xmlbeans/resolver.jar[Added - diff]
java/java/management/core/lib/xmlbeans/saxon8.jar[Added - diff]
java/java/management/core/lib/xmlbeans/xbean.jar[Added - diff]
java/java/management/core/lib/xmlbeans/xbean_xpath.jar[Added - diff]
java/java/management/core/lib/xmlbeans/xmlpublic.jar[Added - diff]
java/java/management/core/src/log4j.properties[Added - diff]
java/java/management/core/src/org/apache/qpid/management/ManagementConnection.java[Added - diff]
java/java/management/core/src/org/apache/qpid/management/jmx/AMQConsole.java[Added - diff]
java/java/management/core/src/org/apache/qpid/management/jmx/AMQMBeanInfo.java[Added - diff]
java/java/management/core/src/org/apache/qpid/management/jmx/CMLMBean.java[Added - diff]
java/java/management/core/src/org/apache/qpid/management/jmx/JmxConstants.java[Added - diff]
java/java/management/core/src/org/apache/qpid/management/jmx/MBeanInfoRegistry.java[Added - diff]
java/java/management/core/src/org/apache/qpid/management/jmx/MBeanRegistrar.java[Added - diff]
java/java/management/core/src/org/apache/qpid/management/jmx/UnsupportedCMLTypeException.java[Added - diff]
java/java/management/core/src/org/apache/qpid/management/messaging/CMLMessageFactory.java[Added - diff]
java/java/management/core/src/org/apache/qpid/management/messaging/ManagementDestination.java[Added - diff]
java/java/management/core/test/org/apache/qpid/management/harness/SimpleJMXClient.java[Added - diff]
java/java/management/core/test/org/apache/qpid/management/schema/TestParseSchema.java[Added - diff]
java/java/management/mc4j/qpid/BlazeConnections.xml[Added - diff]
java/java/management/mc4j/qpid/BlazeExchanges.xml[Added - diff]
java/java/management/mc4j/qpid/BlazeQueues.xml[Added - diff]
java/java/management/mc4j/qpid/BlazeSingleQueue.xml[Added - diff]
java/java/management/webapp/META-INF/context.xml[Added - diff]
java/java/management/webapp/WEB-INF/web.xml[Added - diff]
java/java/module.xml[Added - diff]
java/java/release-docs/RELEASE_NOTES.txt[Added - diff]
java/java/resources/META-INF/DISCLAIMER.txt[Added - diff]
java/java/tasks/src/org/apache/qpid/tasks/BaseTask.java[Added - diff]
java/java/tasks/src/org/apache/qpid/tasks/Foreach.java[Added - diff]
java/java/tasks/src/org/apache/qpid/tasks/Map.java[Added - diff]
java/java/tasks/src/org/apache/qpid/tasks/Require.java[Added - diff]

718 files changed

tree: 56a4059af1d6a800993a9efa4513bada47f3f482

java/