summaryrefslogtreecommitdiff
path: root/java/broker/src
diff options
context:
space:
mode:
authorStephen Vinoski <vinoski@apache.org>2006-11-18 02:12:32 +0000
committerStephen Vinoski <vinoski@apache.org>2006-11-18 02:12:32 +0000
commit1db5a8a2329ec064d1683294ee1a3d8d233de42d (patch)
treef5ac42c441d4829262d560696cb2cad98fc0434f /java/broker/src
parentd386f860a3404ec9735dab2730f8ed683446838c (diff)
downloadqpid-python-1db5a8a2329ec064d1683294ee1a3d8d233de42d.tar.gz
directory moves required for maven merge
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@476414 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/broker/src')
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java (renamed from java/broker/src/org/apache/qpid/server/AMQChannel.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/ConsumerTagNotUniqueException.java (renamed from java/broker/src/org/apache/qpid/server/ConsumerTagNotUniqueException.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/Main.java (renamed from java/broker/src/org/apache/qpid/server/Main.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/ManagedChannel.java (renamed from java/broker/src/org/apache/qpid/server/ManagedChannel.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/RequiredDeliveryException.java (renamed from java/broker/src/org/apache/qpid/server/RequiredDeliveryException.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/ack/TxAck.java (renamed from java/broker/src/org/apache/qpid/server/ack/TxAck.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/ack/UnacknowledgedMessage.java (renamed from java/broker/src/org/apache/qpid/server/ack/UnacknowledgedMessage.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/ack/UnacknowledgedMessageMap.java (renamed from java/broker/src/org/apache/qpid/server/ack/UnacknowledgedMessageMap.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/ack/UnacknowledgedMessageMapImpl.java (renamed from java/broker/src/org/apache/qpid/server/ack/UnacknowledgedMessageMapImpl.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/configuration/Configurator.java (renamed from java/broker/src/org/apache/qpid/server/configuration/Configurator.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/configuration/VirtualHostConfiguration.java (renamed from java/broker/src/org/apache/qpid/server/configuration/VirtualHostConfiguration.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java (renamed from java/broker/src/org/apache/qpid/server/exchange/AbstractExchange.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/exchange/DefaultExchangeFactory.java (renamed from java/broker/src/org/apache/qpid/server/exchange/DefaultExchangeFactory.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/exchange/DefaultExchangeRegistry.java (renamed from java/broker/src/org/apache/qpid/server/exchange/DefaultExchangeRegistry.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/exchange/DestNameExchange.java (renamed from java/broker/src/org/apache/qpid/server/exchange/DestNameExchange.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/exchange/DestWildExchange.java (renamed from java/broker/src/org/apache/qpid/server/exchange/DestWildExchange.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/exchange/Exchange.java (renamed from java/broker/src/org/apache/qpid/server/exchange/Exchange.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/exchange/ExchangeFactory.java (renamed from java/broker/src/org/apache/qpid/server/exchange/ExchangeFactory.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/exchange/ExchangeInUseException.java (renamed from java/broker/src/org/apache/qpid/server/exchange/ExchangeInUseException.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/exchange/ExchangeRegistry.java (renamed from java/broker/src/org/apache/qpid/server/exchange/ExchangeRegistry.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/exchange/HeadersBinding.java (renamed from java/broker/src/org/apache/qpid/server/exchange/HeadersBinding.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/exchange/HeadersExchange.java (renamed from java/broker/src/org/apache/qpid/server/exchange/HeadersExchange.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/exchange/Index.java (renamed from java/broker/src/org/apache/qpid/server/exchange/Index.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/exchange/ManagedExchange.java (renamed from java/broker/src/org/apache/qpid/server/exchange/ManagedExchange.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/exchange/MessageRouter.java (renamed from java/broker/src/org/apache/qpid/server/exchange/MessageRouter.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/exchange/NoRouteException.java (renamed from java/broker/src/org/apache/qpid/server/exchange/NoRouteException.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/handler/BasicAckMethodHandler.java (renamed from java/broker/src/org/apache/qpid/server/handler/BasicAckMethodHandler.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/handler/BasicCancelMethodHandler.java (renamed from java/broker/src/org/apache/qpid/server/handler/BasicCancelMethodHandler.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/handler/BasicConsumeMethodHandler.java (renamed from java/broker/src/org/apache/qpid/server/handler/BasicConsumeMethodHandler.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/handler/BasicPublishMethodHandler.java (renamed from java/broker/src/org/apache/qpid/server/handler/BasicPublishMethodHandler.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/handler/BasicQosHandler.java (renamed from java/broker/src/org/apache/qpid/server/handler/BasicQosHandler.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/handler/BasicRecoverMethodHandler.java (renamed from java/broker/src/org/apache/qpid/server/handler/BasicRecoverMethodHandler.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/handler/ChannelCloseHandler.java (renamed from java/broker/src/org/apache/qpid/server/handler/ChannelCloseHandler.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/handler/ChannelCloseOkHandler.java (renamed from java/broker/src/org/apache/qpid/server/handler/ChannelCloseOkHandler.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/handler/ChannelFlowHandler.java (renamed from java/broker/src/org/apache/qpid/server/handler/ChannelFlowHandler.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/handler/ChannelOpenHandler.java (renamed from java/broker/src/org/apache/qpid/server/handler/ChannelOpenHandler.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/handler/ConnectionCloseMethodHandler.java (renamed from java/broker/src/org/apache/qpid/server/handler/ConnectionCloseMethodHandler.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/handler/ConnectionCloseOkMethodHandler.java (renamed from java/broker/src/org/apache/qpid/server/handler/ConnectionCloseOkMethodHandler.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/handler/ConnectionOpenMethodHandler.java (renamed from java/broker/src/org/apache/qpid/server/handler/ConnectionOpenMethodHandler.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/handler/ConnectionSecureOkMethodHandler.java (renamed from java/broker/src/org/apache/qpid/server/handler/ConnectionSecureOkMethodHandler.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/handler/ConnectionStartOkMethodHandler.java (renamed from java/broker/src/org/apache/qpid/server/handler/ConnectionStartOkMethodHandler.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/handler/ConnectionTuneOkMethodHandler.java (renamed from java/broker/src/org/apache/qpid/server/handler/ConnectionTuneOkMethodHandler.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/handler/ExchangeDeclareHandler.java (renamed from java/broker/src/org/apache/qpid/server/handler/ExchangeDeclareHandler.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/handler/ExchangeDeleteHandler.java (renamed from java/broker/src/org/apache/qpid/server/handler/ExchangeDeleteHandler.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/handler/OnCurrentThreadExecutor.java (renamed from java/broker/src/org/apache/qpid/server/handler/OnCurrentThreadExecutor.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/handler/QueueBindHandler.java (renamed from java/broker/src/org/apache/qpid/server/handler/QueueBindHandler.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/handler/QueueDeclareHandler.java (renamed from java/broker/src/org/apache/qpid/server/handler/QueueDeclareHandler.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/handler/QueueDeleteHandler.java (renamed from java/broker/src/org/apache/qpid/server/handler/QueueDeleteHandler.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/handler/TxCommitHandler.java (renamed from java/broker/src/org/apache/qpid/server/handler/TxCommitHandler.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/handler/TxRollbackHandler.java (renamed from java/broker/src/org/apache/qpid/server/handler/TxRollbackHandler.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/handler/TxSelectHandler.java (renamed from java/broker/src/org/apache/qpid/server/handler/TxSelectHandler.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/jms/JmsConsumer.java (renamed from java/broker/src/org/apache/qpid/server/jms/JmsConsumer.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/management/AMQManagedObject.java (renamed from java/broker/src/org/apache/qpid/server/management/AMQManagedObject.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/management/DefaultManagedObject.java (renamed from java/broker/src/org/apache/qpid/server/management/DefaultManagedObject.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/management/JMXManagedObjectRegistry.java (renamed from java/broker/src/org/apache/qpid/server/management/JMXManagedObjectRegistry.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/management/MBeanAttribute.java (renamed from java/broker/src/org/apache/qpid/server/management/MBeanAttribute.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/management/MBeanConstructor.java (renamed from java/broker/src/org/apache/qpid/server/management/MBeanConstructor.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/management/MBeanDescription.java (renamed from java/broker/src/org/apache/qpid/server/management/MBeanDescription.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/management/MBeanIntrospector.java (renamed from java/broker/src/org/apache/qpid/server/management/MBeanIntrospector.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/management/MBeanOperation.java (renamed from java/broker/src/org/apache/qpid/server/management/MBeanOperation.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/management/MBeanOperationParameter.java (renamed from java/broker/src/org/apache/qpid/server/management/MBeanOperationParameter.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/management/Managable.java (renamed from java/broker/src/org/apache/qpid/server/management/Managable.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/management/ManagedBroker.java (renamed from java/broker/src/org/apache/qpid/server/management/ManagedBroker.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/management/ManagedObject.java (renamed from java/broker/src/org/apache/qpid/server/management/ManagedObject.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/management/ManagedObjectRegistry.java (renamed from java/broker/src/org/apache/qpid/server/management/ManagedObjectRegistry.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/management/ManagementConfiguration.java (renamed from java/broker/src/org/apache/qpid/server/management/ManagementConfiguration.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/management/NoopManagedObjectRegistry.java (renamed from java/broker/src/org/apache/qpid/server/management/NoopManagedObjectRegistry.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMethodEvent.java (renamed from java/broker/src/org/apache/qpid/server/protocol/AMQMethodEvent.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMethodListener.java (renamed from java/broker/src/org/apache/qpid/server/protocol/AMQMethodListener.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java (renamed from java/broker/src/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/protocol/AMQPFastProtocolHandler.java (renamed from java/broker/src/org/apache/qpid/server/protocol/AMQPFastProtocolHandler.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/protocol/AMQPProtocolProvider.java (renamed from java/broker/src/org/apache/qpid/server/protocol/AMQPProtocolProvider.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSession.java (renamed from java/broker/src/org/apache/qpid/server/protocol/AMQProtocolSession.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/protocol/ExchangeInitialiser.java (renamed from java/broker/src/org/apache/qpid/server/protocol/ExchangeInitialiser.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/protocol/HeartbeatConfig.java (renamed from java/broker/src/org/apache/qpid/server/protocol/HeartbeatConfig.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/protocol/ManagedConnection.java (renamed from java/broker/src/org/apache/qpid/server/protocol/ManagedConnection.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/queue/AMQMessage.java (renamed from java/broker/src/org/apache/qpid/server/queue/AMQMessage.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueue.java (renamed from java/broker/src/org/apache/qpid/server/queue/AMQQueue.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/queue/AsyncDeliveryConfig.java (renamed from java/broker/src/org/apache/qpid/server/queue/AsyncDeliveryConfig.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/queue/ConcurrentDeliveryManager.java (renamed from java/broker/src/org/apache/qpid/server/queue/ConcurrentDeliveryManager.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/queue/DefaultQueueRegistry.java (renamed from java/broker/src/org/apache/qpid/server/queue/DefaultQueueRegistry.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/queue/DeliveryManager.java (renamed from java/broker/src/org/apache/qpid/server/queue/DeliveryManager.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/queue/ExchangeBindings.java (renamed from java/broker/src/org/apache/qpid/server/queue/ExchangeBindings.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/queue/FailedDequeueException.java (renamed from java/broker/src/org/apache/qpid/server/queue/FailedDequeueException.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/queue/ManagedQueue.java (renamed from java/broker/src/org/apache/qpid/server/queue/ManagedQueue.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/queue/MessageCleanupException.java (renamed from java/broker/src/org/apache/qpid/server/queue/MessageCleanupException.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/queue/NoConsumersException.java (renamed from java/broker/src/org/apache/qpid/server/queue/NoConsumersException.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/queue/QueueRegistry.java (renamed from java/broker/src/org/apache/qpid/server/queue/QueueRegistry.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/queue/Subscription.java (renamed from java/broker/src/org/apache/qpid/server/queue/Subscription.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/queue/SubscriptionFactory.java (renamed from java/broker/src/org/apache/qpid/server/queue/SubscriptionFactory.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/queue/SubscriptionImpl.java (renamed from java/broker/src/org/apache/qpid/server/queue/SubscriptionImpl.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/queue/SubscriptionManager.java (renamed from java/broker/src/org/apache/qpid/server/queue/SubscriptionManager.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/queue/SubscriptionSet.java (renamed from java/broker/src/org/apache/qpid/server/queue/SubscriptionSet.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/queue/SynchronizedDeliveryManager.java (renamed from java/broker/src/org/apache/qpid/server/queue/SynchronizedDeliveryManager.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/queue/WeightedSubscriptionManager.java (renamed from java/broker/src/org/apache/qpid/server/queue/WeightedSubscriptionManager.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/registry/ApplicationRegistry.java (renamed from java/broker/src/org/apache/qpid/server/registry/ApplicationRegistry.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/registry/ConfigurationFileApplicationRegistry.java (renamed from java/broker/src/org/apache/qpid/server/registry/ConfigurationFileApplicationRegistry.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/registry/IApplicationRegistry.java (renamed from java/broker/src/org/apache/qpid/server/registry/IApplicationRegistry.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/security/auth/AuthenticationManager.java (renamed from java/broker/src/org/apache/qpid/server/security/auth/AuthenticationManager.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/security/auth/AuthenticationProviderInitialiser.java (renamed from java/broker/src/org/apache/qpid/server/security/auth/AuthenticationProviderInitialiser.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/security/auth/AuthenticationResult.java (renamed from java/broker/src/org/apache/qpid/server/security/auth/AuthenticationResult.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/security/auth/CRAMMD5Initialiser.java (renamed from java/broker/src/org/apache/qpid/server/security/auth/CRAMMD5Initialiser.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/security/auth/JCAProvider.java (renamed from java/broker/src/org/apache/qpid/server/security/auth/JCAProvider.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/security/auth/NullAuthenticationManager.java (renamed from java/broker/src/org/apache/qpid/server/security/auth/NullAuthenticationManager.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/security/auth/PasswordFilePrincipalDatabase.java (renamed from java/broker/src/org/apache/qpid/server/security/auth/PasswordFilePrincipalDatabase.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/security/auth/PrincipalDatabase.java (renamed from java/broker/src/org/apache/qpid/server/security/auth/PrincipalDatabase.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/security/auth/SASLAuthenticationManager.java (renamed from java/broker/src/org/apache/qpid/server/security/auth/SASLAuthenticationManager.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/security/auth/UsernamePasswordInitialiser.java (renamed from java/broker/src/org/apache/qpid/server/security/auth/UsernamePasswordInitialiser.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/security/auth/UsernamePrincipal.java (renamed from java/broker/src/org/apache/qpid/server/security/auth/UsernamePrincipal.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/security/auth/amqplain/AmqPlainInitialiser.java (renamed from java/broker/src/org/apache/qpid/server/security/auth/amqplain/AmqPlainInitialiser.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/security/auth/amqplain/AmqPlainSaslServer.java (renamed from java/broker/src/org/apache/qpid/server/security/auth/amqplain/AmqPlainSaslServer.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/security/auth/amqplain/AmqPlainSaslServerFactory.java (renamed from java/broker/src/org/apache/qpid/server/security/auth/amqplain/AmqPlainSaslServerFactory.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/security/auth/plain/PlainInitialiser.java (renamed from java/broker/src/org/apache/qpid/server/security/auth/plain/PlainInitialiser.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/security/auth/plain/PlainSaslServer.java (renamed from java/broker/src/org/apache/qpid/server/security/auth/plain/PlainSaslServer.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/security/auth/plain/PlainSaslServerFactory.java (renamed from java/broker/src/org/apache/qpid/server/security/auth/plain/PlainSaslServerFactory.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/state/AMQState.java (renamed from java/broker/src/org/apache/qpid/server/state/AMQState.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/state/AMQStateManager.java (renamed from java/broker/src/org/apache/qpid/server/state/AMQStateManager.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/state/IllegalStateTransitionException.java (renamed from java/broker/src/org/apache/qpid/server/state/IllegalStateTransitionException.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/state/StateAwareMethodListener.java (renamed from java/broker/src/org/apache/qpid/server/state/StateAwareMethodListener.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/state/StateListener.java (renamed from java/broker/src/org/apache/qpid/server/state/StateListener.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/store/MemoryMessageStore.java (renamed from java/broker/src/org/apache/qpid/server/store/MemoryMessageStore.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/store/MessageStore.java (renamed from java/broker/src/org/apache/qpid/server/store/MessageStore.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/transport/ConnectorConfiguration.java (renamed from java/broker/src/org/apache/qpid/server/transport/ConnectorConfiguration.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/transport/ThreadPoolFilter.java (renamed from java/broker/src/org/apache/qpid/server/transport/ThreadPoolFilter.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/txn/TxnBuffer.java (renamed from java/broker/src/org/apache/qpid/server/txn/TxnBuffer.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/txn/TxnOp.java (renamed from java/broker/src/org/apache/qpid/server/txn/TxnOp.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/util/CircularBuffer.java (renamed from java/broker/src/org/apache/qpid/server/util/CircularBuffer.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/util/ConcurrentLinkedQueueNoSize.java (renamed from java/broker/src/org/apache/qpid/server/util/ConcurrentLinkedQueueNoSize.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/util/LoggingProxy.java (renamed from java/broker/src/org/apache/qpid/server/util/LoggingProxy.java)0
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/util/NullApplicationRegistry.java (renamed from java/broker/src/org/apache/qpid/server/util/NullApplicationRegistry.java)0
-rw-r--r--java/broker/src/test/java/org/apache/qpid/server/UnitTests.java39
-rw-r--r--java/broker/src/test/java/org/apache/qpid/server/configuration/TestPropertyUtils.java53
-rw-r--r--java/broker/src/test/java/org/apache/qpid/server/configuration/UnitTests.java35
-rw-r--r--java/broker/src/test/java/org/apache/qpid/server/exchange/HeadersBindingTest.java203
-rw-r--r--java/broker/src/test/java/org/apache/qpid/server/exchange/UnitTests.java35
-rw-r--r--java/broker/src/test/java/org/apache/qpid/server/util/LoggingProxyTest.java92
-rw-r--r--java/broker/src/test/java/org/apache/qpid/server/util/UnitTests.java35
137 files changed, 492 insertions, 0 deletions
diff --git a/java/broker/src/org/apache/qpid/server/AMQChannel.java b/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java
index a6cb4523cf..a6cb4523cf 100644
--- a/java/broker/src/org/apache/qpid/server/AMQChannel.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/AMQChannel.java
diff --git a/java/broker/src/org/apache/qpid/server/ConsumerTagNotUniqueException.java b/java/broker/src/main/java/org/apache/qpid/server/ConsumerTagNotUniqueException.java
index 9a98af5689..9a98af5689 100644
--- a/java/broker/src/org/apache/qpid/server/ConsumerTagNotUniqueException.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/ConsumerTagNotUniqueException.java
diff --git a/java/broker/src/org/apache/qpid/server/Main.java b/java/broker/src/main/java/org/apache/qpid/server/Main.java
index d2dacb6140..d2dacb6140 100644
--- a/java/broker/src/org/apache/qpid/server/Main.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/Main.java
diff --git a/java/broker/src/org/apache/qpid/server/ManagedChannel.java b/java/broker/src/main/java/org/apache/qpid/server/ManagedChannel.java
index 74c5366c7d..74c5366c7d 100644
--- a/java/broker/src/org/apache/qpid/server/ManagedChannel.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/ManagedChannel.java
diff --git a/java/broker/src/org/apache/qpid/server/RequiredDeliveryException.java b/java/broker/src/main/java/org/apache/qpid/server/RequiredDeliveryException.java
index 87691ccaa3..87691ccaa3 100644
--- a/java/broker/src/org/apache/qpid/server/RequiredDeliveryException.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/RequiredDeliveryException.java
diff --git a/java/broker/src/org/apache/qpid/server/ack/TxAck.java b/java/broker/src/main/java/org/apache/qpid/server/ack/TxAck.java
index a4cb1f1e71..a4cb1f1e71 100644
--- a/java/broker/src/org/apache/qpid/server/ack/TxAck.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/ack/TxAck.java
diff --git a/java/broker/src/org/apache/qpid/server/ack/UnacknowledgedMessage.java b/java/broker/src/main/java/org/apache/qpid/server/ack/UnacknowledgedMessage.java
index 0eff5a3cca..0eff5a3cca 100644
--- a/java/broker/src/org/apache/qpid/server/ack/UnacknowledgedMessage.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/ack/UnacknowledgedMessage.java
diff --git a/java/broker/src/org/apache/qpid/server/ack/UnacknowledgedMessageMap.java b/java/broker/src/main/java/org/apache/qpid/server/ack/UnacknowledgedMessageMap.java
index b0bbe224e3..b0bbe224e3 100644
--- a/java/broker/src/org/apache/qpid/server/ack/UnacknowledgedMessageMap.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/ack/UnacknowledgedMessageMap.java
diff --git a/java/broker/src/org/apache/qpid/server/ack/UnacknowledgedMessageMapImpl.java b/java/broker/src/main/java/org/apache/qpid/server/ack/UnacknowledgedMessageMapImpl.java
index eda3233e56..eda3233e56 100644
--- a/java/broker/src/org/apache/qpid/server/ack/UnacknowledgedMessageMapImpl.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/ack/UnacknowledgedMessageMapImpl.java
diff --git a/java/broker/src/org/apache/qpid/server/configuration/Configurator.java b/java/broker/src/main/java/org/apache/qpid/server/configuration/Configurator.java
index 5e3ac03ba7..5e3ac03ba7 100644
--- a/java/broker/src/org/apache/qpid/server/configuration/Configurator.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/configuration/Configurator.java
diff --git a/java/broker/src/org/apache/qpid/server/configuration/VirtualHostConfiguration.java b/java/broker/src/main/java/org/apache/qpid/server/configuration/VirtualHostConfiguration.java
index 9ecbf3d31a..9ecbf3d31a 100644
--- a/java/broker/src/org/apache/qpid/server/configuration/VirtualHostConfiguration.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/configuration/VirtualHostConfiguration.java
diff --git a/java/broker/src/org/apache/qpid/server/exchange/AbstractExchange.java b/java/broker/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java
index 69f5e862d6..69f5e862d6 100644
--- a/java/broker/src/org/apache/qpid/server/exchange/AbstractExchange.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java
diff --git a/java/broker/src/org/apache/qpid/server/exchange/DefaultExchangeFactory.java b/java/broker/src/main/java/org/apache/qpid/server/exchange/DefaultExchangeFactory.java
index 0c73e0f9f0..0c73e0f9f0 100644
--- a/java/broker/src/org/apache/qpid/server/exchange/DefaultExchangeFactory.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/exchange/DefaultExchangeFactory.java
diff --git a/java/broker/src/org/apache/qpid/server/exchange/DefaultExchangeRegistry.java b/java/broker/src/main/java/org/apache/qpid/server/exchange/DefaultExchangeRegistry.java
index eb9d1acb59..eb9d1acb59 100644
--- a/java/broker/src/org/apache/qpid/server/exchange/DefaultExchangeRegistry.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/exchange/DefaultExchangeRegistry.java
diff --git a/java/broker/src/org/apache/qpid/server/exchange/DestNameExchange.java b/java/broker/src/main/java/org/apache/qpid/server/exchange/DestNameExchange.java
index 085d0aad19..085d0aad19 100644
--- a/java/broker/src/org/apache/qpid/server/exchange/DestNameExchange.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/exchange/DestNameExchange.java
diff --git a/java/broker/src/org/apache/qpid/server/exchange/DestWildExchange.java b/java/broker/src/main/java/org/apache/qpid/server/exchange/DestWildExchange.java
index f6abd53076..f6abd53076 100644
--- a/java/broker/src/org/apache/qpid/server/exchange/DestWildExchange.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/exchange/DestWildExchange.java
diff --git a/java/broker/src/org/apache/qpid/server/exchange/Exchange.java b/java/broker/src/main/java/org/apache/qpid/server/exchange/Exchange.java
index 787d0eddfd..787d0eddfd 100644
--- a/java/broker/src/org/apache/qpid/server/exchange/Exchange.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/exchange/Exchange.java
diff --git a/java/broker/src/org/apache/qpid/server/exchange/ExchangeFactory.java b/java/broker/src/main/java/org/apache/qpid/server/exchange/ExchangeFactory.java
index 37ba883bc3..37ba883bc3 100644
--- a/java/broker/src/org/apache/qpid/server/exchange/ExchangeFactory.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/exchange/ExchangeFactory.java
diff --git a/java/broker/src/org/apache/qpid/server/exchange/ExchangeInUseException.java b/java/broker/src/main/java/org/apache/qpid/server/exchange/ExchangeInUseException.java
index 6b2891c573..6b2891c573 100644
--- a/java/broker/src/org/apache/qpid/server/exchange/ExchangeInUseException.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/exchange/ExchangeInUseException.java
diff --git a/java/broker/src/org/apache/qpid/server/exchange/ExchangeRegistry.java b/java/broker/src/main/java/org/apache/qpid/server/exchange/ExchangeRegistry.java
index dcc50a796a..dcc50a796a 100644
--- a/java/broker/src/org/apache/qpid/server/exchange/ExchangeRegistry.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/exchange/ExchangeRegistry.java
diff --git a/java/broker/src/org/apache/qpid/server/exchange/HeadersBinding.java b/java/broker/src/main/java/org/apache/qpid/server/exchange/HeadersBinding.java
index b058211288..b058211288 100644
--- a/java/broker/src/org/apache/qpid/server/exchange/HeadersBinding.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/exchange/HeadersBinding.java
diff --git a/java/broker/src/org/apache/qpid/server/exchange/HeadersExchange.java b/java/broker/src/main/java/org/apache/qpid/server/exchange/HeadersExchange.java
index 961d4ddf4c..961d4ddf4c 100644
--- a/java/broker/src/org/apache/qpid/server/exchange/HeadersExchange.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/exchange/HeadersExchange.java
diff --git a/java/broker/src/org/apache/qpid/server/exchange/Index.java b/java/broker/src/main/java/org/apache/qpid/server/exchange/Index.java
index fb48729c9e..fb48729c9e 100644
--- a/java/broker/src/org/apache/qpid/server/exchange/Index.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/exchange/Index.java
diff --git a/java/broker/src/org/apache/qpid/server/exchange/ManagedExchange.java b/java/broker/src/main/java/org/apache/qpid/server/exchange/ManagedExchange.java
index 3c2c105186..3c2c105186 100644
--- a/java/broker/src/org/apache/qpid/server/exchange/ManagedExchange.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/exchange/ManagedExchange.java
diff --git a/java/broker/src/org/apache/qpid/server/exchange/MessageRouter.java b/java/broker/src/main/java/org/apache/qpid/server/exchange/MessageRouter.java
index 70b80f65da..70b80f65da 100644
--- a/java/broker/src/org/apache/qpid/server/exchange/MessageRouter.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/exchange/MessageRouter.java
diff --git a/java/broker/src/org/apache/qpid/server/exchange/NoRouteException.java b/java/broker/src/main/java/org/apache/qpid/server/exchange/NoRouteException.java
index fb0a330263..fb0a330263 100644
--- a/java/broker/src/org/apache/qpid/server/exchange/NoRouteException.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/exchange/NoRouteException.java
diff --git a/java/broker/src/org/apache/qpid/server/handler/BasicAckMethodHandler.java b/java/broker/src/main/java/org/apache/qpid/server/handler/BasicAckMethodHandler.java
index b2b7a21296..b2b7a21296 100644
--- a/java/broker/src/org/apache/qpid/server/handler/BasicAckMethodHandler.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/handler/BasicAckMethodHandler.java
diff --git a/java/broker/src/org/apache/qpid/server/handler/BasicCancelMethodHandler.java b/java/broker/src/main/java/org/apache/qpid/server/handler/BasicCancelMethodHandler.java
index 673556cbec..673556cbec 100644
--- a/java/broker/src/org/apache/qpid/server/handler/BasicCancelMethodHandler.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/handler/BasicCancelMethodHandler.java
diff --git a/java/broker/src/org/apache/qpid/server/handler/BasicConsumeMethodHandler.java b/java/broker/src/main/java/org/apache/qpid/server/handler/BasicConsumeMethodHandler.java
index d4c94061a0..d4c94061a0 100644
--- a/java/broker/src/org/apache/qpid/server/handler/BasicConsumeMethodHandler.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/handler/BasicConsumeMethodHandler.java
diff --git a/java/broker/src/org/apache/qpid/server/handler/BasicPublishMethodHandler.java b/java/broker/src/main/java/org/apache/qpid/server/handler/BasicPublishMethodHandler.java
index efdbe7aae4..efdbe7aae4 100644
--- a/java/broker/src/org/apache/qpid/server/handler/BasicPublishMethodHandler.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/handler/BasicPublishMethodHandler.java
diff --git a/java/broker/src/org/apache/qpid/server/handler/BasicQosHandler.java b/java/broker/src/main/java/org/apache/qpid/server/handler/BasicQosHandler.java
index 1357ff16b9..1357ff16b9 100644
--- a/java/broker/src/org/apache/qpid/server/handler/BasicQosHandler.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/handler/BasicQosHandler.java
diff --git a/java/broker/src/org/apache/qpid/server/handler/BasicRecoverMethodHandler.java b/java/broker/src/main/java/org/apache/qpid/server/handler/BasicRecoverMethodHandler.java
index 85e802d10d..85e802d10d 100644
--- a/java/broker/src/org/apache/qpid/server/handler/BasicRecoverMethodHandler.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/handler/BasicRecoverMethodHandler.java
diff --git a/java/broker/src/org/apache/qpid/server/handler/ChannelCloseHandler.java b/java/broker/src/main/java/org/apache/qpid/server/handler/ChannelCloseHandler.java
index 0efe12b137..0efe12b137 100644
--- a/java/broker/src/org/apache/qpid/server/handler/ChannelCloseHandler.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/handler/ChannelCloseHandler.java
diff --git a/java/broker/src/org/apache/qpid/server/handler/ChannelCloseOkHandler.java b/java/broker/src/main/java/org/apache/qpid/server/handler/ChannelCloseOkHandler.java
index fd6714de3a..fd6714de3a 100644
--- a/java/broker/src/org/apache/qpid/server/handler/ChannelCloseOkHandler.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/handler/ChannelCloseOkHandler.java
diff --git a/java/broker/src/org/apache/qpid/server/handler/ChannelFlowHandler.java b/java/broker/src/main/java/org/apache/qpid/server/handler/ChannelFlowHandler.java
index 8417ada15f..8417ada15f 100644
--- a/java/broker/src/org/apache/qpid/server/handler/ChannelFlowHandler.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/handler/ChannelFlowHandler.java
diff --git a/java/broker/src/org/apache/qpid/server/handler/ChannelOpenHandler.java b/java/broker/src/main/java/org/apache/qpid/server/handler/ChannelOpenHandler.java
index 4cccc774ba..4cccc774ba 100644
--- a/java/broker/src/org/apache/qpid/server/handler/ChannelOpenHandler.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/handler/ChannelOpenHandler.java
diff --git a/java/broker/src/org/apache/qpid/server/handler/ConnectionCloseMethodHandler.java b/java/broker/src/main/java/org/apache/qpid/server/handler/ConnectionCloseMethodHandler.java
index 7bdb1942d0..7bdb1942d0 100644
--- a/java/broker/src/org/apache/qpid/server/handler/ConnectionCloseMethodHandler.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/handler/ConnectionCloseMethodHandler.java
diff --git a/java/broker/src/org/apache/qpid/server/handler/ConnectionCloseOkMethodHandler.java b/java/broker/src/main/java/org/apache/qpid/server/handler/ConnectionCloseOkMethodHandler.java
index cc9277593b..cc9277593b 100644
--- a/java/broker/src/org/apache/qpid/server/handler/ConnectionCloseOkMethodHandler.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/handler/ConnectionCloseOkMethodHandler.java
diff --git a/java/broker/src/org/apache/qpid/server/handler/ConnectionOpenMethodHandler.java b/java/broker/src/main/java/org/apache/qpid/server/handler/ConnectionOpenMethodHandler.java
index bfcc50e1f8..bfcc50e1f8 100644
--- a/java/broker/src/org/apache/qpid/server/handler/ConnectionOpenMethodHandler.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/handler/ConnectionOpenMethodHandler.java
diff --git a/java/broker/src/org/apache/qpid/server/handler/ConnectionSecureOkMethodHandler.java b/java/broker/src/main/java/org/apache/qpid/server/handler/ConnectionSecureOkMethodHandler.java
index c858d25e2d..c858d25e2d 100644
--- a/java/broker/src/org/apache/qpid/server/handler/ConnectionSecureOkMethodHandler.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/handler/ConnectionSecureOkMethodHandler.java
diff --git a/java/broker/src/org/apache/qpid/server/handler/ConnectionStartOkMethodHandler.java b/java/broker/src/main/java/org/apache/qpid/server/handler/ConnectionStartOkMethodHandler.java
index 00ae547683..00ae547683 100644
--- a/java/broker/src/org/apache/qpid/server/handler/ConnectionStartOkMethodHandler.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/handler/ConnectionStartOkMethodHandler.java
diff --git a/java/broker/src/org/apache/qpid/server/handler/ConnectionTuneOkMethodHandler.java b/java/broker/src/main/java/org/apache/qpid/server/handler/ConnectionTuneOkMethodHandler.java
index f0b4e0a515..f0b4e0a515 100644
--- a/java/broker/src/org/apache/qpid/server/handler/ConnectionTuneOkMethodHandler.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/handler/ConnectionTuneOkMethodHandler.java
diff --git a/java/broker/src/org/apache/qpid/server/handler/ExchangeDeclareHandler.java b/java/broker/src/main/java/org/apache/qpid/server/handler/ExchangeDeclareHandler.java
index b7c75e290a..b7c75e290a 100644
--- a/java/broker/src/org/apache/qpid/server/handler/ExchangeDeclareHandler.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/handler/ExchangeDeclareHandler.java
diff --git a/java/broker/src/org/apache/qpid/server/handler/ExchangeDeleteHandler.java b/java/broker/src/main/java/org/apache/qpid/server/handler/ExchangeDeleteHandler.java
index 93ef902190..93ef902190 100644
--- a/java/broker/src/org/apache/qpid/server/handler/ExchangeDeleteHandler.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/handler/ExchangeDeleteHandler.java
diff --git a/java/broker/src/org/apache/qpid/server/handler/OnCurrentThreadExecutor.java b/java/broker/src/main/java/org/apache/qpid/server/handler/OnCurrentThreadExecutor.java
index ac516b6133..ac516b6133 100644
--- a/java/broker/src/org/apache/qpid/server/handler/OnCurrentThreadExecutor.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/handler/OnCurrentThreadExecutor.java
diff --git a/java/broker/src/org/apache/qpid/server/handler/QueueBindHandler.java b/java/broker/src/main/java/org/apache/qpid/server/handler/QueueBindHandler.java
index cf9e40a660..cf9e40a660 100644
--- a/java/broker/src/org/apache/qpid/server/handler/QueueBindHandler.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/handler/QueueBindHandler.java
diff --git a/java/broker/src/org/apache/qpid/server/handler/QueueDeclareHandler.java b/java/broker/src/main/java/org/apache/qpid/server/handler/QueueDeclareHandler.java
index b7004de2a9..b7004de2a9 100644
--- a/java/broker/src/org/apache/qpid/server/handler/QueueDeclareHandler.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/handler/QueueDeclareHandler.java
diff --git a/java/broker/src/org/apache/qpid/server/handler/QueueDeleteHandler.java b/java/broker/src/main/java/org/apache/qpid/server/handler/QueueDeleteHandler.java
index 0dbc54f29b..0dbc54f29b 100644
--- a/java/broker/src/org/apache/qpid/server/handler/QueueDeleteHandler.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/handler/QueueDeleteHandler.java
diff --git a/java/broker/src/org/apache/qpid/server/handler/TxCommitHandler.java b/java/broker/src/main/java/org/apache/qpid/server/handler/TxCommitHandler.java
index ac864cab6c..ac864cab6c 100644
--- a/java/broker/src/org/apache/qpid/server/handler/TxCommitHandler.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/handler/TxCommitHandler.java
diff --git a/java/broker/src/org/apache/qpid/server/handler/TxRollbackHandler.java b/java/broker/src/main/java/org/apache/qpid/server/handler/TxRollbackHandler.java
index 475f6ecacf..475f6ecacf 100644
--- a/java/broker/src/org/apache/qpid/server/handler/TxRollbackHandler.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/handler/TxRollbackHandler.java
diff --git a/java/broker/src/org/apache/qpid/server/handler/TxSelectHandler.java b/java/broker/src/main/java/org/apache/qpid/server/handler/TxSelectHandler.java
index c30bc7d66f..c30bc7d66f 100644
--- a/java/broker/src/org/apache/qpid/server/handler/TxSelectHandler.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/handler/TxSelectHandler.java
diff --git a/java/broker/src/org/apache/qpid/server/jms/JmsConsumer.java b/java/broker/src/main/java/org/apache/qpid/server/jms/JmsConsumer.java
index 41786e84ba..41786e84ba 100644
--- a/java/broker/src/org/apache/qpid/server/jms/JmsConsumer.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/jms/JmsConsumer.java
diff --git a/java/broker/src/org/apache/qpid/server/management/AMQManagedObject.java b/java/broker/src/main/java/org/apache/qpid/server/management/AMQManagedObject.java
index a2c2bd62a2..a2c2bd62a2 100644
--- a/java/broker/src/org/apache/qpid/server/management/AMQManagedObject.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/management/AMQManagedObject.java
diff --git a/java/broker/src/org/apache/qpid/server/management/DefaultManagedObject.java b/java/broker/src/main/java/org/apache/qpid/server/management/DefaultManagedObject.java
index 311eb8add9..311eb8add9 100644
--- a/java/broker/src/org/apache/qpid/server/management/DefaultManagedObject.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/management/DefaultManagedObject.java
diff --git a/java/broker/src/org/apache/qpid/server/management/JMXManagedObjectRegistry.java b/java/broker/src/main/java/org/apache/qpid/server/management/JMXManagedObjectRegistry.java
index 140dbc31bb..140dbc31bb 100644
--- a/java/broker/src/org/apache/qpid/server/management/JMXManagedObjectRegistry.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/management/JMXManagedObjectRegistry.java
diff --git a/java/broker/src/org/apache/qpid/server/management/MBeanAttribute.java b/java/broker/src/main/java/org/apache/qpid/server/management/MBeanAttribute.java
index a2e387a9e0..a2e387a9e0 100644
--- a/java/broker/src/org/apache/qpid/server/management/MBeanAttribute.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/management/MBeanAttribute.java
diff --git a/java/broker/src/org/apache/qpid/server/management/MBeanConstructor.java b/java/broker/src/main/java/org/apache/qpid/server/management/MBeanConstructor.java
index c2cafcd387..c2cafcd387 100644
--- a/java/broker/src/org/apache/qpid/server/management/MBeanConstructor.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/management/MBeanConstructor.java
diff --git a/java/broker/src/org/apache/qpid/server/management/MBeanDescription.java b/java/broker/src/main/java/org/apache/qpid/server/management/MBeanDescription.java
index e25ceeab5c..e25ceeab5c 100644
--- a/java/broker/src/org/apache/qpid/server/management/MBeanDescription.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/management/MBeanDescription.java
diff --git a/java/broker/src/org/apache/qpid/server/management/MBeanIntrospector.java b/java/broker/src/main/java/org/apache/qpid/server/management/MBeanIntrospector.java
index b8235a0808..b8235a0808 100644
--- a/java/broker/src/org/apache/qpid/server/management/MBeanIntrospector.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/management/MBeanIntrospector.java
diff --git a/java/broker/src/org/apache/qpid/server/management/MBeanOperation.java b/java/broker/src/main/java/org/apache/qpid/server/management/MBeanOperation.java
index ebeccadf70..ebeccadf70 100644
--- a/java/broker/src/org/apache/qpid/server/management/MBeanOperation.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/management/MBeanOperation.java
diff --git a/java/broker/src/org/apache/qpid/server/management/MBeanOperationParameter.java b/java/broker/src/main/java/org/apache/qpid/server/management/MBeanOperationParameter.java
index adb3c651df..adb3c651df 100644
--- a/java/broker/src/org/apache/qpid/server/management/MBeanOperationParameter.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/management/MBeanOperationParameter.java
diff --git a/java/broker/src/org/apache/qpid/server/management/Managable.java b/java/broker/src/main/java/org/apache/qpid/server/management/Managable.java
index 166a2a376d..166a2a376d 100644
--- a/java/broker/src/org/apache/qpid/server/management/Managable.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/management/Managable.java
diff --git a/java/broker/src/org/apache/qpid/server/management/ManagedBroker.java b/java/broker/src/main/java/org/apache/qpid/server/management/ManagedBroker.java
index 266fb62fd8..266fb62fd8 100644
--- a/java/broker/src/org/apache/qpid/server/management/ManagedBroker.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/management/ManagedBroker.java
diff --git a/java/broker/src/org/apache/qpid/server/management/ManagedObject.java b/java/broker/src/main/java/org/apache/qpid/server/management/ManagedObject.java
index f512c2dea8..f512c2dea8 100644
--- a/java/broker/src/org/apache/qpid/server/management/ManagedObject.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/management/ManagedObject.java
diff --git a/java/broker/src/org/apache/qpid/server/management/ManagedObjectRegistry.java b/java/broker/src/main/java/org/apache/qpid/server/management/ManagedObjectRegistry.java
index 32298f05e3..32298f05e3 100644
--- a/java/broker/src/org/apache/qpid/server/management/ManagedObjectRegistry.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/management/ManagedObjectRegistry.java
diff --git a/java/broker/src/org/apache/qpid/server/management/ManagementConfiguration.java b/java/broker/src/main/java/org/apache/qpid/server/management/ManagementConfiguration.java
index 042f626e8b..042f626e8b 100644
--- a/java/broker/src/org/apache/qpid/server/management/ManagementConfiguration.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/management/ManagementConfiguration.java
diff --git a/java/broker/src/org/apache/qpid/server/management/NoopManagedObjectRegistry.java b/java/broker/src/main/java/org/apache/qpid/server/management/NoopManagedObjectRegistry.java
index 121c992c4f..121c992c4f 100644
--- a/java/broker/src/org/apache/qpid/server/management/NoopManagedObjectRegistry.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/management/NoopManagedObjectRegistry.java
diff --git a/java/broker/src/org/apache/qpid/server/protocol/AMQMethodEvent.java b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMethodEvent.java
index 3d12828900..3d12828900 100644
--- a/java/broker/src/org/apache/qpid/server/protocol/AMQMethodEvent.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMethodEvent.java
diff --git a/java/broker/src/org/apache/qpid/server/protocol/AMQMethodListener.java b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMethodListener.java
index d2062d3c17..d2062d3c17 100644
--- a/java/broker/src/org/apache/qpid/server/protocol/AMQMethodListener.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMethodListener.java
diff --git a/java/broker/src/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java
index 966af77d64..966af77d64 100644
--- a/java/broker/src/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java
diff --git a/java/broker/src/org/apache/qpid/server/protocol/AMQPFastProtocolHandler.java b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQPFastProtocolHandler.java
index 18980f440b..18980f440b 100644
--- a/java/broker/src/org/apache/qpid/server/protocol/AMQPFastProtocolHandler.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQPFastProtocolHandler.java
diff --git a/java/broker/src/org/apache/qpid/server/protocol/AMQPProtocolProvider.java b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQPProtocolProvider.java
index ff1316f704..ff1316f704 100644
--- a/java/broker/src/org/apache/qpid/server/protocol/AMQPProtocolProvider.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQPProtocolProvider.java
diff --git a/java/broker/src/org/apache/qpid/server/protocol/AMQProtocolSession.java b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSession.java
index acaf6b0d9b..acaf6b0d9b 100644
--- a/java/broker/src/org/apache/qpid/server/protocol/AMQProtocolSession.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSession.java
diff --git a/java/broker/src/org/apache/qpid/server/protocol/ExchangeInitialiser.java b/java/broker/src/main/java/org/apache/qpid/server/protocol/ExchangeInitialiser.java
index d3ec70456f..d3ec70456f 100644
--- a/java/broker/src/org/apache/qpid/server/protocol/ExchangeInitialiser.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/protocol/ExchangeInitialiser.java
diff --git a/java/broker/src/org/apache/qpid/server/protocol/HeartbeatConfig.java b/java/broker/src/main/java/org/apache/qpid/server/protocol/HeartbeatConfig.java
index 310deaaf55..310deaaf55 100644
--- a/java/broker/src/org/apache/qpid/server/protocol/HeartbeatConfig.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/protocol/HeartbeatConfig.java
diff --git a/java/broker/src/org/apache/qpid/server/protocol/ManagedConnection.java b/java/broker/src/main/java/org/apache/qpid/server/protocol/ManagedConnection.java
index 889acd0142..889acd0142 100644
--- a/java/broker/src/org/apache/qpid/server/protocol/ManagedConnection.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/protocol/ManagedConnection.java
diff --git a/java/broker/src/org/apache/qpid/server/queue/AMQMessage.java b/java/broker/src/main/java/org/apache/qpid/server/queue/AMQMessage.java
index 8b6db5b53f..8b6db5b53f 100644
--- a/java/broker/src/org/apache/qpid/server/queue/AMQMessage.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/queue/AMQMessage.java
diff --git a/java/broker/src/org/apache/qpid/server/queue/AMQQueue.java b/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueue.java
index f2f46d43dd..f2f46d43dd 100644
--- a/java/broker/src/org/apache/qpid/server/queue/AMQQueue.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueue.java
diff --git a/java/broker/src/org/apache/qpid/server/queue/AsyncDeliveryConfig.java b/java/broker/src/main/java/org/apache/qpid/server/queue/AsyncDeliveryConfig.java
index ba60c9e003..ba60c9e003 100644
--- a/java/broker/src/org/apache/qpid/server/queue/AsyncDeliveryConfig.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/queue/AsyncDeliveryConfig.java
diff --git a/java/broker/src/org/apache/qpid/server/queue/ConcurrentDeliveryManager.java b/java/broker/src/main/java/org/apache/qpid/server/queue/ConcurrentDeliveryManager.java
index dde76e5ba8..dde76e5ba8 100644
--- a/java/broker/src/org/apache/qpid/server/queue/ConcurrentDeliveryManager.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/queue/ConcurrentDeliveryManager.java
diff --git a/java/broker/src/org/apache/qpid/server/queue/DefaultQueueRegistry.java b/java/broker/src/main/java/org/apache/qpid/server/queue/DefaultQueueRegistry.java
index 3b73072e30..3b73072e30 100644
--- a/java/broker/src/org/apache/qpid/server/queue/DefaultQueueRegistry.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/queue/DefaultQueueRegistry.java
diff --git a/java/broker/src/org/apache/qpid/server/queue/DeliveryManager.java b/java/broker/src/main/java/org/apache/qpid/server/queue/DeliveryManager.java
index dadf86c1d8..dadf86c1d8 100644
--- a/java/broker/src/org/apache/qpid/server/queue/DeliveryManager.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/queue/DeliveryManager.java
diff --git a/java/broker/src/org/apache/qpid/server/queue/ExchangeBindings.java b/java/broker/src/main/java/org/apache/qpid/server/queue/ExchangeBindings.java
index 684e312fa3..684e312fa3 100644
--- a/java/broker/src/org/apache/qpid/server/queue/ExchangeBindings.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/queue/ExchangeBindings.java
diff --git a/java/broker/src/org/apache/qpid/server/queue/FailedDequeueException.java b/java/broker/src/main/java/org/apache/qpid/server/queue/FailedDequeueException.java
index b74c49e6e1..b74c49e6e1 100644
--- a/java/broker/src/org/apache/qpid/server/queue/FailedDequeueException.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/queue/FailedDequeueException.java
diff --git a/java/broker/src/org/apache/qpid/server/queue/ManagedQueue.java b/java/broker/src/main/java/org/apache/qpid/server/queue/ManagedQueue.java
index 3a818cf31a..3a818cf31a 100644
--- a/java/broker/src/org/apache/qpid/server/queue/ManagedQueue.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/queue/ManagedQueue.java
diff --git a/java/broker/src/org/apache/qpid/server/queue/MessageCleanupException.java b/java/broker/src/main/java/org/apache/qpid/server/queue/MessageCleanupException.java
index bfe0a0ecf1..bfe0a0ecf1 100644
--- a/java/broker/src/org/apache/qpid/server/queue/MessageCleanupException.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/queue/MessageCleanupException.java
diff --git a/java/broker/src/org/apache/qpid/server/queue/NoConsumersException.java b/java/broker/src/main/java/org/apache/qpid/server/queue/NoConsumersException.java
index 2d37b806f6..2d37b806f6 100644
--- a/java/broker/src/org/apache/qpid/server/queue/NoConsumersException.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/queue/NoConsumersException.java
diff --git a/java/broker/src/org/apache/qpid/server/queue/QueueRegistry.java b/java/broker/src/main/java/org/apache/qpid/server/queue/QueueRegistry.java
index c83f17b98c..c83f17b98c 100644
--- a/java/broker/src/org/apache/qpid/server/queue/QueueRegistry.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/queue/QueueRegistry.java
diff --git a/java/broker/src/org/apache/qpid/server/queue/Subscription.java b/java/broker/src/main/java/org/apache/qpid/server/queue/Subscription.java
index dfc16a7c71..dfc16a7c71 100644
--- a/java/broker/src/org/apache/qpid/server/queue/Subscription.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/queue/Subscription.java
diff --git a/java/broker/src/org/apache/qpid/server/queue/SubscriptionFactory.java b/java/broker/src/main/java/org/apache/qpid/server/queue/SubscriptionFactory.java
index 0fd44e4fbc..0fd44e4fbc 100644
--- a/java/broker/src/org/apache/qpid/server/queue/SubscriptionFactory.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/queue/SubscriptionFactory.java
diff --git a/java/broker/src/org/apache/qpid/server/queue/SubscriptionImpl.java b/java/broker/src/main/java/org/apache/qpid/server/queue/SubscriptionImpl.java
index 5cad28b80d..5cad28b80d 100644
--- a/java/broker/src/org/apache/qpid/server/queue/SubscriptionImpl.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/queue/SubscriptionImpl.java
diff --git a/java/broker/src/org/apache/qpid/server/queue/SubscriptionManager.java b/java/broker/src/main/java/org/apache/qpid/server/queue/SubscriptionManager.java
index 353b461c8d..353b461c8d 100644
--- a/java/broker/src/org/apache/qpid/server/queue/SubscriptionManager.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/queue/SubscriptionManager.java
diff --git a/java/broker/src/org/apache/qpid/server/queue/SubscriptionSet.java b/java/broker/src/main/java/org/apache/qpid/server/queue/SubscriptionSet.java
index 7cc3f5f719..7cc3f5f719 100644
--- a/java/broker/src/org/apache/qpid/server/queue/SubscriptionSet.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/queue/SubscriptionSet.java
diff --git a/java/broker/src/org/apache/qpid/server/queue/SynchronizedDeliveryManager.java b/java/broker/src/main/java/org/apache/qpid/server/queue/SynchronizedDeliveryManager.java
index d2e53717af..d2e53717af 100644
--- a/java/broker/src/org/apache/qpid/server/queue/SynchronizedDeliveryManager.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/queue/SynchronizedDeliveryManager.java
diff --git a/java/broker/src/org/apache/qpid/server/queue/WeightedSubscriptionManager.java b/java/broker/src/main/java/org/apache/qpid/server/queue/WeightedSubscriptionManager.java
index 6c71571807..6c71571807 100644
--- a/java/broker/src/org/apache/qpid/server/queue/WeightedSubscriptionManager.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/queue/WeightedSubscriptionManager.java
diff --git a/java/broker/src/org/apache/qpid/server/registry/ApplicationRegistry.java b/java/broker/src/main/java/org/apache/qpid/server/registry/ApplicationRegistry.java
index 48331843e5..48331843e5 100644
--- a/java/broker/src/org/apache/qpid/server/registry/ApplicationRegistry.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/registry/ApplicationRegistry.java
diff --git a/java/broker/src/org/apache/qpid/server/registry/ConfigurationFileApplicationRegistry.java b/java/broker/src/main/java/org/apache/qpid/server/registry/ConfigurationFileApplicationRegistry.java
index 1eb490d6fb..1eb490d6fb 100644
--- a/java/broker/src/org/apache/qpid/server/registry/ConfigurationFileApplicationRegistry.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/registry/ConfigurationFileApplicationRegistry.java
diff --git a/java/broker/src/org/apache/qpid/server/registry/IApplicationRegistry.java b/java/broker/src/main/java/org/apache/qpid/server/registry/IApplicationRegistry.java
index cd664f9a4b..cd664f9a4b 100644
--- a/java/broker/src/org/apache/qpid/server/registry/IApplicationRegistry.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/registry/IApplicationRegistry.java
diff --git a/java/broker/src/org/apache/qpid/server/security/auth/AuthenticationManager.java b/java/broker/src/main/java/org/apache/qpid/server/security/auth/AuthenticationManager.java
index 9f4addd7ee..9f4addd7ee 100644
--- a/java/broker/src/org/apache/qpid/server/security/auth/AuthenticationManager.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/security/auth/AuthenticationManager.java
diff --git a/java/broker/src/org/apache/qpid/server/security/auth/AuthenticationProviderInitialiser.java b/java/broker/src/main/java/org/apache/qpid/server/security/auth/AuthenticationProviderInitialiser.java
index b26ba9b3dd..b26ba9b3dd 100644
--- a/java/broker/src/org/apache/qpid/server/security/auth/AuthenticationProviderInitialiser.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/security/auth/AuthenticationProviderInitialiser.java
diff --git a/java/broker/src/org/apache/qpid/server/security/auth/AuthenticationResult.java b/java/broker/src/main/java/org/apache/qpid/server/security/auth/AuthenticationResult.java
index 0e3aea4de0..0e3aea4de0 100644
--- a/java/broker/src/org/apache/qpid/server/security/auth/AuthenticationResult.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/security/auth/AuthenticationResult.java
diff --git a/java/broker/src/org/apache/qpid/server/security/auth/CRAMMD5Initialiser.java b/java/broker/src/main/java/org/apache/qpid/server/security/auth/CRAMMD5Initialiser.java
index 4e428bbf23..4e428bbf23 100644
--- a/java/broker/src/org/apache/qpid/server/security/auth/CRAMMD5Initialiser.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/security/auth/CRAMMD5Initialiser.java
diff --git a/java/broker/src/org/apache/qpid/server/security/auth/JCAProvider.java b/java/broker/src/main/java/org/apache/qpid/server/security/auth/JCAProvider.java
index f69e5dc708..f69e5dc708 100644
--- a/java/broker/src/org/apache/qpid/server/security/auth/JCAProvider.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/security/auth/JCAProvider.java
diff --git a/java/broker/src/org/apache/qpid/server/security/auth/NullAuthenticationManager.java b/java/broker/src/main/java/org/apache/qpid/server/security/auth/NullAuthenticationManager.java
index 14cce86715..14cce86715 100644
--- a/java/broker/src/org/apache/qpid/server/security/auth/NullAuthenticationManager.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/security/auth/NullAuthenticationManager.java
diff --git a/java/broker/src/org/apache/qpid/server/security/auth/PasswordFilePrincipalDatabase.java b/java/broker/src/main/java/org/apache/qpid/server/security/auth/PasswordFilePrincipalDatabase.java
index fb2ac612b6..fb2ac612b6 100644
--- a/java/broker/src/org/apache/qpid/server/security/auth/PasswordFilePrincipalDatabase.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/security/auth/PasswordFilePrincipalDatabase.java
diff --git a/java/broker/src/org/apache/qpid/server/security/auth/PrincipalDatabase.java b/java/broker/src/main/java/org/apache/qpid/server/security/auth/PrincipalDatabase.java
index d7fe21735f..d7fe21735f 100644
--- a/java/broker/src/org/apache/qpid/server/security/auth/PrincipalDatabase.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/security/auth/PrincipalDatabase.java
diff --git a/java/broker/src/org/apache/qpid/server/security/auth/SASLAuthenticationManager.java b/java/broker/src/main/java/org/apache/qpid/server/security/auth/SASLAuthenticationManager.java
index 21eb80c69d..21eb80c69d 100644
--- a/java/broker/src/org/apache/qpid/server/security/auth/SASLAuthenticationManager.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/security/auth/SASLAuthenticationManager.java
diff --git a/java/broker/src/org/apache/qpid/server/security/auth/UsernamePasswordInitialiser.java b/java/broker/src/main/java/org/apache/qpid/server/security/auth/UsernamePasswordInitialiser.java
index fccb881eaa..fccb881eaa 100644
--- a/java/broker/src/org/apache/qpid/server/security/auth/UsernamePasswordInitialiser.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/security/auth/UsernamePasswordInitialiser.java
diff --git a/java/broker/src/org/apache/qpid/server/security/auth/UsernamePrincipal.java b/java/broker/src/main/java/org/apache/qpid/server/security/auth/UsernamePrincipal.java
index e068ba6fe4..e068ba6fe4 100644
--- a/java/broker/src/org/apache/qpid/server/security/auth/UsernamePrincipal.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/security/auth/UsernamePrincipal.java
diff --git a/java/broker/src/org/apache/qpid/server/security/auth/amqplain/AmqPlainInitialiser.java b/java/broker/src/main/java/org/apache/qpid/server/security/auth/amqplain/AmqPlainInitialiser.java
index 1d5932ca31..1d5932ca31 100644
--- a/java/broker/src/org/apache/qpid/server/security/auth/amqplain/AmqPlainInitialiser.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/security/auth/amqplain/AmqPlainInitialiser.java
diff --git a/java/broker/src/org/apache/qpid/server/security/auth/amqplain/AmqPlainSaslServer.java b/java/broker/src/main/java/org/apache/qpid/server/security/auth/amqplain/AmqPlainSaslServer.java
index 3ad74ce180..3ad74ce180 100644
--- a/java/broker/src/org/apache/qpid/server/security/auth/amqplain/AmqPlainSaslServer.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/security/auth/amqplain/AmqPlainSaslServer.java
diff --git a/java/broker/src/org/apache/qpid/server/security/auth/amqplain/AmqPlainSaslServerFactory.java b/java/broker/src/main/java/org/apache/qpid/server/security/auth/amqplain/AmqPlainSaslServerFactory.java
index befd724b33..befd724b33 100644
--- a/java/broker/src/org/apache/qpid/server/security/auth/amqplain/AmqPlainSaslServerFactory.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/security/auth/amqplain/AmqPlainSaslServerFactory.java
diff --git a/java/broker/src/org/apache/qpid/server/security/auth/plain/PlainInitialiser.java b/java/broker/src/main/java/org/apache/qpid/server/security/auth/plain/PlainInitialiser.java
index b92e0b9209..b92e0b9209 100644
--- a/java/broker/src/org/apache/qpid/server/security/auth/plain/PlainInitialiser.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/security/auth/plain/PlainInitialiser.java
diff --git a/java/broker/src/org/apache/qpid/server/security/auth/plain/PlainSaslServer.java b/java/broker/src/main/java/org/apache/qpid/server/security/auth/plain/PlainSaslServer.java
index fdf655c2d9..fdf655c2d9 100644
--- a/java/broker/src/org/apache/qpid/server/security/auth/plain/PlainSaslServer.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/security/auth/plain/PlainSaslServer.java
diff --git a/java/broker/src/org/apache/qpid/server/security/auth/plain/PlainSaslServerFactory.java b/java/broker/src/main/java/org/apache/qpid/server/security/auth/plain/PlainSaslServerFactory.java
index 444f7d9b58..444f7d9b58 100644
--- a/java/broker/src/org/apache/qpid/server/security/auth/plain/PlainSaslServerFactory.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/security/auth/plain/PlainSaslServerFactory.java
diff --git a/java/broker/src/org/apache/qpid/server/state/AMQState.java b/java/broker/src/main/java/org/apache/qpid/server/state/AMQState.java
index f427cc7206..f427cc7206 100644
--- a/java/broker/src/org/apache/qpid/server/state/AMQState.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/state/AMQState.java
diff --git a/java/broker/src/org/apache/qpid/server/state/AMQStateManager.java b/java/broker/src/main/java/org/apache/qpid/server/state/AMQStateManager.java
index 5e88ff7f2d..5e88ff7f2d 100644
--- a/java/broker/src/org/apache/qpid/server/state/AMQStateManager.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/state/AMQStateManager.java
diff --git a/java/broker/src/org/apache/qpid/server/state/IllegalStateTransitionException.java b/java/broker/src/main/java/org/apache/qpid/server/state/IllegalStateTransitionException.java
index 2d7cc27a85..2d7cc27a85 100644
--- a/java/broker/src/org/apache/qpid/server/state/IllegalStateTransitionException.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/state/IllegalStateTransitionException.java
diff --git a/java/broker/src/org/apache/qpid/server/state/StateAwareMethodListener.java b/java/broker/src/main/java/org/apache/qpid/server/state/StateAwareMethodListener.java
index 7d58f242e5..7d58f242e5 100644
--- a/java/broker/src/org/apache/qpid/server/state/StateAwareMethodListener.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/state/StateAwareMethodListener.java
diff --git a/java/broker/src/org/apache/qpid/server/state/StateListener.java b/java/broker/src/main/java/org/apache/qpid/server/state/StateListener.java
index 00fc09867b..00fc09867b 100644
--- a/java/broker/src/org/apache/qpid/server/state/StateListener.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/state/StateListener.java
diff --git a/java/broker/src/org/apache/qpid/server/store/MemoryMessageStore.java b/java/broker/src/main/java/org/apache/qpid/server/store/MemoryMessageStore.java
index 328aed81d9..328aed81d9 100644
--- a/java/broker/src/org/apache/qpid/server/store/MemoryMessageStore.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/store/MemoryMessageStore.java
diff --git a/java/broker/src/org/apache/qpid/server/store/MessageStore.java b/java/broker/src/main/java/org/apache/qpid/server/store/MessageStore.java
index 8ee1d09862..8ee1d09862 100644
--- a/java/broker/src/org/apache/qpid/server/store/MessageStore.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/store/MessageStore.java
diff --git a/java/broker/src/org/apache/qpid/server/transport/ConnectorConfiguration.java b/java/broker/src/main/java/org/apache/qpid/server/transport/ConnectorConfiguration.java
index ca008a0bd5..ca008a0bd5 100644
--- a/java/broker/src/org/apache/qpid/server/transport/ConnectorConfiguration.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/transport/ConnectorConfiguration.java
diff --git a/java/broker/src/org/apache/qpid/server/transport/ThreadPoolFilter.java b/java/broker/src/main/java/org/apache/qpid/server/transport/ThreadPoolFilter.java
index 2ee75c001f..2ee75c001f 100644
--- a/java/broker/src/org/apache/qpid/server/transport/ThreadPoolFilter.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/transport/ThreadPoolFilter.java
diff --git a/java/broker/src/org/apache/qpid/server/txn/TxnBuffer.java b/java/broker/src/main/java/org/apache/qpid/server/txn/TxnBuffer.java
index 402065d5e1..402065d5e1 100644
--- a/java/broker/src/org/apache/qpid/server/txn/TxnBuffer.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/txn/TxnBuffer.java
diff --git a/java/broker/src/org/apache/qpid/server/txn/TxnOp.java b/java/broker/src/main/java/org/apache/qpid/server/txn/TxnOp.java
index e863bab73e..e863bab73e 100644
--- a/java/broker/src/org/apache/qpid/server/txn/TxnOp.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/txn/TxnOp.java
diff --git a/java/broker/src/org/apache/qpid/server/util/CircularBuffer.java b/java/broker/src/main/java/org/apache/qpid/server/util/CircularBuffer.java
index 4767844abe..4767844abe 100644
--- a/java/broker/src/org/apache/qpid/server/util/CircularBuffer.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/util/CircularBuffer.java
diff --git a/java/broker/src/org/apache/qpid/server/util/ConcurrentLinkedQueueNoSize.java b/java/broker/src/main/java/org/apache/qpid/server/util/ConcurrentLinkedQueueNoSize.java
index cf5e71a6e2..cf5e71a6e2 100644
--- a/java/broker/src/org/apache/qpid/server/util/ConcurrentLinkedQueueNoSize.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/util/ConcurrentLinkedQueueNoSize.java
diff --git a/java/broker/src/org/apache/qpid/server/util/LoggingProxy.java b/java/broker/src/main/java/org/apache/qpid/server/util/LoggingProxy.java
index eda97e0ed2..eda97e0ed2 100644
--- a/java/broker/src/org/apache/qpid/server/util/LoggingProxy.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/util/LoggingProxy.java
diff --git a/java/broker/src/org/apache/qpid/server/util/NullApplicationRegistry.java b/java/broker/src/main/java/org/apache/qpid/server/util/NullApplicationRegistry.java
index 2e77f33363..2e77f33363 100644
--- a/java/broker/src/org/apache/qpid/server/util/NullApplicationRegistry.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/util/NullApplicationRegistry.java
diff --git a/java/broker/src/test/java/org/apache/qpid/server/UnitTests.java b/java/broker/src/test/java/org/apache/qpid/server/UnitTests.java
new file mode 100644
index 0000000000..fcae268288
--- /dev/null
+++ b/java/broker/src/test/java/org/apache/qpid/server/UnitTests.java
@@ -0,0 +1,39 @@
+/*
+ *
+ * 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.server;
+
+import junit.framework.JUnit4TestAdapter;
+import org.junit.runner.RunWith;
+import org.junit.runners.Suite;
+
+@RunWith(Suite.class)
+@Suite.SuiteClasses({
+ org.apache.qpid.server.configuration.UnitTests.class,
+ org.apache.qpid.server.exchange.UnitTests.class,
+ org.apache.qpid.server.util.UnitTests.class
+ })
+public class UnitTests
+{
+ public static junit.framework.Test suite()
+ {
+ return new JUnit4TestAdapter(UnitTests.class);
+ }
+}
diff --git a/java/broker/src/test/java/org/apache/qpid/server/configuration/TestPropertyUtils.java b/java/broker/src/test/java/org/apache/qpid/server/configuration/TestPropertyUtils.java
new file mode 100644
index 0000000000..8bab0fbc12
--- /dev/null
+++ b/java/broker/src/test/java/org/apache/qpid/server/configuration/TestPropertyUtils.java
@@ -0,0 +1,53 @@
+/*
+ *
+ * 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.server.configuration;
+
+import junit.framework.JUnit4TestAdapter;
+import org.apache.qpid.configuration.PropertyException;
+import org.apache.qpid.configuration.PropertyUtils;
+import static org.junit.Assert.assertEquals;
+import org.junit.Test;
+
+// TODO: This belongs in the "common" module.
+public class TestPropertyUtils
+{
+ @Test
+ public void testSimpleExpansion() throws PropertyException
+ {
+ System.setProperty("banana", "fruity");
+ String expandedProperty = PropertyUtils.replaceProperties("${banana}");
+ assertEquals(expandedProperty, "fruity");
+ }
+
+ @Test
+ public void testDualExpansion() throws PropertyException
+ {
+ System.setProperty("banana", "fruity");
+ System.setProperty("concrete", "horrible");
+ String expandedProperty = PropertyUtils.replaceProperties("${banana}xyz${concrete}");
+ assertEquals(expandedProperty, "fruityxyzhorrible");
+ }
+
+ public static junit.framework.Test suite()
+ {
+ return new JUnit4TestAdapter(TestPropertyUtils.class);
+ }
+}
diff --git a/java/broker/src/test/java/org/apache/qpid/server/configuration/UnitTests.java b/java/broker/src/test/java/org/apache/qpid/server/configuration/UnitTests.java
new file mode 100644
index 0000000000..6e39e9efd1
--- /dev/null
+++ b/java/broker/src/test/java/org/apache/qpid/server/configuration/UnitTests.java
@@ -0,0 +1,35 @@
+/*
+ *
+ * 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.server.configuration;
+
+import junit.framework.JUnit4TestAdapter;
+import org.junit.runner.RunWith;
+import org.junit.runners.Suite;
+
+@RunWith(Suite.class)
+@Suite.SuiteClasses({TestPropertyUtils.class})
+public class UnitTests
+{
+ public static junit.framework.Test suite()
+ {
+ return new JUnit4TestAdapter(UnitTests.class);
+ }
+}
diff --git a/java/broker/src/test/java/org/apache/qpid/server/exchange/HeadersBindingTest.java b/java/broker/src/test/java/org/apache/qpid/server/exchange/HeadersBindingTest.java
new file mode 100644
index 0000000000..0e7ab10c59
--- /dev/null
+++ b/java/broker/src/test/java/org/apache/qpid/server/exchange/HeadersBindingTest.java
@@ -0,0 +1,203 @@
+/*
+ *
+ * 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.server.exchange;
+
+import org.junit.Test;
+import static org.junit.Assert.assertTrue;
+import static org.junit.Assert.assertFalse;
+
+
+import java.util.Map;
+import java.util.HashMap;
+
+import junit.framework.JUnit4TestAdapter;
+
+/**
+ */
+public class HeadersBindingTest
+{
+ private Map<String, String> bindHeaders = new HashMap<String, String>();
+ private Map<String, String> matchHeaders = new HashMap<String, String>();
+
+ @Test public void default_1()
+ {
+ bindHeaders.put("A", "Value of A");
+
+ matchHeaders.put("A", "Value of A");
+
+ assertTrue(new HeadersBinding(bindHeaders).matches(matchHeaders));
+ }
+
+ @Test public void default_2()
+ {
+ bindHeaders.put("A", "Value of A");
+
+ matchHeaders.put("A", "Value of A");
+ matchHeaders.put("B", "Value of B");
+
+ assertTrue(new HeadersBinding(bindHeaders).matches(matchHeaders));
+ }
+
+ @Test public void default_3()
+ {
+ bindHeaders.put("A", "Value of A");
+
+ matchHeaders.put("A", "Altered value of A");
+
+ assertFalse(new HeadersBinding(bindHeaders).matches(matchHeaders));
+ }
+
+ @Test public void all_1()
+ {
+ bindHeaders.put("X-match", "all");
+ bindHeaders.put("A", "Value of A");
+
+ matchHeaders.put("A", "Value of A");
+
+ assertTrue(new HeadersBinding(bindHeaders).matches(matchHeaders));
+ }
+
+ @Test public void all_2()
+ {
+ bindHeaders.put("X-match", "all");
+ bindHeaders.put("A", "Value of A");
+ bindHeaders.put("B", "Value of B");
+
+ matchHeaders.put("A", "Value of A");
+
+ assertFalse(new HeadersBinding(bindHeaders).matches(matchHeaders));
+ }
+
+ @Test public void all_3()
+ {
+ bindHeaders.put("X-match", "all");
+ bindHeaders.put("A", "Value of A");
+ bindHeaders.put("B", "Value of B");
+
+ matchHeaders.put("A", "Value of A");
+ matchHeaders.put("B", "Value of B");
+
+ assertTrue(new HeadersBinding(bindHeaders).matches(matchHeaders));
+ }
+
+ @Test public void all_4()
+ {
+ bindHeaders.put("X-match", "all");
+ bindHeaders.put("A", "Value of A");
+ bindHeaders.put("B", "Value of B");
+
+ matchHeaders.put("A", "Value of A");
+ matchHeaders.put("B", "Value of B");
+ matchHeaders.put("C", "Value of C");
+
+ assertTrue(new HeadersBinding(bindHeaders).matches(matchHeaders));
+ }
+
+ @Test public void all_5()
+ {
+ bindHeaders.put("X-match", "all");
+ bindHeaders.put("A", "Value of A");
+ bindHeaders.put("B", "Value of B");
+
+ matchHeaders.put("A", "Value of A");
+ matchHeaders.put("B", "Altered value of B");
+ matchHeaders.put("C", "Value of C");
+
+ assertFalse(new HeadersBinding(bindHeaders).matches(matchHeaders));
+ }
+
+ @Test public void any_1()
+ {
+ bindHeaders.put("X-match", "any");
+ bindHeaders.put("A", "Value of A");
+
+ matchHeaders.put("A", "Value of A");
+
+ assertTrue(new HeadersBinding(bindHeaders).matches(matchHeaders));
+ }
+
+ @Test public void any_2()
+ {
+ bindHeaders.put("X-match", "any");
+ bindHeaders.put("A", "Value of A");
+ bindHeaders.put("B", "Value of B");
+
+ matchHeaders.put("A", "Value of A");
+
+ assertTrue(new HeadersBinding(bindHeaders).matches(matchHeaders));
+ }
+
+ @Test public void any_3()
+ {
+ bindHeaders.put("X-match", "any");
+ bindHeaders.put("A", "Value of A");
+ bindHeaders.put("B", "Value of B");
+
+ matchHeaders.put("A", "Value of A");
+ matchHeaders.put("B", "Value of B");
+
+ assertTrue(new HeadersBinding(bindHeaders).matches(matchHeaders));
+ }
+
+ @Test public void any_4()
+ {
+ bindHeaders.put("X-match", "any");
+ bindHeaders.put("A", "Value of A");
+ bindHeaders.put("B", "Value of B");
+
+ matchHeaders.put("A", "Value of A");
+ matchHeaders.put("B", "Value of B");
+ matchHeaders.put("C", "Value of C");
+
+ assertTrue(new HeadersBinding(bindHeaders).matches(matchHeaders));
+ }
+
+ @Test public void any_5()
+ {
+ bindHeaders.put("X-match", "any");
+ bindHeaders.put("A", "Value of A");
+ bindHeaders.put("B", "Value of B");
+
+ matchHeaders.put("A", "Value of A");
+ matchHeaders.put("B", "Altered value of B");
+ matchHeaders.put("C", "Value of C");
+
+ assertTrue(new HeadersBinding(bindHeaders).matches(matchHeaders));
+ }
+
+ @Test public void any_6()
+ {
+ bindHeaders.put("X-match", "any");
+ bindHeaders.put("A", "Value of A");
+ bindHeaders.put("B", "Value of B");
+
+ matchHeaders.put("A", "Altered value of A");
+ matchHeaders.put("B", "Altered value of B");
+ matchHeaders.put("C", "Value of C");
+
+ assertFalse(new HeadersBinding(bindHeaders).matches(matchHeaders));
+ }
+ public static junit.framework.Test suite()
+ {
+ return new JUnit4TestAdapter(HeadersBindingTest.class);
+ }
+
+}
diff --git a/java/broker/src/test/java/org/apache/qpid/server/exchange/UnitTests.java b/java/broker/src/test/java/org/apache/qpid/server/exchange/UnitTests.java
new file mode 100644
index 0000000000..ce3812be7f
--- /dev/null
+++ b/java/broker/src/test/java/org/apache/qpid/server/exchange/UnitTests.java
@@ -0,0 +1,35 @@
+/*
+ *
+ * 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.server.exchange;
+
+import junit.framework.JUnit4TestAdapter;
+import org.junit.runner.RunWith;
+import org.junit.runners.Suite;
+
+@RunWith(Suite.class)
+@Suite.SuiteClasses({HeadersBindingTest.class})
+public class UnitTests
+{
+ public static junit.framework.Test suite()
+ {
+ return new JUnit4TestAdapter(UnitTests.class);
+ }
+}
diff --git a/java/broker/src/test/java/org/apache/qpid/server/util/LoggingProxyTest.java b/java/broker/src/test/java/org/apache/qpid/server/util/LoggingProxyTest.java
new file mode 100644
index 0000000000..878500689a
--- /dev/null
+++ b/java/broker/src/test/java/org/apache/qpid/server/util/LoggingProxyTest.java
@@ -0,0 +1,92 @@
+/*
+ *
+ * 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.server.util;
+
+import junit.framework.JUnit4TestAdapter;
+import org.junit.Assert;
+import static org.junit.Assert.assertEquals;
+import org.junit.Test;
+
+import java.util.Arrays;
+import java.util.Collection;
+import java.util.List;
+
+public class LoggingProxyTest
+{
+ static interface IFoo {
+ void foo();
+ void foo(int i, Collection c);
+ String bar();
+ String bar(String s, List l);
+ }
+
+ static class Foo implements IFoo {
+ public void foo()
+ {
+ }
+
+ public void foo(int i, Collection c)
+ {
+ }
+
+ public String bar()
+ {
+ return null;
+ }
+
+ public String bar(String s, List l)
+ {
+ return "ha";
+ }
+ }
+
+ @Test
+ public void simple() {
+ LoggingProxy proxy = new LoggingProxy(new Foo(), 20);
+ IFoo foo = (IFoo)proxy.getProxy(IFoo.class);
+ foo.foo();
+ assertEquals(2, proxy.getBufferSize());
+ Assert.assertTrue(proxy.getBuffer().get(0).toString().matches(".*: foo\\(\\) entered$"));
+ Assert.assertTrue(proxy.getBuffer().get(1).toString().matches(".*: foo\\(\\) returned$"));
+
+ foo.foo(3, Arrays.asList(0, 1, 2));
+ assertEquals(4, proxy.getBufferSize());
+ Assert.assertTrue(proxy.getBuffer().get(2).toString().matches(".*: foo\\(\\[3, \\[0, 1, 2\\]\\]\\) entered$"));
+ Assert.assertTrue(proxy.getBuffer().get(3).toString().matches(".*: foo\\(\\) returned$"));
+
+ foo.bar();
+ assertEquals(6, proxy.getBufferSize());
+ Assert.assertTrue(proxy.getBuffer().get(4).toString().matches(".*: bar\\(\\) entered$"));
+ Assert.assertTrue(proxy.getBuffer().get(5).toString().matches(".*: bar\\(\\) returned null$"));
+
+ foo.bar("hello", Arrays.asList(1, 2, 3));
+ assertEquals(8, proxy.getBufferSize());
+ Assert.assertTrue(proxy.getBuffer().get(6).toString().matches(".*: bar\\(\\[hello, \\[1, 2, 3\\]\\]\\) entered$"));
+ Assert.assertTrue(proxy.getBuffer().get(7).toString().matches(".*: bar\\(\\) returned ha$"));
+
+ proxy.dump();
+ }
+
+ public static junit.framework.Test suite()
+ {
+ return new JUnit4TestAdapter(LoggingProxyTest.class);
+ }
+}
diff --git a/java/broker/src/test/java/org/apache/qpid/server/util/UnitTests.java b/java/broker/src/test/java/org/apache/qpid/server/util/UnitTests.java
new file mode 100644
index 0000000000..5314fa0df8
--- /dev/null
+++ b/java/broker/src/test/java/org/apache/qpid/server/util/UnitTests.java
@@ -0,0 +1,35 @@
+/*
+ *
+ * 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.server.util;
+
+import junit.framework.JUnit4TestAdapter;
+import org.junit.runner.RunWith;
+import org.junit.runners.Suite;
+
+@RunWith(Suite.class)
+@Suite.SuiteClasses({LoggingProxyTest.class})
+public class UnitTests
+{
+ public static junit.framework.Test suite()
+ {
+ return new JUnit4TestAdapter(UnitTests.class);
+ }
+}