diff options
| author | Stephen Vinoski <vinoski@apache.org> | 2006-11-18 02:12:32 +0000 |
|---|---|---|
| committer | Stephen Vinoski <vinoski@apache.org> | 2006-11-18 02:12:32 +0000 |
| commit | 1db5a8a2329ec064d1683294ee1a3d8d233de42d (patch) | |
| tree | f5ac42c441d4829262d560696cb2cad98fc0434f /java/broker/src | |
| parent | d386f860a3404ec9735dab2730f8ed683446838c (diff) | |
| download | qpid-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.java | 39 | ||||
| -rw-r--r-- | java/broker/src/test/java/org/apache/qpid/server/configuration/TestPropertyUtils.java | 53 | ||||
| -rw-r--r-- | java/broker/src/test/java/org/apache/qpid/server/configuration/UnitTests.java | 35 | ||||
| -rw-r--r-- | java/broker/src/test/java/org/apache/qpid/server/exchange/HeadersBindingTest.java | 203 | ||||
| -rw-r--r-- | java/broker/src/test/java/org/apache/qpid/server/exchange/UnitTests.java | 35 | ||||
| -rw-r--r-- | java/broker/src/test/java/org/apache/qpid/server/util/LoggingProxyTest.java | 92 | ||||
| -rw-r--r-- | java/broker/src/test/java/org/apache/qpid/server/util/UnitTests.java | 35 |
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); + } +} |
