svn commit: r783612 [1/3] - in /activemq/sandbox/activemq-flow: activemq-all/ activemq-all/src/test/java/org/apache/activemq/ activemq-all/src/test/java/org/apache/activemq/blob/ activemq-all/src/test/java/org/apache/activemq/broker/ activemq-all/src/t...

[ch...@apache.org]

Author: chirino
Date: Thu Jun 11 03:08:06 2009
New Revision: 783612

URL: http://svn.apache.org/viewvc?rev=783612&view=rev
Log:
ported over the test cases from the 5.x branch. 
 They are mostly not working, all the broker 5.x config APIs are just stubed out so that at least it all compiles.
 None of the multi broker tests were ported.  Once we implement networks we can bring those in, but I'm guessing that is still a long ways away.


Added:
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ActiveMQConnectionFactoryTest.java
      - copied, changed from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ActiveMQConnectionFactoryTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ActiveMQInputStreamTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ActiveMQInputStreamTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ActiveMQMessageAuditTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ActiveMQMessageAuditTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ActiveMQXAConnectionFactoryTest.java
      - copied, changed from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ActiveMQXAConnectionFactoryTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/AutoFailTestSupport.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/AutoFailTestSupport.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ClientTestSupport.java
      - copied, changed from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ClientTestSupport.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/CombinationTestSupport.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/CombinationTestSupport.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ConnectionCleanupTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ConnectionCleanupTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ConsumerReceiveWithTimeoutTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ConsumerReceiveWithTimeoutTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/CreateConsumerButDontStartConnectionWarningTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/CreateConsumerButDontStartConnectionWarningTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/EmbeddedBrokerAndConnectionTestSupport.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/EmbeddedBrokerAndConnectionTestSupport.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/EmbeddedBrokerTestSupport.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/EmbeddedBrokerTestSupport.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ExclusiveConsumerTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ExclusiveConsumerTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JMSConsumerTest.java
      - copied, changed from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JMSConsumerTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JMSDurableTopicRedeliverTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JMSDurableTopicRedeliverTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JMSExclusiveConsumerTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JMSExclusiveConsumerTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JMSIndividualAckTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JMSIndividualAckTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JMSMessageTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JMSMessageTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JMSQueueRedeliverTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JMSQueueRedeliverTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JMSUsecaseTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JMSUsecaseTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsAutoAckListenerTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsAutoAckListenerTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsAutoAckTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsAutoAckTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsBenchmark.java
      - copied, changed from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsBenchmark.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsClientAckListenerTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsClientAckListenerTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsClientAckTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsClientAckTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsConnectionStartStopTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsConnectionStartStopTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsConsumerResetActiveListenerTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsConsumerResetActiveListenerTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsCreateConsumerInOnMessageTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsCreateConsumerInOnMessageTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsDurableQueueWildcardSendReceiveTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsDurableQueueWildcardSendReceiveTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsDurableTopicSelectorTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsDurableTopicSelectorTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsDurableTopicSendReceiveTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsDurableTopicSendReceiveTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsDurableTopicTransactionTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsDurableTopicTransactionTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsDurableTopicWildcardSendReceiveTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsDurableTopicWildcardSendReceiveTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsMultipleClientsTestSupport.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsQueueBrowserTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsQueueBrowserTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsQueueCompositeSendReceiveTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsQueueCompositeSendReceiveTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsQueueRequestReplyTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsQueueRequestReplyTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsQueueSelectorTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsQueueSelectorTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsQueueSendReceiveTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsQueueSendReceiveTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsQueueSendReceiveTwoConnectionsStartBeforeBrokerTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsQueueSendReceiveTwoConnectionsStartBeforeBrokerTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsQueueSendReceiveTwoConnectionsTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsQueueSendReceiveTwoConnectionsTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsQueueSendReceiveUsingTwoSessionsTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsQueueSendReceiveUsingTwoSessionsTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsQueueTopicCompositeSendReceiveTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsQueueTopicCompositeSendReceiveTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsQueueTransactionTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsQueueTransactionTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsQueueWildcardSendReceiveTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsQueueWildcardSendReceiveTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsRedeliveredTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsRedeliveredTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsRollbackRedeliveryTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsRollbackRedeliveryTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsSendReceiveTestSupport.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsSendReceiveTestSupport.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsSendReceiveWithMessageExpirationTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsSendReceiveWithMessageExpirationTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsSessionRecoverTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsSessionRecoverTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsTempDestinationTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTempDestinationTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsTestSupport.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTestSupport.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsTopicCompositeSendReceiveTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicCompositeSendReceiveTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsTopicRedeliverTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicRedeliverTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsTopicRequestReplyTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicRequestReplyTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsTopicSelectorTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSelectorTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsTopicSendReceiveSubscriberTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSendReceiveSubscriberTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsTopicSendReceiveTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSendReceiveTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsTopicSendReceiveWithTwoConnectionsTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSendReceiveWithTwoConnectionsTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsTopicSendReceiveWithTwoConnectionsWithJMXTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSendReceiveWithTwoConnectionsWithJMXTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsTopicSendSameMessageTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicSendSameMessageTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsTopicTransactionTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicTransactionTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsTopicWildcardSendReceiveTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTopicWildcardSendReceiveTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsTransactionTestSupport.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTransactionTestSupport.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/LargeMessageTestSupport.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/LargeMessageTestSupport.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/LargeStreamletTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/LargeStreamletTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/LoadTestBurnIn.java
      - copied, changed from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/LoadTestBurnIn.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/MessageGroupTest.java
      - copied, changed from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/region/group/MessageGroupTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/MessageListenerRedeliveryTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/MessageListenerRedeliveryTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/MessageTransformationTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/MessageTransformationTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ProducerFlowControlSendFailTest.java
      - copied, changed from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ProducerFlowControlSendFailTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ProducerFlowControlTest.java
      - copied, changed from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ProducerFlowControlTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/QueueConsumerPriorityTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/QueueConsumerPriorityTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ReconnectWithSameClientIDTest.java
      - copied, changed from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ReconnectWithSameClientIDTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/RedeliveryPolicyTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/RedeliveryPolicyTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/RemoveDestinationTest.java
      - copied, changed from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/RemoveDestinationTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/SpringTestSupport.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/SpringTestSupport.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/TestSupport.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/TestSupport.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/TimeStampTest.java
      - copied, changed from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/TimeStampTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ZeroPrefetchConsumerTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ZeroPrefetchConsumerTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/blob/
      - copied from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/blob/
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/broker/BrokerBenchmark.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerBenchmark.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/broker/BrokerRestartTestSupport.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerRestartTestSupport.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/broker/BrokerServiceTest.java
      - copied, changed from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerServiceTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/broker/BrokerTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/broker/BrokerTestSupport.java
      - copied, changed from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTestSupport.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/broker/ConcurrentConnectSimulationTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/ConcurrentConnectSimulationTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/broker/CreateDestinationsOnStartupViaXBeanTest.java
      - copied, changed from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/CreateDestinationsOnStartupViaXBeanTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/broker/Main.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/Main.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/broker/MarshallingBrokerTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/MarshallingBrokerTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/broker/MessageExpirationTest.java
      - copied, changed from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/MessageExpirationTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/broker/NioQueueSubscriptionTest.java
      - copied, changed from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/NioQueueSubscriptionTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/broker/ProgressPrinter.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/ProgressPrinter.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/broker/QueueSubscriptionTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/QueueSubscriptionTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/broker/ReconnectWithJMXEnabledTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/ReconnectWithJMXEnabledTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/broker/RecoveryBrokerTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/RecoveryBrokerTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/broker/SpringTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/SpringTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/broker/StubBroker.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/StubBroker.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/broker/StubConnection.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/StubConnection.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/broker/TopicSubscriptionTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/TopicSubscriptionTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/broker/XARecoveryBrokerTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/XARecoveryBrokerTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/broker/advisory/
      - copied from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/advisory/
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/bugs/
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/bugs/AMQ1866.java
      - copied, changed from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/AMQ1866.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/bugs/AMQ1917Test.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/AMQ1917Test.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/bugs/AMQ1936Test.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/AMQ1936Test.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/bugs/AMQ2021Test.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/AMQ2021Test.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/bugs/AMQ2102Test.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/AMQ2102Test.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/bugs/ConnectionPerMessageTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/ConnectionPerMessageTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/bugs/CraigsBugTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/CraigsBugTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/bugs/JmsDurableTopicSlowReceiveTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/JmsDurableTopicSlowReceiveTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/bugs/MessageSender.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/MessageSender.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/bugs/MissingDataFileTest.java
      - copied, changed from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/MissingDataFileTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/bugs/QueueWorkerPrefetchTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/QueueWorkerPrefetchTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/bugs/RawRollbackSharedConsumerTests.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/RawRollbackSharedConsumerTests.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/bugs/RawRollbackTests.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/RawRollbackTests.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/bugs/Receiver.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/Receiver.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/bugs/SlowConsumerTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/SlowConsumerTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/bugs/TransactionNotStartedErrorTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/TransactionNotStartedErrorTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/bugs/VerifySteadyEnqueueRate.java
      - copied, changed from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/VerifySteadyEnqueueRate.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/bugs/amq1095/
      - copied from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/amq1095/
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/demo/
      - copied from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/demo/
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/test/
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/test/JmsResourceProvider.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/JmsResourceProvider.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/test/JmsSendReceiveTestSupport.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/JmsSendReceiveTestSupport.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/test/JmsTopicSendReceiveTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/JmsTopicSendReceiveTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/test/JmsTopicSendReceiveWithEmbeddedBrokerAndUserIDTest.java
      - copied, changed from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/JmsTopicSendReceiveWithEmbeddedBrokerAndUserIDTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/test/JmsTopicSendReceiveWithTwoConnectionsAndByteSelectorTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/JmsTopicSendReceiveWithTwoConnectionsAndByteSelectorTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/test/JmsTopicSendReceiveWithTwoConnectionsAndEmbeddedBrokerTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/JmsTopicSendReceiveWithTwoConnectionsAndEmbeddedBrokerTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/test/JmsTopicSendReceiveWithTwoConnectionsTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/JmsTopicSendReceiveWithTwoConnectionsTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/test/TemporaryDestinationToFromNameTest.java
      - copied, changed from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/TemporaryDestinationToFromNameTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/test/TestSupport.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/TestSupport.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/test/rollback/
      - copied from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/rollback/
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/transport/
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/transport/QueueClusterTest.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/QueueClusterTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/transport/StubTransport.java
      - copied, changed from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/StubTransport.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/transport/StubTransportListener.java
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/StubTransportListener.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/transport/TopicClusterTest.java
      - copied, changed from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/TopicClusterTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/transport/TransportBrokerTestSupport.java
      - copied, changed from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/TransportBrokerTestSupport.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/transport/discovery/
      - copied from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/discovery/
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/transport/failover/
      - copied from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/transport/nio/
      - copied from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/nio/
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/transport/peer/
      - copied from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/peer/
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/transport/tcp/
      - copied from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/tcp/
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/
      - copied from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/META-INF/
      - copied from r783310, activemq/trunk/activemq-core/src/test/resources/META-INF/
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/activemq.xml
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/resources/activemq.xml
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/client.keystore
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/resources/client.keystore
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/dummy.keystore
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/resources/dummy.keystore
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/jndi.properties
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/resources/jndi.properties
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/log4j.properties
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/resources/log4j.properties
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/login.config
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/resources/login.config
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/openwire-control/
      - copied from r783310, activemq/trunk/activemq-core/src/test/resources/openwire-control/
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/broker/
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/broker/destinations-on-start.xml
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/broker/destinations-on-start.xml
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/broker/ft/
      - copied from r783310, activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/broker/ft/
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/broker/policy/
      - copied from r783310, activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/broker/policy/
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/broker/spring.xml
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/broker/spring.xml
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/broker/store/
      - copied from r783310, activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/broker/store/
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/broker/virtual/
      - copied from r783310, activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/broker/virtual/
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/bugs/
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/bugs/amq1095/
      - copied from r783310, activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/bugs/amq1095/
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/config/
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/config/broker.properties
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/config/broker.properties
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/config/config.xml
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/config/config.xml
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/config/example.xml
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/config/example.xml
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/config/sample-conf/
      - copied from r783310, activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/config/sample-conf/
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/config/spring-test.xml
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/config/spring-test.xml
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/filter/
      - copied from r783310, activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/filter/
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/memory/
      - copied from r783310, activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/memory/
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/network/
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/network/duplexLocalBroker.xml
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/network/duplexLocalBroker.xml
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/network/jms/
      - copied from r783310, activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/network/jms/
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/network/localBroker.xml
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/network/localBroker.xml
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/network/multicast/
      - copied from r783310, activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/network/multicast/
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/network/reconnect-broker1.xml
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/network/reconnect-broker1.xml
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/network/reconnect-broker2.xml
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/network/reconnect-broker2.xml
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/network/remoteBroker.xml
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/network/remoteBroker.xml
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/network/ssh-reconnect-broker1.xml
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/network/ssh-reconnect-broker1.xml
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/network/ssh-reconnect-broker2.xml
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/network/ssh-reconnect-broker2.xml
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/perf/
      - copied from r783310, activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/perf/
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/security/
      - copied from r783310, activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/security/
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/spring/
      - copied from r783310, activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/spring/
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/test/
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/test/retroactive/
      - copied from r783310, activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/test/retroactive/
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/transport/
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/transport/stomp/
      - copied from r783310, activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/transport/stomp/
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/transport/tcp/
      - copied from r783310, activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/transport/tcp/
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/usecases/
      - copied from r783310, activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/usecases/
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/util/
      - copied from r783310, activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/util/
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/org/apache/activemq/xbean/
      - copied from r783310, activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/xbean/
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/server.keystore
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/resources/server.keystore
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/spring-embedded-pooled.xml
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/resources/spring-embedded-pooled.xml
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/spring-embedded-xbean-local.xml
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/resources/spring-embedded-xbean-local.xml
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/spring-embedded-xbean-noversion.xml
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/resources/spring-embedded-xbean-noversion.xml
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/spring-embedded-xbean.xml
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/resources/spring-embedded-xbean.xml
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/spring-embedded.xml
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/resources/spring-embedded.xml
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/spring-jndi.xml
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/resources/spring-jndi.xml
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/spring-queue.xml
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/resources/spring-queue.xml
    activemq/sandbox/activemq-flow/activemq-all/src/test/resources/spring.xml
      - copied unchanged from r783310, activemq/trunk/activemq-core/src/test/resources/spring.xml
    activemq/sandbox/activemq-flow/activemq-broker/src/main/java/org/apache/activemq/broker/ConnectionContext.java   (with props)
    activemq/sandbox/activemq-flow/activemq-broker/src/main/java/org/apache/activemq/broker/EmptyBroker.java
    activemq/sandbox/activemq-flow/activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/FixedCountSubscriptionRecoveryPolicy.java
    activemq/sandbox/activemq-flow/activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/RoundRobinDispatchPolicy.java
    activemq/sandbox/activemq-flow/activemq-broker/src/main/java/org/apache/activemq/store/
    activemq/sandbox/activemq-flow/activemq-broker/src/main/java/org/apache/activemq/store/PersistenceAdapter.java
    activemq/sandbox/activemq-flow/activemq-network/src/test/java/org/
    activemq/sandbox/activemq-flow/activemq-network/src/test/java/org/apache/
    activemq/sandbox/activemq-flow/activemq-network/src/test/java/org/apache/activemq/
    activemq/sandbox/activemq-flow/activemq-network/src/test/java/org/apache/activemq/network/
    activemq/sandbox/activemq-flow/activemq-network/src/test/java/org/apache/activemq/network/jms/
    activemq/sandbox/activemq-flow/activemq-network/src/test/java/org/apache/activemq/network/jms/QueueBridgeTest.java   (with props)
    activemq/sandbox/activemq-flow/activemq-network/src/test/java/org/apache/activemq/network/jms/QueueBridgeXBeanTest.java
    activemq/sandbox/activemq-flow/activemq-network/src/test/java/org/apache/activemq/network/jms/TopicBridgeSpringTest.java   (with props)
    activemq/sandbox/activemq-flow/activemq-network/src/test/java/org/apache/activemq/network/jms/TopicBridgeXBeanTest.java
    activemq/sandbox/activemq-flow/activemq-transport/src/test/java/org/
    activemq/sandbox/activemq-flow/activemq-transport/src/test/java/org/apache/
    activemq/sandbox/activemq-flow/activemq-transport/src/test/java/org/apache/activemq/
    activemq/sandbox/activemq-flow/activemq-transport/src/test/java/org/apache/activemq/transport/
    activemq/sandbox/activemq-flow/activemq-transport/src/test/java/org/apache/activemq/transport/mock/
    activemq/sandbox/activemq-flow/activemq-transport/src/test/java/org/apache/activemq/transport/mock/MockTransport.java
    activemq/sandbox/activemq-flow/activemq-transport/src/test/java/org/apache/activemq/transport/mock/MockTransportFactory.java   (with props)
    activemq/sandbox/activemq-flow/activemq-transport/src/test/java/org/apache/activemq/transport/mock/package.html   (with props)
    activemq/sandbox/activemq-flow/activemq-transport/src/test/resources/META-INF/
    activemq/sandbox/activemq-flow/activemq-transport/src/test/resources/META-INF/services/
    activemq/sandbox/activemq-flow/activemq-transport/src/test/resources/META-INF/services/org/
    activemq/sandbox/activemq-flow/activemq-transport/src/test/resources/META-INF/services/org/apache/
    activemq/sandbox/activemq-flow/activemq-transport/src/test/resources/META-INF/services/org/apache/activemq/
    activemq/sandbox/activemq-flow/activemq-transport/src/test/resources/META-INF/services/org/apache/activemq/transport/
    activemq/sandbox/activemq-flow/activemq-transport/src/test/resources/META-INF/services/org/apache/activemq/transport/mock
    activemq/sandbox/activemq-flow/activemq-util/src/main/java/org/apache/activemq/util/IOHelper.java
    activemq/sandbox/activemq-flow/activemq-util/src/test/java/org/apache/activemq/util/MessageIdList.java
Removed:
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/transport/discovery/DiscoveryTransportBrokerTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/transport/discovery/RendezvousDiscoverTransportTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/transport/failover/FailoverConsumerTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/transport/failover/FailoverTransportBrokerTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/BrokerQueueNetworkWithDisconnectTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/JDBCDurableSubscriptionTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/JournalDurableSubscriptionTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/KahaDurableSubscriptionTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/MultiBrokersMultiClientsTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/MultiBrokersMultiClientsUsingTcpTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/QueueMemoryFullMultiBrokersTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/ThreeBrokerQueueNetworkTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/ThreeBrokerQueueNetworkUsingTcpTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/ThreeBrokerTempQueueNetworkTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/ThreeBrokerTopicNetworkTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/ThreeBrokerTopicNetworkUsingTcpTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/TwoBrokerMessageNotSentToRemoteWhenNoConsumerTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/TwoBrokerMulticastQueueTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/TwoBrokerQueueClientsReconnectTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/TwoBrokerQueueSendReceiveTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/TwoBrokerTopicSendReceiveLotsOfMessagesUsingTcpTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/TwoBrokerTopicSendReceiveTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/TwoBrokerTopicSendReceiveUsingHttpTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/TwoBrokerTopicSendReceiveUsingJavaConfigurationTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/TwoBrokerTopicSendReceiveUsingTcpTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/TwoMulticastDiscoveryBrokerTopicSendReceiveTest.java
    activemq/sandbox/activemq-flow/activemq-broker/src/main/java/org/apache/activemq/broker/ManagementContext.java
Modified:
    activemq/sandbox/activemq-flow/activemq-all/pom.xml
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/broker/openwire/OpenwireRemoteConsumer.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/broker/openwire/OpenwireRemoteProducer.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/transport/failover/AMQ1925Test.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/transport/failover/FailoverRandomTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/transport/failover/FailoverTimeoutTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/transport/failover/ReconnectTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/transport/tcp/SslBrokerServiceTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/transport/tcp/SslContextBrokerServiceTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/transport/tcp/SslContextNBrokerServiceTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/AMQStackOverFlowTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/CompositeConsumeTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/CompositePublishTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/ConsumeTopicPrefetchTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/DurableSubscriptionTestSupport.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/ExpiredMessagesTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/MessageGroupDelayedTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/NoDuplicateOnTopicNetworkTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/PublishOnQueueConsumedMessageInTransactionTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/PublishOnQueueConsumedMessageUsingActivemqXMLTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/PublishOnTopicConsumerMessageUsingActivemqXMLTest.java
    activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/usecases/ReliableReconnectTest.java
    activemq/sandbox/activemq-flow/activemq-broker/src/main/java/org/apache/activemq/broker/Broker.java
    activemq/sandbox/activemq-flow/activemq-broker/src/main/java/org/apache/activemq/broker/BrokerService.java
    activemq/sandbox/activemq-flow/activemq-broker/src/main/java/org/apache/activemq/broker/Connection.java
    activemq/sandbox/activemq-flow/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnector.java
    activemq/sandbox/activemq-flow/activemq-broker/src/main/java/org/apache/activemq/broker/region/RegionBroker.java
    activemq/sandbox/activemq-flow/activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java
    activemq/sandbox/activemq-flow/activemq-broker/src/main/java/org/apache/activemq/broker/region/policy/PolicyMap.java
    activemq/sandbox/activemq-flow/activemq-network/pom.xml
    activemq/sandbox/activemq-flow/activemq-network/src/main/java/org/apache/activemq/network/NetworkConnector.java
    activemq/sandbox/activemq-flow/activemq-spring/pom.xml
    activemq/sandbox/activemq-flow/activemq-transport/src/main/java/org/apache/activemq/transport/TransportSupport.java
    activemq/sandbox/activemq-flow/activemq-util/pom.xml

Modified: activemq/sandbox/activemq-flow/activemq-all/pom.xml
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-flow/activemq-all/pom.xml?rev=783612&r1=783611&r2=783612&view=diff
==============================================================================
--- activemq/sandbox/activemq-flow/activemq-all/pom.xml (original)
+++ activemq/sandbox/activemq-flow/activemq-all/pom.xml Thu Jun 11 03:08:06 2009
@@ -65,16 +65,41 @@
       <groupId>org.apache.activemq</groupId>
       <artifactId>activemq-spring</artifactId>
     </dependency>
+    <dependency>
+      <groupId>org.apache.activemq</groupId>
+      <artifactId>activemq-network</artifactId>
+    </dependency>
 
     <!-- Testing Dependencies -->    
     <dependency>
       <groupId>org.apache.activemq</groupId>
+      <artifactId>activemq-transport</artifactId>
+      <version>${activemq-version}</version>
+      <type>test-jar</type>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.apache.activemq</groupId>
       <artifactId>activemq-broker</artifactId>
       <version>${activemq-version}</version>
       <type>test-jar</type>
       <scope>test</scope>
     </dependency>
     <dependency>
+      <groupId>org.apache.activemq</groupId>
+      <artifactId>activemq-util</artifactId>
+      <version>${activemq-version}</version>
+      <type>test-jar</type>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.apache.activemq</groupId>
+      <artifactId>activemq-spring</artifactId>
+      <version>${activemq-version}</version>
+      <type>test-jar</type>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
       <groupId>org.springframework</groupId>
       <artifactId>spring-jms</artifactId>
       <scope>test</scope>

Copied: activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ActiveMQConnectionFactoryTest.java (from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ActiveMQConnectionFactoryTest.java)
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ActiveMQConnectionFactoryTest.java?p2=activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ActiveMQConnectionFactoryTest.java&p1=activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ActiveMQConnectionFactoryTest.java&r1=783310&r2=783612&rev=783612&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ActiveMQConnectionFactoryTest.java (original)
+++ activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ActiveMQConnectionFactoryTest.java Thu Jun 11 03:08:06 2009
@@ -30,7 +30,6 @@
 import org.apache.activemq.broker.BrokerRegistry;
 import org.apache.activemq.broker.BrokerService;
 import org.apache.activemq.broker.TransportConnector;
-import org.apache.activemq.network.DiscoveryNetworkConnector;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 

Copied: activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ActiveMQXAConnectionFactoryTest.java (from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ActiveMQXAConnectionFactoryTest.java)
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ActiveMQXAConnectionFactoryTest.java?p2=activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ActiveMQXAConnectionFactoryTest.java&p1=activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ActiveMQXAConnectionFactoryTest.java&r1=783310&r2=783612&rev=783612&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ActiveMQXAConnectionFactoryTest.java (original)
+++ activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ActiveMQXAConnectionFactoryTest.java Thu Jun 11 03:08:06 2009
@@ -38,8 +38,8 @@
 import javax.transaction.xa.Xid;
 
 import org.apache.activemq.broker.BrokerRegistry;
-import org.apache.activemq.broker.BrokerService;
 import org.apache.activemq.broker.TransportConnector;
+import org.apache.activemq.broker.BrokerService;
 import org.apache.activemq.command.ActiveMQQueue;
 import org.apache.activemq.command.ActiveMQTextMessage;
 import org.apache.activemq.transport.stomp.StompTransportFilter;

Copied: activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ClientTestSupport.java (from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ClientTestSupport.java)
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ClientTestSupport.java?p2=activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ClientTestSupport.java&p1=activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ClientTestSupport.java&r1=783310&r2=783612&rev=783612&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ClientTestSupport.java (original)
+++ activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ClientTestSupport.java Thu Jun 11 03:08:06 2009
@@ -26,6 +26,7 @@
 import javax.jms.JMSException;
 
 import junit.framework.TestCase;
+
 import org.apache.activemq.broker.Broker;
 import org.apache.activemq.broker.BrokerFactory;
 import org.apache.activemq.broker.BrokerService;

Copied: activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JMSConsumerTest.java (from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JMSConsumerTest.java)
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JMSConsumerTest.java?p2=activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JMSConsumerTest.java&p1=activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JMSConsumerTest.java&r1=783310&r2=783612&rev=783612&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JMSConsumerTest.java (original)
+++ activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JMSConsumerTest.java Thu Jun 11 03:08:06 2009
@@ -49,7 +49,6 @@
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
-import edu.emory.mathcs.backport.java.util.Collections;
 
 /**
  * Test cases used to test the JMS message consumer.
@@ -141,7 +140,7 @@
         final ActiveMQMessageConsumer consumer = (ActiveMQMessageConsumer)session.createConsumer(destination);
        
         final Map<Thread, Throwable> exceptions = 
-            Collections.synchronizedMap(new HashMap<Thread, Throwable>());
+            java.util.Collections.synchronizedMap(new HashMap<Thread, Throwable>());
         Thread.setDefaultUncaughtExceptionHandler(new UncaughtExceptionHandler() {
             public void uncaughtException(Thread t, Throwable e) {
                 LOG.error("Uncaught exception:", e);
@@ -914,7 +913,7 @@
     }
     
     protected DestinationViewMBean createView(ActiveMQDestination destination) throws Exception {
-         MBeanServer mbeanServer = broker.getManagementContext().getMBeanServer();
+         MBeanServer mbeanServer = broker.getMBeanServer();
          String domain = "org.apache.activemq";
          ObjectName name;
         if (destination.isQueue()) {

Copied: activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsBenchmark.java (from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsBenchmark.java)
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsBenchmark.java?p2=activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsBenchmark.java&p1=activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsBenchmark.java&r1=783310&r2=783612&rev=783612&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsBenchmark.java (original)
+++ activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsBenchmark.java Thu Jun 11 03:08:06 2009
@@ -37,9 +37,10 @@
 import javax.jms.Session;
 
 import junit.framework.Test;
+
 import org.apache.activemq.broker.BrokerFactory;
-import org.apache.activemq.broker.BrokerService;
 import org.apache.activemq.broker.TransportConnector;
+import org.apache.activemq.broker.BrokerService;
 import org.apache.activemq.command.ActiveMQDestination;
 import org.apache.activemq.command.ActiveMQQueue;
 import org.apache.commons.logging.Log;

Added: activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsMultipleClientsTestSupport.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsMultipleClientsTestSupport.java?rev=783612&view=auto
==============================================================================
--- activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsMultipleClientsTestSupport.java (added)
+++ activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/JmsMultipleClientsTestSupport.java Thu Jun 11 03:08:06 2009
@@ -0,0 +1,283 @@
+/**
+ * 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.activemq;
+
+import java.net.URI;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.atomic.AtomicInteger;
+
+import javax.jms.Connection;
+import javax.jms.ConnectionFactory;
+import javax.jms.DeliveryMode;
+import javax.jms.Destination;
+import javax.jms.JMSException;
+import javax.jms.MessageConsumer;
+import javax.jms.MessageProducer;
+import javax.jms.Session;
+import javax.jms.TextMessage;
+import javax.jms.TopicSubscriber;
+
+import org.apache.activemq.broker.BrokerFactory;
+import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.command.ActiveMQDestination;
+import org.apache.activemq.command.ActiveMQQueue;
+import org.apache.activemq.command.ActiveMQTopic;
+import org.apache.activemq.util.MessageIdList;
+
+/**
+ * Test case support used to test multiple message comsumers and message
+ * producers connecting to a single broker.
+ * 
+ * @version $Revision$
+ */
+public class JmsMultipleClientsTestSupport extends CombinationTestSupport {
+
+    protected Map<MessageConsumer, MessageIdList> consumers = new HashMap<MessageConsumer, MessageIdList>(); // Map of consumer with messages
+                                                // received
+    protected int consumerCount = 1;
+    protected int producerCount = 1;
+
+    protected int messageSize = 1024;
+
+    protected boolean useConcurrentSend = true;
+    protected boolean durable;
+    protected boolean topic;
+    protected boolean persistent;
+
+    protected BrokerService broker;
+    protected Destination destination;
+    protected List<Connection> connections = Collections.synchronizedList(new ArrayList<Connection>());
+    protected MessageIdList allMessagesList = new MessageIdList();
+
+    private AtomicInteger producerLock;
+
+    protected void startProducers(Destination dest, int msgCount) throws Exception {
+        startProducers(createConnectionFactory(), dest, msgCount);
+    }
+
+    protected void startProducers(final ConnectionFactory factory, final Destination dest, final int msgCount) throws Exception {
+        // Use concurrent send
+        if (useConcurrentSend) {
+            producerLock = new AtomicInteger(producerCount);
+
+            for (int i = 0; i < producerCount; i++) {
+                Thread t = new Thread(new Runnable() {
+                    public void run() {
+                        try {
+                            sendMessages(factory.createConnection(), dest, msgCount);
+                        } catch (Exception e) {
+                            e.printStackTrace();
+                        }
+
+                        synchronized (producerLock) {
+                            producerLock.decrementAndGet();
+                            producerLock.notifyAll();
+                        }
+                    }
+                });
+
+                t.start();
+            }
+
+            // Wait for all producers to finish sending
+            synchronized (producerLock) {
+                while (producerLock.get() != 0) {
+                    producerLock.wait(2000);
+                }
+            }
+
+            // Use serialized send
+        } else {
+            for (int i = 0; i < producerCount; i++) {
+                sendMessages(factory.createConnection(), dest, msgCount);
+            }
+        }
+    }
+
+    protected void sendMessages(Connection connection, Destination destination, int count) throws Exception {
+        connection.start();
+
+        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+        MessageProducer producer = session.createProducer(destination);
+        producer.setDeliveryMode(persistent ? DeliveryMode.PERSISTENT : DeliveryMode.NON_PERSISTENT);
+
+        for (int i = 0; i < count; i++) {
+            TextMessage msg = createTextMessage(session, "" + i);
+            producer.send(msg);
+        }
+
+        producer.close();
+        session.close();
+        connection.close();
+    }
+
+    protected TextMessage createTextMessage(Session session, String initText) throws Exception {
+        TextMessage msg = session.createTextMessage();
+
+        // Pad message text
+        if (initText.length() < messageSize) {
+            char[] data = new char[messageSize - initText.length()];
+            Arrays.fill(data, '*');
+            String str = new String(data);
+            msg.setText(initText + str);
+
+            // Do not pad message text
+        } else {
+            msg.setText(initText);
+        }
+
+        return msg;
+    }
+
+    protected void startConsumers(Destination dest) throws Exception {
+        startConsumers(createConnectionFactory(), dest);
+    }
+
+    protected void startConsumers(ConnectionFactory factory, Destination dest) throws Exception {
+        MessageConsumer consumer;
+        for (int i = 0; i < consumerCount; i++) {
+            if (durable && topic) {
+                consumer = createDurableSubscriber(factory.createConnection(), dest, "consumer" + (i + 1));
+            } else {
+                consumer = createMessageConsumer(factory.createConnection(), dest);
+            }
+            MessageIdList list = new MessageIdList();
+            list.setParent(allMessagesList);
+            consumer.setMessageListener(list);
+            consumers.put(consumer, list);
+        }
+    }
+
+    protected MessageConsumer createMessageConsumer(Connection conn, Destination dest) throws Exception {
+        connections.add(conn);
+
+        Session sess = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
+        final MessageConsumer consumer = sess.createConsumer(dest);
+        conn.start();
+
+        return consumer;
+    }
+
+    protected TopicSubscriber createDurableSubscriber(Connection conn, Destination dest, String name) throws Exception {
+        conn.setClientID(name);
+        connections.add(conn);
+        conn.start();
+
+        Session sess = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
+        final TopicSubscriber consumer = sess.createDurableSubscriber((javax.jms.Topic)dest, name);
+
+        return consumer;
+    }
+
+    protected void waitForAllMessagesToBeReceived(int messageCount) throws Exception {
+        allMessagesList.waitForMessagesToArrive(messageCount);
+    }
+
+    protected ActiveMQDestination createDestination() throws JMSException {
+        String name = "." + getClass().getName() + "." + getName();
+        if (topic) {
+            destination = new ActiveMQTopic("Topic" + name);
+            return (ActiveMQDestination)destination;
+        } else {
+            destination = new ActiveMQQueue("Queue" + name);
+            return (ActiveMQDestination)destination;
+        }
+    }
+
+    protected ConnectionFactory createConnectionFactory() throws Exception {
+        return new ActiveMQConnectionFactory("vm://localhost");
+    }
+
+    protected BrokerService createBroker() throws Exception {
+        return BrokerFactory.createBroker(new URI("broker://()/localhost?persistent=false&useJmx=true"));
+    }
+
+    protected void setUp() throws Exception {
+        super.setAutoFail(true);
+        super.setUp();
+        broker = createBroker();
+        broker.start();
+    }
+
+    protected void tearDown() throws Exception {
+        for (Iterator<Connection> iter = connections.iterator(); iter.hasNext();) {
+            Connection conn = iter.next();
+            try {
+                conn.close();
+            } catch (Throwable e) {
+            }
+        }
+        broker.stop();
+        allMessagesList.flushMessages();
+        consumers.clear();
+        super.tearDown();
+    }
+
+    /*
+     * Some helpful assertions for multiple consumers.
+     */
+    protected void assertConsumerReceivedAtLeastXMessages(MessageConsumer consumer, int msgCount) {
+        MessageIdList messageIdList = consumers.get(consumer);
+        messageIdList.assertAtLeastMessagesReceived(msgCount);
+    }
+
+    protected void assertConsumerReceivedAtMostXMessages(MessageConsumer consumer, int msgCount) {
+        MessageIdList messageIdList = consumers.get(consumer);
+        messageIdList.assertAtMostMessagesReceived(msgCount);
+    }
+
+    protected void assertConsumerReceivedXMessages(MessageConsumer consumer, int msgCount) {
+        MessageIdList messageIdList = consumers.get(consumer);
+        messageIdList.assertMessagesReceivedNoWait(msgCount);
+    }
+
+    protected void assertEachConsumerReceivedAtLeastXMessages(int msgCount) {
+        for (Iterator<MessageConsumer> i = consumers.keySet().iterator(); i.hasNext();) {
+            assertConsumerReceivedAtLeastXMessages(i.next(), msgCount);
+        }
+    }
+
+    protected void assertEachConsumerReceivedAtMostXMessages(int msgCount) {
+        for (Iterator<MessageConsumer> i = consumers.keySet().iterator(); i.hasNext();) {
+            assertConsumerReceivedAtMostXMessages(i.next(), msgCount);
+        }
+    }
+
+    protected void assertEachConsumerReceivedXMessages(int msgCount) {
+        for (Iterator<MessageConsumer> i = consumers.keySet().iterator(); i.hasNext();) {
+            assertConsumerReceivedXMessages(i.next(), msgCount);
+        }
+    }
+
+    protected void assertTotalMessagesReceived(int msgCount) {
+        allMessagesList.assertMessagesReceivedNoWait(msgCount);
+
+        // now lets count the individual messages received
+        int totalMsg = 0;
+        for (Iterator<MessageConsumer> i = consumers.keySet().iterator(); i.hasNext();) {
+            MessageIdList messageIdList = consumers.get(i.next());
+            totalMsg += messageIdList.getMessageCount();
+        }
+        assertEquals("Total of consumers message count", msgCount, totalMsg);
+    }
+}

Copied: activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/LoadTestBurnIn.java (from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/LoadTestBurnIn.java)
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/LoadTestBurnIn.java?p2=activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/LoadTestBurnIn.java&p1=activemq/trunk/activemq-core/src/test/java/org/apache/activemq/LoadTestBurnIn.java&r1=783310&r2=783612&rev=783612&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/LoadTestBurnIn.java (original)
+++ activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/LoadTestBurnIn.java Thu Jun 11 03:08:06 2009
@@ -34,9 +34,10 @@
 import javax.jms.Topic;
 
 import junit.framework.Test;
+
 import org.apache.activemq.broker.BrokerFactory;
-import org.apache.activemq.broker.BrokerService;
 import org.apache.activemq.broker.TransportConnector;
+import org.apache.activemq.broker.BrokerService;
 import org.apache.activemq.command.ActiveMQDestination;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;

Copied: activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/MessageGroupTest.java (from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/region/group/MessageGroupTest.java)
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/MessageGroupTest.java?p2=activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/MessageGroupTest.java&p1=activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/region/group/MessageGroupTest.java&r1=783310&r2=783612&rev=783612&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/region/group/MessageGroupTest.java (original)
+++ activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/MessageGroupTest.java Thu Jun 11 03:08:06 2009
@@ -1,4 +1,4 @@
-package org.apache.activemq.broker.region.group;
+package org.apache.activemq;
 
 import javax.jms.Connection;
 import javax.jms.Message;
@@ -7,8 +7,6 @@
 import javax.jms.Session;
 import javax.jms.TextMessage;
 
-import org.apache.activemq.CombinationTestSupport;
-import org.apache.activemq.JmsTestSupport;
 import org.apache.activemq.command.ActiveMQDestination;
 import org.apache.activemq.command.ActiveMQQueue;
 import org.apache.commons.logging.Log;

Copied: activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ProducerFlowControlSendFailTest.java (from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ProducerFlowControlSendFailTest.java)
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ProducerFlowControlSendFailTest.java?p2=activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ProducerFlowControlSendFailTest.java&p1=activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ProducerFlowControlSendFailTest.java&r1=783310&r2=783612&rev=783612&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ProducerFlowControlSendFailTest.java (original)
+++ activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ProducerFlowControlSendFailTest.java Thu Jun 11 03:08:06 2009
@@ -28,11 +28,11 @@
 import javax.jms.Session;
 import javax.jms.TextMessage;
 
-import org.apache.activemq.broker.BrokerService;
 import org.apache.activemq.broker.region.policy.PolicyEntry;
 import org.apache.activemq.broker.region.policy.PolicyMap;
 import org.apache.activemq.broker.region.policy.VMPendingQueueMessageStoragePolicy;
 import org.apache.activemq.broker.region.policy.VMPendingSubscriberMessageStoragePolicy;
+import org.apache.activemq.broker.BrokerService;
 
 public class ProducerFlowControlSendFailTest extends ProducerFlowControlTest {
 

Copied: activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ProducerFlowControlTest.java (from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ProducerFlowControlTest.java)
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ProducerFlowControlTest.java?p2=activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ProducerFlowControlTest.java&p1=activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ProducerFlowControlTest.java&r1=783310&r2=783612&rev=783612&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ProducerFlowControlTest.java (original)
+++ activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ProducerFlowControlTest.java Thu Jun 11 03:08:06 2009
@@ -29,12 +29,12 @@
 import javax.jms.Session;
 import javax.jms.TextMessage;
 
-import org.apache.activemq.broker.BrokerService;
 import org.apache.activemq.broker.TransportConnector;
 import org.apache.activemq.broker.region.policy.PolicyEntry;
 import org.apache.activemq.broker.region.policy.PolicyMap;
 import org.apache.activemq.broker.region.policy.VMPendingQueueMessageStoragePolicy;
 import org.apache.activemq.broker.region.policy.VMPendingSubscriberMessageStoragePolicy;
+import org.apache.activemq.broker.BrokerService;
 import org.apache.activemq.command.ActiveMQQueue;
 import org.apache.activemq.transport.tcp.TcpTransport;
 

Copied: activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ReconnectWithSameClientIDTest.java (from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ReconnectWithSameClientIDTest.java)
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ReconnectWithSameClientIDTest.java?p2=activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ReconnectWithSameClientIDTest.java&p1=activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ReconnectWithSameClientIDTest.java&r1=783310&r2=783612&rev=783612&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ReconnectWithSameClientIDTest.java (original)
+++ activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/ReconnectWithSameClientIDTest.java Thu Jun 11 03:08:06 2009
@@ -21,7 +21,6 @@
 import javax.jms.JMSException;
 import javax.jms.Session;
 
-import org.apache.activemq.store.kahadaptor.KahaPersistenceAdapter;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 

Copied: activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/RemoveDestinationTest.java (from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/RemoveDestinationTest.java)
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/RemoveDestinationTest.java?p2=activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/RemoveDestinationTest.java&p1=activemq/trunk/activemq-core/src/test/java/org/apache/activemq/RemoveDestinationTest.java&r1=783310&r2=783612&rev=783612&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/RemoveDestinationTest.java (original)
+++ activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/RemoveDestinationTest.java Thu Jun 11 03:08:06 2009
@@ -32,6 +32,7 @@
 import org.apache.activemq.advisory.DestinationSource;
 import org.apache.activemq.broker.BrokerFactory;
 import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.broker.jmx.BrokerViewMBean;
 import org.apache.activemq.command.ActiveMQDestination;
 import org.apache.activemq.command.ActiveMQTopic;
 
@@ -153,7 +154,8 @@
     private boolean destinationPresentInAdminView(BrokerService broker2,
             ActiveMQTopic amqTopic) throws Exception {
         boolean found = false;
-        for (ObjectName name : broker.getAdminView().getTopics()) {
+        BrokerViewMBean view = broker.getAdminView();
+        for (ObjectName name : view.getTopics()) {
             if (name.getKeyProperty("Destination") != null &&
                     name.getKeyProperty("Destination").equalsIgnoreCase(amqTopic.getTopicName())) {
                 found = true;

Copied: activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/TimeStampTest.java (from r783310, activemq/trunk/activemq-core/src/test/java/org/apache/activemq/TimeStampTest.java)
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/TimeStampTest.java?p2=activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/TimeStampTest.java&p1=activemq/trunk/activemq-core/src/test/java/org/apache/activemq/TimeStampTest.java&r1=783310&r2=783612&rev=783612&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/TimeStampTest.java (original)
+++ activemq/sandbox/activemq-flow/activemq-all/src/test/java/org/apache/activemq/TimeStampTest.java Thu Jun 11 03:08:06 2009
@@ -25,17 +25,18 @@
 import javax.jms.Session;
 
 import junit.framework.TestCase;
+
 import org.apache.activemq.broker.BrokerPlugin;
+//import org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
+//import org.apache.activemq.broker.view.ConnectionDotFilePlugin;
 import org.apache.activemq.broker.BrokerService;
-import org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
-import org.apache.activemq.broker.view.ConnectionDotFilePlugin;
 
 public class TimeStampTest extends TestCase {
     public void test() throws Exception {
         BrokerService broker = new BrokerService();
         broker.setPersistent(false);
         broker.setUseJmx(true);
-        broker.setPlugins(new BrokerPlugin[] {new ConnectionDotFilePlugin(), new UDPTraceBrokerPlugin()});
+//        broker.setPlugins(new BrokerPlugin[] {new ConnectionDotFilePlugin(), new UDPTraceBrokerPlugin()});
         broker.addConnector("tcp://localhost:61616");
         broker.addConnector("stomp://localhost:61613");
         broker.start();