ARTEMIS-127 Adding activemq unit test module to Artemis This test module brings in activemq unit tests and run them against Artemis broker.
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/60979268 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/60979268 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/60979268 Branch: refs/heads/master Commit: 60979268e1dc95526fbca976a43b8d13f5b48859 Parents: afe5b5c Author: Howard Gao <[email protected]> Authored: Mon Jun 8 10:45:30 2015 +0800 Committer: Clebert Suconic <[email protected]> Committed: Tue Jun 9 12:35:56 2015 -0400 ---------------------------------------------------------------------- pom.xml | 7 + tests/activemq5-unit-tests/README.md | 15 + tests/activemq5-unit-tests/pom.xml | 387 ++++ .../artemiswrapper/ArtemisBrokerHelper.java | 76 + .../apache/activemq/broker/BrokerService.java | 811 ++++++++ .../activemq/broker/SslBrokerService.java | 61 + .../artemiswrapper/ArtemisBrokerBase.java | 674 +++++++ .../artemiswrapper/ArtemisBrokerWrapper.java | 209 +++ .../broker/artemiswrapper/InVMNameParser.java | 74 + .../artemiswrapper/InVMNamingContext.java | 370 ++++ .../artemiswrapper/NonSerializableFactory.java | 111 ++ ...mis.spi.core.protocol.ProtocolManagerFactory | 2 + .../src/test/java/activemq-browse.properties | 61 + .../src/test/java/activemq-partition.xml | 58 + .../src/test/java/activemq.xml | 37 + .../src/test/java/client.keystore | 0 .../src/test/java/credentials.properties | 24 + .../src/test/java/dummy.keystore | 0 .../src/test/java/jmx.access | 18 + .../src/test/java/jmx.password | 18 + .../src/test/java/jndi.properties | 38 + .../src/test/java/log4j.properties | 46 + .../src/test/java/login.config | 87 + ....apache.activemq.openwire.BrokerInfoData.bin | 0 ...che.activemq.openwire.WireFormatInfoData.bin | 0 .../activemq/ActiveMQConnectionFactoryTest.java | 261 +++ .../activemq/ActiveMQInputStreamTest.java | 145 ++ .../activemq/ActiveMQMessageAuditTest.java | 186 ++ .../ActiveMQSslConnectionFactoryTest.java | 262 +++ .../ActiveMQXAConnectionFactoryTest.java | 584 ++++++ .../org/apache/activemq/ClientTestSupport.java | 177 ++ .../apache/activemq/CombinationTestSupport.java | 272 +++ .../apache/activemq/ConnectionCleanupTest.java | 69 + ...nectionCloseMultipleTimesConcurrentTest.java | 96 + .../ConnectionCloseMultipleTimesTest.java | 67 + .../ConsumerReceiveWithTimeoutTest.java | 87 + ...nsumerButDontStartConnectionWarningTest.java | 43 + .../EmbeddedBrokerAndConnectionTestSupport.java | 44 + .../activemq/EmbeddedBrokerTestSupport.java | 143 ++ ...ExclusiveConsumerStartupDestinationTest.java | 203 ++ .../apache/activemq/ExclusiveConsumerTest.java | 357 ++++ .../java/org/apache/activemq/ExpiryHogTest.java | 82 + .../org/apache/activemq/JMSConsumerTest.java | 937 ++++++++++ .../activemq/JMSDurableTopicRedeliverTest.java | 80 + .../activemq/JMSExclusiveConsumerTest.java | 152 ++ .../apache/activemq/JMSIndividualAckTest.java | 161 ++ .../org/apache/activemq/JMSMessageTest.java | 547 ++++++ .../apache/activemq/JMSQueueRedeliverTest.java | 27 + .../org/apache/activemq/JMSUsecaseTest.java | 141 ++ .../org/apache/activemq/JMSXAConsumerTest.java | 50 + .../apache/activemq/JmsAutoAckListenerTest.java | 80 + .../org/apache/activemq/JmsAutoAckTest.java | 80 + .../java/org/apache/activemq/JmsBenchmark.java | 209 +++ .../activemq/JmsClientAckListenerTest.java | 130 ++ .../org/apache/activemq/JmsClientAckTest.java | 151 ++ .../activemq/JmsConnectionStartStopTest.java | 158 ++ .../JmsConsumerResetActiveListenerTest.java | 151 ++ .../JmsCreateConsumerInOnMessageTest.java | 99 + .../JmsDurableQueueWildcardSendReceiveTest.java | 52 + .../activemq/JmsDurableTopicSelectorTest.java | 27 + .../JmsDurableTopicSendReceiveTest.java | 90 + .../JmsDurableTopicTransactionTest.java | 40 + .../JmsDurableTopicWildcardSendReceiveTest.java | 54 + .../apache/activemq/JmsMessageConsumerTest.java | 170 ++ .../activemq/JmsMultipleBrokersTestSupport.java | 641 +++++++ .../activemq/JmsMultipleClientsTestSupport.java | 335 ++++ .../apache/activemq/JmsQueueBrowserTest.java | 448 +++++ .../JmsQueueCompositeSendReceiveTest.java | 119 ++ .../activemq/JmsQueueRequestReplyTest.java | 33 + .../apache/activemq/JmsQueueSelectorTest.java | 28 + .../activemq/JmsQueueSendReceiveTest.java | 35 + ...eiveTwoConnectionsStartBeforeBrokerTest.java | 86 + .../JmsQueueSendReceiveTwoConnectionsTest.java | 36 + ...JmsQueueSendReceiveUsingTwoSessionsTest.java | 33 + .../JmsQueueTopicCompositeSendReceiveTest.java | 88 + .../JmsQueueWildcardSendReceiveTest.java | 174 ++ .../org/apache/activemq/JmsRedeliveredTest.java | 562 ++++++ .../activemq/JmsRollbackRedeliveryTest.java | 358 ++++ .../activemq/JmsSendReceiveTestSupport.java | 237 +++ ...JmsSendReceiveWithMessageExpirationTest.java | 310 +++ .../activemq/JmsSendWithAsyncCallbackTest.java | 127 ++ .../apache/activemq/JmsSessionRecoverTest.java | 294 +++ .../apache/activemq/JmsTempDestinationTest.java | 377 ++++ .../org/apache/activemq/JmsTestSupport.java | 186 ++ .../JmsTopicCompositeSendReceiveTest.java | 88 + .../apache/activemq/JmsTopicRedeliverTest.java | 161 ++ .../activemq/JmsTopicRequestReplyTest.java | 222 +++ .../apache/activemq/JmsTopicSelectorTest.java | 208 +++ .../JmsTopicSendReceiveSubscriberTest.java | 36 + .../activemq/JmsTopicSendReceiveTest.java | 92 + ...sTopicSendReceiveWithTwoConnectionsTest.java | 113 ++ ...endReceiveWithTwoConnectionsWithJMXTest.java | 29 + .../activemq/JmsTopicSendSameMessageTest.java | 48 + .../activemq/JmsTopicTransactionTest.java | 38 + .../JmsTopicWildcardSendReceiveTest.java | 209 +++ .../activemq/LargeMessageTestSupport.java | 197 ++ .../org/apache/activemq/LargeStreamletTest.java | 162 ++ .../org/apache/activemq/LoadTestBurnIn.java | 171 ++ .../apache/activemq/MessageEvictionTest.java | 288 +++ .../activemq/MessageListenerRedeliveryTest.java | 357 ++++ .../activemq/MessageTransformationTest.java | 100 + .../activemq/OnePrefetchAsyncConsumerTest.java | 222 +++ .../org/apache/activemq/OptimizedAckTest.java | 180 ++ .../activemq/PerDestinationStoreLimitTest.java | 199 ++ .../ProducerFlowControlSendFailTest.java | 176 ++ .../activemq/ProducerFlowControlTest.java | 348 ++++ .../activemq/QueueConsumerPriorityTest.java | 94 + .../activemq/ReconnectWithSameClientIDTest.java | 116 ++ .../apache/activemq/RedeliveryPolicyTest.java | 830 +++++++++ .../apache/activemq/RemoveDestinationTest.java | 165 ++ .../org/apache/activemq/SpringTestSupport.java | 65 + .../java/org/apache/activemq/TestSupport.java | 228 +++ .../java/org/apache/activemq/TimeStampTest.java | 97 + .../apache/activemq/TransactionContextTest.java | 140 ++ .../activemq/ZeroPrefetchConsumerTest.java | 404 ++++ .../advisory/AdvisoryTempDestinationTests.java | 232 +++ .../apache/activemq/advisory/AdvisoryTests.java | 238 +++ .../activemq/advisory/ConsumerListenerTest.java | 152 ++ .../advisory/DestinationListenerTest.java | 129 ++ .../activemq/advisory/ProducerListenerTest.java | 151 ++ .../activemq/advisory/TempDestDeleteTest.java | 149 ++ .../activemq/advisory/TempDestLoadTest.java | 115 ++ .../activemq/advisory/TempQueueMemoryTest.java | 171 ++ .../blob/BlobTransferPolicyUriTest.java | 32 + .../blob/FTPBlobDownloadStrategyTest.java | 108 ++ .../org/apache/activemq/blob/FTPBlobTest.java | 75 + .../blob/FTPBlobUploadStrategyTest.java | 75 + .../apache/activemq/blob/FTPTestSupport.java | 124 ++ .../activemq/blob/FilesystemBlobTest.java | 104 ++ .../org/apache/activemq/broker/AMQ4351Test.java | 260 +++ .../apache/activemq/broker/BrokerBenchmark.java | 193 ++ .../activemq/broker/BrokerRedeliveryTest.java | 185 ++ .../broker/BrokerRestartTestSupport.java | 67 + .../activemq/broker/BrokerServiceTest.java | 84 + .../org/apache/activemq/broker/BrokerTest.java | 1759 ++++++++++++++++++ .../activemq/broker/BrokerTestSupport.java | 357 ++++ .../broker/ConcurrentConnectSimulationTest.java | 59 + ...CreateDestinationsOnStartupViaXBeanTest.java | 69 + .../broker/DedicatedTaskRunnerBrokerTest.java | 37 + .../activemq/broker/DoubleSubscriptionTest.java | 118 ++ .../DurablePersistentFalseRestartTest.java | 90 + .../broker/JdbcXARecoveryBrokerTest.java | 89 + .../java/org/apache/activemq/broker/Main.java | 86 + .../activemq/broker/MarshallingBrokerTest.java | 75 + .../activemq/broker/MessageExpirationTest.java | 274 +++ .../broker/NioQueueSubscriptionTest.java | 134 ++ .../activemq/broker/OutOfOrderXMLTest.java | 33 + .../apache/activemq/broker/ProgressPrinter.java | 43 + .../activemq/broker/QueueMbeanRestartTest.java | 123 ++ .../activemq/broker/QueueSubscriptionTest.java | 188 ++ .../broker/ReconnectWithJMXEnabledTest.java | 92 + .../activemq/broker/RecoveryBrokerTest.java | 586 ++++++ .../activemq/broker/RedeliveryRestartTest.java | 297 +++ .../RedeliveryRestartWithExceptionTest.java | 472 +++++ .../org/apache/activemq/broker/SpringTest.java | 105 ++ .../org/apache/activemq/broker/StubBroker.java | 57 + .../apache/activemq/broker/StubConnection.java | 164 ++ .../activemq/broker/TopicSubscriptionTest.java | 160 ++ .../activemq/broker/XARecoveryBrokerTest.java | 1246 +++++++++++++ .../broker/advisory/AdvisoryBrokerTest.java | 330 ++++ .../AdvisoryDuplexNetworkBridgeTest.java | 47 + .../broker/advisory/AdvisoryJmxTest.java | 86 + .../advisory/AdvisoryNetworkBridgeTest.java | 128 ++ .../activemq/broker/destinations-on-start.xml | 39 + .../exclusive-consumer-startup-destination.xml | 46 + ...artJDBCQueueMasterSlaveLeaseQuiesceTest.java | 80 + .../DbRestartJDBCQueueMasterSlaveLeaseTest.java | 57 + .../ft/DbRestartJDBCQueueMasterSlaveTest.java | 149 ++ .../broker/ft/DbRestartJDBCQueueTest.java | 158 ++ .../broker/ft/JDBCQueueMasterSlaveTest.java | 112 ++ .../ft/QueueMasterSlaveSingleUrlTest.java | 95 + .../broker/ft/QueueMasterSlaveTestSupport.java | 156 ++ ...QueueMasterSlaveTestUsingSharedFileTest.java | 44 + .../broker/ft/SyncCreateDataSource.java | 86 + .../ft/kahaDbJdbcLeaseQueueMasterSlaveTest.java | 114 ++ .../broker/ft/mKahaDbQueueMasterSlaveTest.java | 89 + .../activemq/broker/ft/sharedFileMaster.xml | 34 + .../activemq/broker/ft/sharedFileSlave.xml | 35 + .../jmx/BrokerViewSlowStoreStartupTest.java | 356 ++++ .../broker/jmx/HealthViewMBeanTest.java | 117 ++ .../activemq/broker/jmx/Log4JConfigTest.java | 200 ++ .../broker/jmx/MBeanOperationTimeoutTest.java | 131 ++ .../apache/activemq/broker/jmx/MBeanTest.java | 1508 +++++++++++++++ .../apache/activemq/broker/jmx/PurgeTest.java | 250 +++ .../broker/jmx/TransportConnectorMBeanTest.java | 140 ++ .../broker/mKahaDBXARecoveryBrokerTest.java | 62 + .../broker/mLevelDBXARecoveryBrokerTest.java | 69 + .../security/MessageAuthenticationTest.java | 99 + .../broker/out-of-order-broker-elements.xml | 50 + .../partition/SpringPartitionBrokerTest.java | 53 + .../policy/AbortSlowAckConsumer0Test.java | 178 ++ .../policy/AbortSlowAckConsumer1Test.java | 71 + .../policy/AbortSlowAckConsumer2Test.java | 71 + .../broker/policy/AbortSlowConsumer0Test.java | 244 +++ .../broker/policy/AbortSlowConsumer1Test.java | 104 ++ .../broker/policy/AbortSlowConsumer2Test.java | 53 + .../broker/policy/AbortSlowConsumerBase.java | 96 + .../activemq/broker/policy/DeadLetterTest.java | 94 + .../broker/policy/DeadLetterTestSupport.java | 211 +++ .../policy/DestinationCursorConfigTest.java | 74 + .../policy/DiscardingDeadLetterPolicyTest.java | 77 + .../broker/policy/IndividualDeadLetterTest.java | 109 ++ .../policy/IndividualDeadLetterViaXmlTest.java | 48 + .../broker/policy/MessageGroupConfigTest.java | 93 + .../policy/MessageListenerDeadLetterTest.java | 151 ++ .../broker/policy/NoConsumerDeadLetterTest.java | 112 ++ .../broker/policy/NoRetryDeadLetterTest.java | 33 + .../PerDurableConsumerDeadLetterTest.java | 70 + .../PriorityNetworkDispatchPolicyTest.java | 81 + .../policy/RoundRobinDispatchPolicyTest.java | 125 ++ .../activemq/broker/policy/SecureDLQTest.java | 128 ++ .../broker/policy/SimpleDispatchPolicyTest.java | 91 + .../policy/StrictOrderDispatchPolicyTest.java | 133 ++ .../apache/activemq/broker/policy/cursor.xml | 67 + .../activemq/broker/policy/individual-dlq.xml | 60 + .../broker/region/DestinationGCTest.java | 113 ++ .../region/DestinationRemoveRestartTest.java | 117 ++ .../region/QueueDuplicatesFromStoreTest.java | 407 ++++ .../QueueOptimizedDispatchExceptionTest.java | 255 +++ .../activemq/broker/region/QueuePurgeTest.java | 216 +++ .../region/QueueResendDuringShutdownTest.java | 250 +++ .../region/SubscriptionAddRemoveQueueTest.java | 374 ++++ ...iquePropertyMessageEvictionStrategyTest.java | 105 ++ .../region/cursors/CursorDurableTest.java | 57 + .../region/cursors/CursorQueueStoreTest.java | 75 + .../broker/region/cursors/CursorSupport.java | 198 ++ .../FilePendingMessageCursorTestSupport.java | 89 + .../region/cursors/NegativeQueueTest.java | 421 +++++ .../region/cursors/OrderPendingListTest.java | 444 +++++ .../cursors/PrioritizedPendingListTest.java | 303 +++ .../region/cursors/StoreBasedCursorTest.java | 160 ++ .../StoreQueueCursorJDBCNoDuplicateTest.java | 37 + .../StoreQueueCursorKahaDBNoDuplicateTest.java | 40 + .../StoreQueueCursorLevelDBNoDuplicateTest.java | 40 + .../StoreQueueCursorMemoryNoDuplicateTest.java | 33 + .../StoreQueueCursorNoDuplicateTest.java | 133 ++ .../cursors/StoreQueueCursorOrderTest.java | 517 +++++ .../group/MessageGroupHashBucketTest.java | 30 + .../region/group/MessageGroupMapTest.java | 104 ++ .../broker/region/group/MessageGroupTest.java | 181 ++ .../broker/scheduler/JmsCronSchedulerTest.java | 118 ++ .../broker/scheduler/JmsSchedulerTest.java | 288 +++ .../JobSchedulerBrokerShutdownTest.java | 78 + .../JobSchedulerJmxManagementTests.java | 155 ++ .../scheduler/JobSchedulerManagementTest.java | 409 ++++ .../JobSchedulerStoreCheckpointTest.java | 125 ++ .../broker/scheduler/JobSchedulerStoreTest.java | 77 + .../broker/scheduler/JobSchedulerTest.java | 297 +++ .../scheduler/JobSchedulerTestSupport.java | 116 ++ .../broker/scheduler/JobSchedulerTxTest.java | 107 ++ .../KahaDBSchedulerIndexRebuildTest.java | 195 ++ .../KahaDBSchedulerMissingJournalLogsTest.java | 204 ++ .../scheduler/LostScheduledMessagesTest.java | 153 ++ .../scheduler/SchedulerDBVersionTest.java | 164 ++ .../memory/InMemeoryJmsSchedulerTest.java | 40 + .../memory/InMemoryJmsCronSchedulerTest.java | 30 + .../InMemoryJobSchedulerJmxManagementTests.java | 30 + .../InMemoryJobSchedulerManagementTest.java | 30 + .../memory/InMemoryJobSchedulerStoreTest.java | 74 + .../memory/InMemoryJobSchedulerTest.java | 36 + .../memory/InMemoryJobSchedulerTxTest.java | 30 + .../java/org/apache/activemq/broker/spring.xml | 97 + .../broker/store/DefaultStoreBrokerTest.java | 50 + .../store/DefaultStoreRecoveryBrokerTest.java | 50 + .../activemq/broker/store/LoadTester.java | 110 ++ .../store/RecoverExpiredMessagesTest.java | 144 ++ .../apache/activemq/broker/store/kahabroker.xml | 38 + .../apache/activemq/broker/store/loadtester.xml | 61 + .../broker/util/DestinationsPluginTest.java | 80 + .../activemq/broker/util/PluginBrokerTest.java | 88 + .../broker/util/RedeliveryPluginTest.java | 73 + .../util/TimeStampingBrokerPluginTest.java | 197 ++ .../broker/util/TraceBrokerPathPluginTest.java | 129 ++ .../broker/virtual/CompositeQueueTest.java | 132 ++ .../broker/virtual/CompositeTopicTest.java | 45 + .../DestinationInterceptorDurableSubTest.java | 282 +++ .../broker/virtual/FilteredQueueTest.java | 36 + .../MirroredQueueCorrectMemoryUsageTest.java | 165 ++ .../broker/virtual/MirroredQueueTest.java | 116 ++ ...MirroredQueueUsingVirtualTopicQueueTest.java | 34 + .../broker/virtual/VirtualDestPerfTest.java | 209 +++ .../broker/virtual/VirtualTopicDLQTest.java | 415 +++++ .../VirtualTopicDisconnectSelectorTest.java | 185 ++ .../broker/virtual/VirtualTopicPubSubTest.java | 129 ++ .../VirtualTopicPubSubUsingXBeanTest.java | 52 + .../virtual/VirtualTopicSelectorTest.java | 105 ++ .../VirtualTopicsAndDurableSubsTest.java | 103 + .../activemq/broker/virtual/composite-queue.xml | 47 + .../activemq/broker/virtual/composite-topic.xml | 47 + .../broker/virtual/disconnected-selector.xml | 43 + .../activemq/broker/virtual/filtered-queue.xml | 47 + .../broker/virtual/global-virtual-topics.xml | 42 + .../broker/virtual/virtual-individual-dlq.xml | 80 + .../virtual/virtual-topics-and-interceptor.xml | 50 + .../java/org/apache/activemq/bugs/AMQ1282.java | 188 ++ .../org/apache/activemq/bugs/AMQ1687Test.java | 104 ++ .../org/apache/activemq/bugs/AMQ1853Test.java | 368 ++++ .../java/org/apache/activemq/bugs/AMQ1866.java | 224 +++ .../org/apache/activemq/bugs/AMQ1893Test.java | 196 ++ .../org/apache/activemq/bugs/AMQ1917Test.java | 228 +++ .../org/apache/activemq/bugs/AMQ1936Test.java | 310 +++ .../org/apache/activemq/bugs/AMQ2021Test.java | 267 +++ .../org/apache/activemq/bugs/AMQ2084Test.java | 181 ++ .../org/apache/activemq/bugs/AMQ2103Test.java | 129 ++ .../activemq/bugs/AMQ2149LevelDBTest.java | 30 + .../org/apache/activemq/bugs/AMQ2149Test.java | 584 ++++++ .../org/apache/activemq/bugs/AMQ2171Test.java | 146 ++ .../org/apache/activemq/bugs/AMQ2200Test.java | 100 + .../org/apache/activemq/bugs/AMQ2213Test.java | 104 ++ .../org/apache/activemq/bugs/AMQ2314Test.java | 175 ++ .../org/apache/activemq/bugs/AMQ2356Test.java | 190 ++ .../org/apache/activemq/bugs/AMQ2364Test.java | 113 ++ .../org/apache/activemq/bugs/AMQ2383Test.java | 63 + .../org/apache/activemq/bugs/AMQ2401Test.java | 237 +++ .../org/apache/activemq/bugs/AMQ2413Test.java | 346 ++++ .../org/apache/activemq/bugs/AMQ2439Test.java | 92 + .../org/apache/activemq/bugs/AMQ2489Test.java | 226 +++ .../org/apache/activemq/bugs/AMQ2512Test.java | 174 ++ .../org/apache/activemq/bugs/AMQ2513Test.java | 107 ++ .../org/apache/activemq/bugs/AMQ2528Test.java | 81 + .../org/apache/activemq/bugs/AMQ2571Test.java | 110 ++ .../org/apache/activemq/bugs/AMQ2580Test.java | 201 ++ .../activemq/bugs/AMQ2584ConcurrentDlqTest.java | 266 +++ .../org/apache/activemq/bugs/AMQ2584Test.java | 233 +++ .../org/apache/activemq/bugs/AMQ2585Test.java | 83 + .../org/apache/activemq/bugs/AMQ2616Test.java | 116 ++ .../org/apache/activemq/bugs/AMQ2645Test.java | 109 ++ .../org/apache/activemq/bugs/AMQ2736Test.java | 96 + .../org/apache/activemq/bugs/AMQ2751Test.java | 94 + .../org/apache/activemq/bugs/AMQ2801Test.java | 201 ++ .../org/apache/activemq/bugs/AMQ2832Test.java | 380 ++++ .../org/apache/activemq/bugs/AMQ2870Test.java | 230 +++ .../org/apache/activemq/bugs/AMQ2902Test.java | 98 + .../org/apache/activemq/bugs/AMQ2910Test.java | 129 ++ .../org/apache/activemq/bugs/AMQ2982Test.java | 182 ++ .../org/apache/activemq/bugs/AMQ2983Test.java | 162 ++ .../org/apache/activemq/bugs/AMQ3014Test.java | 208 +++ .../org/apache/activemq/bugs/AMQ3120Test.java | 148 ++ .../org/apache/activemq/bugs/AMQ3140Test.java | 145 ++ .../org/apache/activemq/bugs/AMQ3141Test.java | 117 ++ .../org/apache/activemq/bugs/AMQ3145Test.java | 133 ++ .../org/apache/activemq/bugs/AMQ3157Test.java | 175 ++ .../org/apache/activemq/bugs/AMQ3167Test.java | 462 +++++ .../org/apache/activemq/bugs/AMQ3274Test.java | 734 ++++++++ .../org/apache/activemq/bugs/AMQ3324Test.java | 148 ++ .../org/apache/activemq/bugs/AMQ3352Test.java | 75 + .../org/apache/activemq/bugs/AMQ3405Test.java | 280 +++ .../org/apache/activemq/bugs/AMQ3436Test.java | 202 ++ .../org/apache/activemq/bugs/AMQ3445Test.java | 150 ++ .../org/apache/activemq/bugs/AMQ3454Test.java | 74 + .../org/apache/activemq/bugs/AMQ3465Test.java | 195 ++ .../org/apache/activemq/bugs/AMQ3529Test.java | 177 ++ .../org/apache/activemq/bugs/AMQ3537Test.java | 104 ++ .../org/apache/activemq/bugs/AMQ3567Test.java | 208 +++ .../org/apache/activemq/bugs/AMQ3622Test.java | 109 ++ .../org/apache/activemq/bugs/AMQ3625Test.java | 111 ++ .../org/apache/activemq/bugs/AMQ3674Test.java | 120 ++ .../org/apache/activemq/bugs/AMQ3675Test.java | 161 ++ .../org/apache/activemq/bugs/AMQ3678Test.java | 220 +++ .../org/apache/activemq/bugs/AMQ3732Test.java | 174 ++ .../org/apache/activemq/bugs/AMQ3779Test.java | 76 + .../org/apache/activemq/bugs/AMQ3841Test.java | 120 ++ .../org/apache/activemq/bugs/AMQ3879Test.java | 112 ++ .../org/apache/activemq/bugs/AMQ3903Test.java | 141 ++ .../org/apache/activemq/bugs/AMQ3932Test.java | 158 ++ .../org/apache/activemq/bugs/AMQ3934Test.java | 105 ++ .../org/apache/activemq/bugs/AMQ3961Test.java | 185 ++ .../org/apache/activemq/bugs/AMQ3992Test.java | 107 ++ .../org/apache/activemq/bugs/AMQ4062Test.java | 276 +++ .../org/apache/activemq/bugs/AMQ4083Test.java | 508 +++++ .../org/apache/activemq/bugs/AMQ4092Test.java | 238 +++ .../org/apache/activemq/bugs/AMQ4116Test.java | 111 ++ .../org/apache/activemq/bugs/AMQ4126Test.java | 180 ++ .../org/apache/activemq/bugs/AMQ4133Test.java | 107 ++ .../org/apache/activemq/bugs/AMQ4147Test.java | 211 +++ .../org/apache/activemq/bugs/AMQ4148Test.java | 95 + .../org/apache/activemq/bugs/AMQ4157Test.java | 175 ++ .../org/apache/activemq/bugs/AMQ4160Test.java | 393 ++++ .../org/apache/activemq/bugs/AMQ4212Test.java | 358 ++++ .../org/apache/activemq/bugs/AMQ4213Test.java | 89 + .../org/apache/activemq/bugs/AMQ4220Test.java | 120 ++ .../org/apache/activemq/bugs/AMQ4221Test.java | 267 +++ .../org/apache/activemq/bugs/AMQ4222Test.java | 188 ++ .../org/apache/activemq/bugs/AMQ4323Test.java | 161 ++ .../org/apache/activemq/bugs/AMQ4356Test.java | 142 ++ .../org/apache/activemq/bugs/AMQ4361Test.java | 157 ++ .../org/apache/activemq/bugs/AMQ4368Test.java | 248 +++ .../org/apache/activemq/bugs/AMQ4407Test.java | 177 ++ .../org/apache/activemq/bugs/AMQ4413Test.java | 240 +++ .../org/apache/activemq/bugs/AMQ4469Test.java | 114 ++ .../org/apache/activemq/bugs/AMQ4472Test.java | 91 + .../org/apache/activemq/bugs/AMQ4475Test.java | 344 ++++ .../bugs/AMQ4485LowLimitLevelDBTest.java | 38 + .../activemq/bugs/AMQ4485LowLimitTest.java | 466 +++++ ...XBrokersWithNDestsFanoutTransactionTest.java | 353 ++++ .../org/apache/activemq/bugs/AMQ4485Test.java | 197 ++ .../org/apache/activemq/bugs/AMQ4487Test.java | 135 ++ .../org/apache/activemq/bugs/AMQ4504Test.java | 82 + .../org/apache/activemq/bugs/AMQ4513Test.java | 142 ++ .../org/apache/activemq/bugs/AMQ4517Test.java | 128 ++ .../org/apache/activemq/bugs/AMQ4518Test.java | 128 ++ .../org/apache/activemq/bugs/AMQ4530Test.java | 116 ++ .../org/apache/activemq/bugs/AMQ4531Test.java | 144 ++ .../org/apache/activemq/bugs/AMQ4554Test.java | 107 ++ .../org/apache/activemq/bugs/AMQ4582Test.java | 91 + .../org/apache/activemq/bugs/AMQ4595Test.java | 158 ++ .../org/apache/activemq/bugs/AMQ4607Test.java | 246 +++ .../org/apache/activemq/bugs/AMQ4636Test.java | 267 +++ .../org/apache/activemq/bugs/AMQ4656Test.java | 153 ++ .../org/apache/activemq/bugs/AMQ4671Test.java | 81 + .../org/apache/activemq/bugs/AMQ4677Test.java | 184 ++ .../org/apache/activemq/bugs/AMQ4853Test.java | 300 +++ .../org/apache/activemq/bugs/AMQ4887Test.java | 165 ++ .../org/apache/activemq/bugs/AMQ4893Test.java | 86 + .../org/apache/activemq/bugs/AMQ4899Test.java | 192 ++ .../org/apache/activemq/bugs/AMQ4930Test.java | 144 ++ .../org/apache/activemq/bugs/AMQ4950Test.java | 195 ++ .../org/apache/activemq/bugs/AMQ4952Test.java | 505 +++++ .../org/apache/activemq/bugs/AMQ5035Test.java | 83 + .../org/apache/activemq/bugs/AMQ5136Test.java | 95 + .../org/apache/activemq/bugs/AMQ5212Test.java | 225 +++ .../activemq/bugs/AMQ5266SingleDestTest.java | 602 ++++++ .../bugs/AMQ5266StarvedConsumerTest.java | 620 ++++++ .../org/apache/activemq/bugs/AMQ5266Test.java | 601 ++++++ .../org/apache/activemq/bugs/AMQ5274Test.java | 133 ++ .../org/apache/activemq/bugs/AMQ5381Test.java | 182 ++ .../org/apache/activemq/bugs/AMQ5421Test.java | 119 ++ .../org/apache/activemq/bugs/AMQ5450Test.java | 194 ++ .../org/apache/activemq/bugs/AMQ5567Test.java | 228 +++ .../bugs/ActiveMQSlowConsumerManualTest.java | 232 +++ .../activemq/bugs/ConnectionPerMessageTest.java | 104 ++ .../org/apache/activemq/bugs/CraigsBugTest.java | 67 + .../apache/activemq/bugs/DoubleExpireTest.java | 145 ++ .../activemq/bugs/DurableConsumerTest.java | 463 +++++ .../bugs/JMSDurableTopicNoLocalTest.java | 83 + .../bugs/JmsDurableTopicSlowReceiveTest.java | 180 ++ .../apache/activemq/bugs/JmsTimeoutTest.java | 158 ++ .../bugs/MemoryUsageBlockResumeTest.java | 224 +++ .../activemq/bugs/MemoryUsageBrokerTest.java | 90 + .../activemq/bugs/MemoryUsageCleanupTest.java | 255 +++ .../bugs/MessageExpirationReaperTest.java | 185 ++ .../org/apache/activemq/bugs/MessageSender.java | 45 + .../activemq/bugs/MissingDataFileTest.java | 323 ++++ .../OptimizeAcknowledgeWithExpiredMsgsTest.java | 312 ++++ .../activemq/bugs/OutOfOrderTestCase.java | 131 ++ .../activemq/bugs/QueueWorkerPrefetchTest.java | 248 +++ .../bugs/RawRollbackSharedConsumerTests.java | 134 ++ .../apache/activemq/bugs/RawRollbackTests.java | 135 ++ .../java/org/apache/activemq/bugs/Receiver.java | 21 + .../bugs/RedeliveryPluginHeaderTest.java | 167 ++ .../apache/activemq/bugs/SlowConsumerTest.java | 159 ++ ...ReplayAfterStoreCleanupLevelDBStoreTest.java | 30 + .../bugs/TempQueueDeleteOnCloseTest.java | 54 + .../bugs/TempStorageBlockedBrokerTest.java | 266 +++ .../bugs/TempStorageConfigBrokerTest.java | 220 +++ .../activemq/bugs/TempStoreDataCleanupTest.java | 261 +++ .../TransactedStoreUsageSuspendResumeTest.java | 193 ++ .../bugs/TransactionNotStartedErrorTest.java | 284 +++ .../bugs/TrapMessageInJDBCStoreTest.java | 291 +++ .../activemq/bugs/VMTransportClosureTest.java | 131 ++ .../activemq/bugs/VerifySteadyEnqueueRate.java | 153 ++ .../activemq/bugs/amq1095/ActiveMQTestCase.java | 166 ++ .../bugs/amq1095/MessageSelectorTest.java | 227 +++ .../apache/activemq/bugs/amq1095/activemq.xml | 39 + .../activemq/bugs/amq1974/TryJmsClient.java | 150 ++ .../activemq/bugs/amq1974/TryJmsManager.java | 124 ++ .../bugs/amq3625/conf/JaasStompSSLBroker1.xml | 65 + .../bugs/amq3625/conf/JaasStompSSLBroker2.xml | 39 + .../bugs/amq3625/conf/groups2.properties | 20 + .../activemq/bugs/amq3625/conf/login.config | 22 + .../bugs/amq3625/conf/users2.properties | 23 + .../activemq/bugs/amq3625/keys/broker2.ks | 0 .../activemq/bugs/amq3625/keys/client2.ks | 0 .../activemq/bugs/amq3625/keys/client2.ts | 0 ...InconsistentConnectorPropertiesBehaviour.xml | 46 + .../bugs/amq4126/JaasStompSSLBroker.xml | 46 + .../apache/activemq/bugs/amq4126/dns.properties | 17 + .../activemq/bugs/amq4126/groups.properties | 18 + .../apache/activemq/bugs/amq4126/login.config | 30 + .../activemq/bugs/amq4126/users.properties | 18 + .../apache/activemq/bugs/amq5035/activemq.xml | 109 ++ .../bugs/embedded/EmbeddedActiveMQ.java | 114 ++ .../activemq/bugs/embedded/ThreadExplorer.java | 168 ++ .../command/ActiveMQBytesMessageTest.java | 488 +++++ .../command/ActiveMQDestinationTest.java | 145 ++ .../command/ActiveMQMapMessageTest.java | 492 +++++ .../activemq/command/ActiveMQMessageTest.java | 992 ++++++++++ .../command/ActiveMQObjectMessageTest.java | 126 ++ .../command/ActiveMQStreamMessageTest.java | 1000 ++++++++++ .../command/ActiveMQTextMessageTest.java | 159 ++ .../command/DataStructureTestSupport.java | 158 ++ .../command/MessageCompressionTest.java | 143 ++ .../activemq/command/MessageSendTest.java | 78 + .../apache/activemq/command/MessageTest.java | 100 + .../activemq/config/BrokerPropertiesTest.java | 60 + .../config/BrokerXmlConfigFromJNDITest.java | 53 + .../activemq/config/BrokerXmlConfigTest.java | 48 + .../org/apache/activemq/config/ConfigTest.java | 457 +++++ .../config/ConfigUsingDestinationOptions.java | 72 + .../apache/activemq/config/JDBCConfigTest.java | 102 + .../apache/activemq/config/broker.properties | 21 + .../java/org/apache/activemq/config/config.xml | 31 + .../java/org/apache/activemq/config/example.xml | 104 ++ .../config/sample-conf/connector-properties.xml | 37 + .../config/sample-conf/jdbc-example.xml | 52 + .../config/sample-conf/journal-example.xml | 60 + .../sample-conf/journaledjdbc-example.xml | 36 + .../config/sample-conf/memory-example.xml | 37 + .../org/apache/activemq/config/spring-test.xml | 35 + .../activemq/console/command/AMQ3410Test.java | 186 ++ .../activemq/console/command/AMQ3411Test.java | 197 ++ .../console/command/DummyConnectionFactory.java | 44 + .../command/InvalidConnectionFactory.java | 23 + .../command/LowercasingPasswordFactory.java | 25 + .../console/command/PurgeCommandTest.java | 464 +++++ .../activemq/console/command/activemq.xml | 77 + .../activemq/conversions/AmqpAndMqttTest.java | 120 ++ .../activemq/demo/DefaultQueueSender.java | 111 ++ .../apache/activemq/demo/SimpleConsumer.java | 130 ++ .../apache/activemq/demo/SimpleProducer.java | 139 ++ .../activemq/demo/SimpleQueueReceiver.java | 130 ++ .../apache/activemq/demo/SimpleQueueSender.java | 137 ++ .../activemq/filter/DestinationFilterTest.java | 65 + .../filter/DestinationMapMemoryTest.java | 52 + .../DestinationMapTempDestinationTest.java | 45 + .../activemq/filter/DestinationMapTest.java | 414 +++++ .../activemq/filter/DestinationPathTest.java | 36 + .../org/apache/activemq/filter/DummyPolicy.java | 40 + .../activemq/filter/DummyPolicyEntry.java | 44 + .../apache/activemq/filter/DummyPolicyTest.java | 44 + .../org/apache/activemq/filter/dummyPolicy.xml | 37 + .../apache/activemq/jmx/JmxCreateNCTest.java | 67 + .../activemq/jmx/OpenTypeSupportTest.java | 115 ++ .../jndi/ActiveMQInitialContextFactoryTest.java | 75 + .../ActiveMQWASInitialContextFactoryTest.java | 43 + .../jndi/CustomConnectionFactoryNameTest.java | 56 + .../jndi/DestinationNameWithSlashTest.java | 36 + .../activemq/jndi/InitialContextTest.java | 97 + .../apache/activemq/jndi/JNDITestSupport.java | 103 + .../apache/activemq/jndi/ObjectFactoryTest.java | 89 + .../activemq/jndi/XAConnectionFactoryTest.java | 32 + .../activemq/joramtests/ActiveMQAdmin.java | 150 ++ .../activemq/joramtests/JoramJmsTest.java | 74 + .../leveldb/LevelDBStoreBrokerTest.java | 62 + .../leveldb/LevelDBXARecoveryBrokerTest.java | 68 + .../org/apache/activemq/load/LoadClient.java | 233 +++ .../apache/activemq/load/LoadController.java | 103 + .../java/org/apache/activemq/load/LoadTest.java | 155 ++ .../management/BoundaryStatisticTest.java | 38 + .../management/BoundedRangeStatisticTest.java | 38 + .../activemq/management/CountStatisticTest.java | 57 + .../activemq/management/RangeStatisticTest.java | 78 + .../management/StatisticTestSupport.java | 47 + .../activemq/management/TimeStatisticTest.java | 75 + .../activemq/memory/MemoryPropertyTest.java | 75 + .../org/apache/activemq/memory/activemq.xml | 51 + .../activemq/memory/buffer/DummyMessage.java | 43 + .../memory/buffer/MemoryBufferTestSupport.java | 67 + .../buffer/OrderBasedMemoryBufferTest.java | 74 + .../buffer/SizeBasedMessageBufferTest.java | 57 + .../org/apache/activemq/memory/usage.properties | 19 + .../BrokerNetworkWithStuckMessagesTest.java | 629 +++++++ .../CheckDuplicateMessagesOnDuplexTest.java | 356 ++++ .../network/CompressionOverNetworkTest.java | 330 ++++ .../DemandForwardingBridgeFilterTest.java | 211 +++ .../network/DemandForwardingBridgeTest.java | 177 ++ .../network/DuplexNetworkMBeanTest.java | 171 ++ .../activemq/network/DuplexNetworkTest.java | 60 + ...lyIncludedDestinationsDuplexNetworkTest.java | 117 ++ .../network/FailoverStaticNetworkTest.java | 467 +++++ .../activemq/network/ForwardingBridgeTest.java | 154 ++ .../MQTTNetworkOfBrokersFailoverTest.java | 254 +++ .../activemq/network/MulticastNetworkTest.java | 38 + .../network/NetworkBrokerDetachTest.java | 305 +++ .../network/NetworkConnectionsTest.java | 245 +++ .../network/NetworkDestinationFilterTest.java | 45 + .../activemq/network/NetworkFailoverTest.java | 232 +++ .../activemq/network/NetworkLoadTest.java | 336 ++++ .../activemq/network/NetworkLoopBackTest.java | 65 + .../activemq/network/NetworkReconnectTest.java | 326 ++++ .../NetworkRemovesSubscriptionsTest.java | 190 ++ .../network/NetworkRestartPlainTest.java | 24 + .../activemq/network/NetworkRestartTest.java | 187 ++ .../activemq/network/NetworkRouteTest.java | 346 ++++ .../activemq/network/NetworkTestSupport.java | 179 ++ .../network/SSHTunnelNetworkReconnectTest.java | 94 + .../activemq/network/SimpleNetworkTest.java | 322 ++++ .../duplexDynamicIncludedDestLocalBroker.xml | 54 + .../activemq/network/duplexLocalBroker.xml | 49 + .../jms/QueueBridgeStandaloneReconnectTest.java | 370 ++++ .../activemq/network/jms/QueueBridgeTest.java | 111 ++ .../network/jms/QueueBridgeXBeanTest.java | 45 + .../jms/QueueOutboundBridgeReconnectTest.java | 345 ++++ .../network/jms/TopicBridgeSpringTest.java | 106 ++ .../jms/TopicBridgeStandaloneReconnectTest.java | 367 ++++ .../network/jms/TopicBridgeXBeanTest.java | 32 + .../jms/TopicOutboundBridgeReconnectTest.java | 332 ++++ .../activemq/network/jms/queue-config.xml | 85 + .../apache/activemq/network/jms/queue-xbean.xml | 72 + .../activemq/network/jms/topic-config.xml | 85 + .../activemq/network/jms/topic-spring.xml | 85 + .../activemq/network/localBroker-plain.xml | 36 + .../org/apache/activemq/network/localBroker.xml | 50 + .../activemq/network/multicast/localBroker.xml | 42 + .../activemq/network/multicast/remoteBroker.xml | 43 + .../activemq/network/reconnect-broker1.xml | 52 + .../activemq/network/reconnect-broker2.xml | 53 + .../apache/activemq/network/remoteBroker.xml | 38 + .../activemq/network/ssh-reconnect-broker1.xml | 53 + .../activemq/network/ssh-reconnect-broker2.xml | 54 + .../activemq/openwire/BooleanStreamTest.java | 149 ++ .../activemq/openwire/BrokerInfoData.java | 35 + .../activemq/openwire/DataFileGenerator.java | 141 ++ .../openwire/DataFileGeneratorTestSupport.java | 330 ++++ .../openwire/ItStillMarshallsTheSameTest.java | 27 + .../NumberRangesWhileMarshallingTest.java | 145 ++ .../activemq/openwire/WireFormatInfoData.java | 33 + .../openwire/v1/ActiveMQBytesMessageTest.java | 46 + .../v1/ActiveMQDestinationTestSupport.java | 40 + .../openwire/v1/ActiveMQMapMessageTest.java | 46 + .../openwire/v1/ActiveMQMessageTest.java | 46 + .../openwire/v1/ActiveMQObjectMessageTest.java | 46 + .../activemq/openwire/v1/ActiveMQQueueTest.java | 44 + .../openwire/v1/ActiveMQStreamMessageTest.java | 44 + .../v1/ActiveMQTempDestinationTestSupport.java | 36 + .../openwire/v1/ActiveMQTempQueueTest.java | 44 + .../openwire/v1/ActiveMQTempTopicTest.java | 44 + .../openwire/v1/ActiveMQTextMessageTest.java | 44 + .../activemq/openwire/v1/ActiveMQTopicTest.java | 44 + .../openwire/v1/BaseCommandTestSupport.java | 39 + .../activemq/openwire/v1/BrokerIdTest.java | 48 + .../activemq/openwire/v1/BrokerInfoTest.java | 58 + .../openwire/v1/ConnectionControlTest.java | 51 + .../openwire/v1/ConnectionErrorTest.java | 48 + .../activemq/openwire/v1/ConnectionIdTest.java | 48 + .../openwire/v1/ConnectionInfoTest.java | 59 + .../openwire/v1/ConsumerControlTest.java | 49 + .../activemq/openwire/v1/ConsumerIdTest.java | 50 + .../activemq/openwire/v1/ConsumerInfoTest.java | 69 + .../openwire/v1/ControlCommandTest.java | 47 + .../openwire/v1/DataArrayResponseTest.java | 53 + .../activemq/openwire/v1/DataResponseTest.java | 47 + .../openwire/v1/DestinationInfoTest.java | 57 + .../openwire/v1/DiscoveryEventTest.java | 49 + .../openwire/v1/ExceptionResponseTest.java | 47 + .../activemq/openwire/v1/FlushCommandTest.java | 46 + .../openwire/v1/IntegerResponseTest.java | 47 + .../openwire/v1/JournalQueueAckTest.java | 49 + .../openwire/v1/JournalTopicAckTest.java | 53 + .../activemq/openwire/v1/JournalTraceTest.java | 48 + .../openwire/v1/JournalTransactionTest.java | 50 + .../activemq/openwire/v1/KeepAliveInfoTest.java | 46 + .../openwire/v1/LastPartialCommandTest.java | 46 + .../openwire/v1/LocalTransactionIdTest.java | 48 + .../activemq/openwire/v1/MessageAckTest.java | 53 + .../v1/MessageDispatchNotificationTest.java | 50 + .../openwire/v1/MessageDispatchTest.java | 50 + .../activemq/openwire/v1/MessageIdTest.java | 50 + .../openwire/v1/MessageTestSupport.java | 92 + .../openwire/v1/NetworkBridgeFilterTest.java | 49 + .../openwire/v1/PartialCommandTest.java | 49 + .../activemq/openwire/v1/ProducerIdTest.java | 50 + .../activemq/openwire/v1/ProducerInfoTest.java | 55 + .../activemq/openwire/v1/RemoveInfoTest.java | 47 + .../openwire/v1/RemoveSubscriptionInfoTest.java | 49 + .../activemq/openwire/v1/ReplayCommandTest.java | 48 + .../activemq/openwire/v1/ResponseTest.java | 47 + .../activemq/openwire/v1/SessionIdTest.java | 49 + .../activemq/openwire/v1/SessionInfoTest.java | 47 + .../activemq/openwire/v1/ShutdownInfoTest.java | 46 + .../openwire/v1/SubscriptionInfoTest.java | 51 + .../openwire/v1/TransactionIdTestSupport.java | 39 + .../openwire/v1/TransactionInfoTest.java | 49 + .../openwire/v1/WireFormatInfoTest.java | 51 + .../openwire/v1/XATransactionIdTest.java | 49 + .../openwire/v2/ActiveMQBytesMessageTest.java | 46 + .../v2/ActiveMQDestinationTestSupport.java | 40 + .../openwire/v2/ActiveMQMapMessageTest.java | 45 + .../openwire/v2/ActiveMQMessageTest.java | 46 + .../openwire/v2/ActiveMQObjectMessageTest.java | 46 + .../activemq/openwire/v2/ActiveMQQueueTest.java | 46 + .../openwire/v2/ActiveMQStreamMessageTest.java | 46 + .../v2/ActiveMQTempDestinationTestSupport.java | 38 + .../openwire/v2/ActiveMQTempQueueTest.java | 46 + .../openwire/v2/ActiveMQTempTopicTest.java | 46 + .../openwire/v2/ActiveMQTextMessageTest.java | 46 + .../activemq/openwire/v2/ActiveMQTopicTest.java | 46 + .../openwire/v2/BaseCommandTestSupport.java | 39 + .../activemq/openwire/v2/BrokerIdTest.java | 51 + .../activemq/openwire/v2/BrokerInfoTest.java | 60 + .../openwire/v2/ConnectionControlTest.java | 54 + .../openwire/v2/ConnectionErrorTest.java | 51 + .../activemq/openwire/v2/ConnectionIdTest.java | 51 + .../openwire/v2/ConnectionInfoTest.java | 59 + .../openwire/v2/ConsumerControlTest.java | 55 + .../activemq/openwire/v2/ConsumerIdTest.java | 53 + .../activemq/openwire/v2/ConsumerInfoTest.java | 68 + .../openwire/v2/ControlCommandTest.java | 50 + .../openwire/v2/DataArrayResponseTest.java | 52 + .../activemq/openwire/v2/DataResponseTest.java | 50 + .../openwire/v2/DestinationInfoTest.java | 56 + .../openwire/v2/DiscoveryEventTest.java | 52 + .../openwire/v2/ExceptionResponseTest.java | 50 + .../activemq/openwire/v2/FlushCommandTest.java | 49 + .../openwire/v2/IntegerResponseTest.java | 50 + .../openwire/v2/JournalQueueAckTest.java | 52 + .../openwire/v2/JournalTopicAckTest.java | 56 + .../activemq/openwire/v2/JournalTraceTest.java | 51 + .../openwire/v2/JournalTransactionTest.java | 53 + .../activemq/openwire/v2/KeepAliveInfoTest.java | 49 + .../openwire/v2/LastPartialCommandTest.java | 49 + .../openwire/v2/LocalTransactionIdTest.java | 51 + .../activemq/openwire/v2/MessageAckTest.java | 56 + .../v2/MessageDispatchNotificationTest.java | 53 + .../openwire/v2/MessageDispatchTest.java | 53 + .../activemq/openwire/v2/MessageIdTest.java | 53 + .../activemq/openwire/v2/MessagePullTest.java | 52 + .../openwire/v2/MessageTestSupport.java | 89 + .../openwire/v2/NetworkBridgeFilterTest.java | 52 + .../openwire/v2/PartialCommandTest.java | 52 + .../activemq/openwire/v2/ProducerIdTest.java | 53 + .../activemq/openwire/v2/ProducerInfoTest.java | 55 + .../activemq/openwire/v2/RemoveInfoTest.java | 50 + .../openwire/v2/RemoveSubscriptionInfoTest.java | 52 + .../activemq/openwire/v2/ReplayCommandTest.java | 51 + .../activemq/openwire/v2/ResponseTest.java | 50 + .../activemq/openwire/v2/SessionIdTest.java | 52 + .../activemq/openwire/v2/SessionInfoTest.java | 50 + .../activemq/openwire/v2/ShutdownInfoTest.java | 49 + .../openwire/v2/SubscriptionInfoTest.java | 54 + .../openwire/v2/TransactionIdTestSupport.java | 42 + .../openwire/v2/TransactionInfoTest.java | 52 + .../openwire/v2/WireFormatInfoTest.java | 51 + .../openwire/v2/XATransactionIdTest.java | 52 + .../openwire/v3/BaseCommandTestSupport.java | 41 + .../activemq/openwire/v3/BrokerIdTest.java | 51 + .../activemq/openwire/v3/BrokerInfoTest.java | 62 + .../openwire/v3/ConnectionControlTest.java | 54 + .../openwire/v3/ConnectionErrorTest.java | 51 + .../activemq/openwire/v3/ConnectionIdTest.java | 51 + .../openwire/v3/ConnectionInfoTest.java | 59 + .../openwire/v3/ConsumerControlTest.java | 55 + .../activemq/openwire/v3/ConsumerIdTest.java | 53 + .../activemq/openwire/v3/ConsumerInfoTest.java | 68 + .../openwire/v3/ControlCommandTest.java | 50 + .../openwire/v3/DataArrayResponseTest.java | 52 + .../activemq/openwire/v3/DataResponseTest.java | 50 + .../openwire/v3/DestinationInfoTest.java | 56 + .../openwire/v3/DiscoveryEventTest.java | 52 + .../openwire/v3/ExceptionResponseTest.java | 50 + .../activemq/openwire/v3/FlushCommandTest.java | 49 + .../openwire/v3/IntegerResponseTest.java | 50 + .../openwire/v3/JournalQueueAckTest.java | 52 + .../openwire/v3/JournalTopicAckTest.java | 56 + .../activemq/openwire/v3/JournalTraceTest.java | 51 + .../openwire/v3/JournalTransactionTest.java | 53 + .../activemq/openwire/v3/KeepAliveInfoTest.java | 49 + .../openwire/v3/LastPartialCommandTest.java | 49 + .../openwire/v3/LocalTransactionIdTest.java | 51 + .../activemq/openwire/v3/MessageAckTest.java | 56 + .../v3/MessageDispatchNotificationTest.java | 53 + .../openwire/v3/MessageDispatchTest.java | 53 + .../activemq/openwire/v3/MessageIdTest.java | 53 + .../activemq/openwire/v3/MessagePullTest.java | 54 + .../openwire/v3/MessageTestSupport.java | 84 + .../openwire/v3/NetworkBridgeFilterTest.java | 52 + .../openwire/v3/PartialCommandTest.java | 52 + .../activemq/openwire/v3/ProducerAckTest.java | 51 + .../activemq/openwire/v3/ProducerIdTest.java | 53 + .../activemq/openwire/v3/ProducerInfoTest.java | 56 + .../activemq/openwire/v3/RemoveInfoTest.java | 50 + .../openwire/v3/RemoveSubscriptionInfoTest.java | 52 + .../activemq/openwire/v3/ReplayCommandTest.java | 51 + .../activemq/openwire/v3/ResponseTest.java | 50 + .../activemq/openwire/v3/SessionIdTest.java | 52 + .../activemq/openwire/v3/SessionInfoTest.java | 50 + .../activemq/openwire/v3/ShutdownInfoTest.java | 49 + .../openwire/v3/SubscriptionInfoTest.java | 55 + .../openwire/v3/TransactionIdTestSupport.java | 42 + .../openwire/v3/TransactionInfoTest.java | 52 + .../openwire/v3/XATransactionIdTest.java | 52 + .../openwire/v4/BaseCommandTestSupport.java | 39 + .../activemq/openwire/v4/BrokerIdTest.java | 56 + .../activemq/openwire/v4/BrokerInfoTest.java | 73 + .../openwire/v4/ConnectionControlTest.java | 60 + .../openwire/v4/ConnectionErrorTest.java | 57 + .../activemq/openwire/v4/ConnectionIdTest.java | 56 + .../openwire/v4/ConnectionInfoTest.java | 69 + .../openwire/v4/ConsumerControlTest.java | 61 + .../activemq/openwire/v4/ConsumerIdTest.java | 58 + .../activemq/openwire/v4/ConsumerInfoTest.java | 85 + .../openwire/v4/ControlCommandTest.java | 56 + .../openwire/v4/DataArrayResponseTest.java | 62 + .../activemq/openwire/v4/DataResponseTest.java | 56 + .../openwire/v4/DestinationInfoTest.java | 66 + .../openwire/v4/DiscoveryEventTest.java | 57 + .../openwire/v4/ExceptionResponseTest.java | 56 + .../activemq/openwire/v4/FlushCommandTest.java | 55 + .../openwire/v4/IntegerResponseTest.java | 56 + .../openwire/v4/JournalQueueAckTest.java | 57 + .../openwire/v4/JournalTopicAckTest.java | 61 + .../activemq/openwire/v4/JournalTraceTest.java | 56 + .../openwire/v4/JournalTransactionTest.java | 58 + .../activemq/openwire/v4/KeepAliveInfoTest.java | 55 + .../openwire/v4/LastPartialCommandTest.java | 55 + .../openwire/v4/LocalTransactionIdTest.java | 57 + .../activemq/openwire/v4/MessageAckTest.java | 62 + .../v4/MessageDispatchNotificationTest.java | 59 + .../openwire/v4/MessageDispatchTest.java | 59 + .../activemq/openwire/v4/MessageIdTest.java | 58 + .../activemq/openwire/v4/MessagePullTest.java | 60 + .../openwire/v4/MessageTestSupport.java | 89 + .../openwire/v4/NetworkBridgeFilterTest.java | 57 + .../openwire/v4/PartialCommandTest.java | 57 + .../activemq/openwire/v4/ProducerAckTest.java | 57 + .../activemq/openwire/v4/ProducerIdTest.java | 58 + .../activemq/openwire/v4/ProducerInfoTest.java | 66 + .../activemq/openwire/v4/RemoveInfoTest.java | 56 + .../openwire/v4/RemoveSubscriptionInfoTest.java | 58 + .../activemq/openwire/v4/ReplayCommandTest.java | 57 + .../activemq/openwire/v4/ResponseTest.java | 56 + .../activemq/openwire/v4/SessionIdTest.java | 57 + .../activemq/openwire/v4/SessionInfoTest.java | 56 + .../activemq/openwire/v4/ShutdownInfoTest.java | 55 + .../openwire/v4/SubscriptionInfoTest.java | 60 + .../openwire/v4/TransactionIdTestSupport.java | 47 + .../openwire/v4/TransactionInfoTest.java | 58 + .../openwire/v4/XATransactionIdTest.java | 58 + .../openwire/v5/BaseCommandTestSupport.java | 38 + .../activemq/openwire/v5/BrokerIdTest.java | 56 + .../activemq/openwire/v5/BrokerInfoTest.java | 73 + .../openwire/v5/ConnectionControlTest.java | 60 + .../openwire/v5/ConnectionErrorTest.java | 57 + .../activemq/openwire/v5/ConnectionIdTest.java | 56 + .../openwire/v5/ConnectionInfoTest.java | 69 + .../openwire/v5/ConsumerControlTest.java | 61 + .../activemq/openwire/v5/ConsumerIdTest.java | 58 + .../activemq/openwire/v5/ConsumerInfoTest.java | 85 + .../openwire/v5/ControlCommandTest.java | 56 + .../openwire/v5/DataArrayResponseTest.java | 62 + .../activemq/openwire/v5/DataResponseTest.java | 56 + .../openwire/v5/DestinationInfoTest.java | 66 + .../openwire/v5/DiscoveryEventTest.java | 57 + .../openwire/v5/ExceptionResponseTest.java | 56 + .../activemq/openwire/v5/FlushCommandTest.java | 55 + .../openwire/v5/IntegerResponseTest.java | 56 + .../openwire/v5/JournalQueueAckTest.java | 57 + .../openwire/v5/JournalTopicAckTest.java | 61 + .../activemq/openwire/v5/JournalTraceTest.java | 56 + .../openwire/v5/JournalTransactionTest.java | 58 + .../activemq/openwire/v5/KeepAliveInfoTest.java | 55 + .../openwire/v5/LastPartialCommandTest.java | 55 + .../openwire/v5/LocalTransactionIdTest.java | 57 + .../activemq/openwire/v5/MessageAckTest.java | 62 + .../v5/MessageDispatchNotificationTest.java | 59 + .../openwire/v5/MessageDispatchTest.java | 59 + .../activemq/openwire/v5/MessageIdTest.java | 58 + .../activemq/openwire/v5/MessagePullTest.java | 60 + .../openwire/v5/MessageTestSupport.java | 89 + .../openwire/v5/NetworkBridgeFilterTest.java | 57 + .../openwire/v5/PartialCommandTest.java | 57 + .../activemq/openwire/v5/ProducerAckTest.java | 57 + .../activemq/openwire/v5/ProducerIdTest.java | 58 + .../activemq/openwire/v5/ProducerInfoTest.java | 66 + .../activemq/openwire/v5/RemoveInfoTest.java | 57 + .../openwire/v5/RemoveSubscriptionInfoTest.java | 58 + .../activemq/openwire/v5/ReplayCommandTest.java | 57 + .../activemq/openwire/v5/ResponseTest.java | 56 + .../activemq/openwire/v5/SessionIdTest.java | 57 + .../activemq/openwire/v5/SessionInfoTest.java | 56 + .../activemq/openwire/v5/ShutdownInfoTest.java | 55 + .../openwire/v5/SubscriptionInfoTest.java | 60 + .../openwire/v5/TransactionIdTestSupport.java | 47 + .../openwire/v5/TransactionInfoTest.java | 58 + .../openwire/v5/XATransactionIdTest.java | 58 + .../openwire/v6/BaseCommandTestSupport.java | 38 + .../activemq/openwire/v6/BrokerIdTest.java | 56 + .../activemq/openwire/v6/BrokerInfoTest.java | 73 + .../openwire/v6/ConnectionControlTest.java | 63 + .../openwire/v6/ConnectionErrorTest.java | 57 + .../activemq/openwire/v6/ConnectionIdTest.java | 56 + .../openwire/v6/ConnectionInfoTest.java | 71 + .../openwire/v6/ConsumerControlTest.java | 62 + .../activemq/openwire/v6/ConsumerIdTest.java | 58 + .../activemq/openwire/v6/ConsumerInfoTest.java | 85 + .../openwire/v6/ControlCommandTest.java | 56 + .../openwire/v6/DataArrayResponseTest.java | 62 + .../activemq/openwire/v6/DataResponseTest.java | 56 + .../openwire/v6/DestinationInfoTest.java | 66 + .../openwire/v6/DiscoveryEventTest.java | 57 + .../openwire/v6/ExceptionResponseTest.java | 56 + .../activemq/openwire/v6/FlushCommandTest.java | 55 + .../openwire/v6/IntegerResponseTest.java | 56 + .../openwire/v6/JournalQueueAckTest.java | 57 + .../openwire/v6/JournalTopicAckTest.java | 61 + .../activemq/openwire/v6/JournalTraceTest.java | 56 + .../openwire/v6/JournalTransactionTest.java | 58 + .../activemq/openwire/v6/KeepAliveInfoTest.java | 55 + .../openwire/v6/LastPartialCommandTest.java | 55 + .../openwire/v6/LocalTransactionIdTest.java | 57 + .../activemq/openwire/v6/MessageAckTest.java | 62 + .../v6/MessageDispatchNotificationTest.java | 59 + .../openwire/v6/MessageDispatchTest.java | 59 + .../activemq/openwire/v6/MessageIdTest.java | 58 + .../activemq/openwire/v6/MessagePullTest.java | 60 + .../openwire/v6/MessageTestSupport.java | 89 + .../openwire/v6/NetworkBridgeFilterTest.java | 57 + .../openwire/v6/PartialCommandTest.java | 57 + .../activemq/openwire/v6/ProducerAckTest.java | 57 + .../activemq/openwire/v6/ProducerIdTest.java | 58 + .../activemq/openwire/v6/ProducerInfoTest.java | 66 + .../activemq/openwire/v6/RemoveInfoTest.java | 57 + .../openwire/v6/RemoveSubscriptionInfoTest.java | 58 + .../activemq/openwire/v6/ReplayCommandTest.java | 57 + .../activemq/openwire/v6/ResponseTest.java | 56 + .../activemq/openwire/v6/SessionIdTest.java | 57 + .../activemq/openwire/v6/SessionInfoTest.java | 56 + .../activemq/openwire/v6/ShutdownInfoTest.java | 55 + .../openwire/v6/SubscriptionInfoTest.java | 60 + .../openwire/v6/TransactionIdTestSupport.java | 47 + .../openwire/v6/TransactionInfoTest.java | 58 + .../openwire/v6/XATransactionIdTest.java | 58 + .../openwire/v7/BaseCommandTestSupport.java | 38 + .../activemq/openwire/v7/BrokerIdTest.java | 1 + .../activemq/openwire/v7/BrokerInfoTest.java | 1 + .../openwire/v7/ConnectionControlTest.java | 1 + .../openwire/v7/ConnectionErrorTest.java | 1 + .../activemq/openwire/v7/ConnectionIdTest.java | 1 + .../openwire/v7/ConnectionInfoTest.java | 1 + .../openwire/v7/ConsumerControlTest.java | 1 + .../activemq/openwire/v7/ConsumerIdTest.java | 1 + .../activemq/openwire/v7/ConsumerInfoTest.java | 1 + .../openwire/v7/ControlCommandTest.java | 1 + .../openwire/v7/DataArrayResponseTest.java | 1 + .../activemq/openwire/v7/DataResponseTest.java | 1 + .../openwire/v7/DestinationInfoTest.java | 1 + .../openwire/v7/DiscoveryEventTest.java | 1 + .../openwire/v7/ExceptionResponseTest.java | 1 + .../activemq/openwire/v7/FlushCommandTest.java | 1 + .../openwire/v7/IntegerResponseTest.java | 1 + .../openwire/v7/JournalQueueAckTest.java | 1 + .../openwire/v7/JournalTopicAckTest.java | 1 + .../activemq/openwire/v7/JournalTraceTest.java | 1 + .../openwire/v7/JournalTransactionTest.java | 1 + .../activemq/openwire/v7/KeepAliveInfoTest.java | 1 + .../openwire/v7/LastPartialCommandTest.java | 1 + .../openwire/v7/LocalTransactionIdTest.java | 1 + .../activemq/openwire/v7/MessageAckTest.java | 1 + .../v7/MessageDispatchNotificationTest.java | 1 + .../openwire/v7/MessageDispatchTest.java | 1 + .../activemq/openwire/v7/MessageIdTest.java | 1 + .../activemq/openwire/v7/MessagePullTest.java | 1 + .../openwire/v7/MessageTestSupport.java | 1 + .../openwire/v7/NetworkBridgeFilterTest.java | 1 + .../openwire/v7/PartialCommandTest.java | 1 + .../activemq/openwire/v7/ProducerAckTest.java | 1 + .../activemq/openwire/v7/ProducerIdTest.java | 1 + .../activemq/openwire/v7/ProducerInfoTest.java | 1 + .../activemq/openwire/v7/RemoveInfoTest.java | 1 + .../openwire/v7/RemoveSubscriptionInfoTest.java | 1 + .../activemq/openwire/v7/ReplayCommandTest.java | 1 + .../activemq/openwire/v7/ResponseTest.java | 1 + .../activemq/openwire/v7/SessionIdTest.java | 1 + .../activemq/openwire/v7/SessionInfoTest.java | 1 + .../activemq/openwire/v7/ShutdownInfoTest.java | 1 + .../openwire/v7/SubscriptionInfoTest.java | 1 + .../openwire/v7/TransactionIdTestSupport.java | 1 + .../openwire/v7/TransactionInfoTest.java | 1 + .../openwire/v7/XATransactionIdTest.java | 1 + .../openwire/v8/BaseCommandTestSupport.java | 38 + .../activemq/openwire/v8/BrokerIdTest.java | 1 + .../activemq/openwire/v8/BrokerInfoTest.java | 1 + .../openwire/v8/ConnectionControlTest.java | 1 + .../openwire/v8/ConnectionErrorTest.java | 1 + .../activemq/openwire/v8/ConnectionIdTest.java | 1 + .../openwire/v8/ConnectionInfoTest.java | 1 + .../openwire/v8/ConsumerControlTest.java | 1 + .../activemq/openwire/v8/ConsumerIdTest.java | 1 + .../activemq/openwire/v8/ConsumerInfoTest.java | 1 + .../openwire/v8/ControlCommandTest.java | 1 + .../openwire/v8/DataArrayResponseTest.java | 1 + .../activemq/openwire/v8/DataResponseTest.java | 1 + .../openwire/v8/DestinationInfoTest.java | 1 + .../openwire/v8/DiscoveryEventTest.java | 1 + .../openwire/v8/ExceptionResponseTest.java | 1 + .../activemq/openwire/v8/FlushCommandTest.java | 1 + .../openwire/v8/IntegerResponseTest.java | 1 + .../openwire/v8/JournalQueueAckTest.java | 1 + .../openwire/v8/JournalTopicAckTest.java | 1 + .../activemq/openwire/v8/JournalTraceTest.java | 1 + .../openwire/v8/JournalTransactionTest.java | 1 + .../activemq/openwire/v8/KeepAliveInfoTest.java | 1 + .../openwire/v8/LastPartialCommandTest.java | 1 + .../openwire/v8/LocalTransactionIdTest.java | 1 + .../activemq/openwire/v8/MessageAckTest.java | 1 + .../v8/MessageDispatchNotificationTest.java | 1 + .../openwire/v8/MessageDispatchTest.java | 1 + .../activemq/openwire/v8/MessageIdTest.java | 1 + .../activemq/openwire/v8/MessagePullTest.java | 1 + .../openwire/v8/MessageTestSupport.java | 1 + .../openwire/v8/NetworkBridgeFilterTest.java | 1 + .../openwire/v8/PartialCommandTest.java | 1 + .../activemq/openwire/v8/ProducerAckTest.java | 1 + .../activemq/openwire/v8/ProducerIdTest.java | 1 + .../activemq/openwire/v8/ProducerInfoTest.java | 1 + .../activemq/openwire/v8/RemoveInfoTest.java | 1 + .../openwire/v8/RemoveSubscriptionInfoTest.java | 1 + .../activemq/openwire/v8/ReplayCommandTest.java | 1 + .../activemq/openwire/v8/ResponseTest.java | 1 + .../activemq/openwire/v8/SessionIdTest.java | 1 + .../activemq/openwire/v8/SessionInfoTest.java | 1 + .../activemq/openwire/v8/ShutdownInfoTest.java | 1 + .../openwire/v8/SubscriptionInfoTest.java | 1 + .../openwire/v8/TransactionIdTestSupport.java | 1 + .../openwire/v8/TransactionInfoTest.java | 1 + .../openwire/v8/XATransactionIdTest.java | 1 + .../openwire/v9/BaseCommandTestSupport.java | 38 + .../activemq/openwire/v9/BrokerIdTest.java | 1 + .../activemq/openwire/v9/BrokerInfoTest.java | 1 + .../openwire/v9/ConnectionControlTest.java | 1 + .../openwire/v9/ConnectionErrorTest.java | 1 + .../activemq/openwire/v9/ConnectionIdTest.java | 1 + .../openwire/v9/ConnectionInfoTest.java | 1 + .../openwire/v9/ConsumerControlTest.java | 1 + .../activemq/openwire/v9/ConsumerIdTest.java | 1 + .../activemq/openwire/v9/ConsumerInfoTest.java | 1 + .../openwire/v9/ControlCommandTest.java | 1 + .../openwire/v9/DataArrayResponseTest.java | 1 + .../activemq/openwire/v9/DataResponseTest.java | 1 + .../openwire/v9/DestinationInfoTest.java | 1 + .../openwire/v9/DiscoveryEventTest.java | 1 + .../openwire/v9/ExceptionResponseTest.java | 1 + .../activemq/openwire/v9/FlushCommandTest.java | 1 + .../openwire/v9/IntegerResponseTest.java | 1 + .../openwire/v9/JournalQueueAckTest.java | 1 + .../openwire/v9/JournalTopicAckTest.java | 1 + .../activemq/openwire/v9/JournalTraceTest.java | 1 + .../openwire/v9/JournalTransactionTest.java | 1 + .../activemq/openwire/v9/KeepAliveInfoTest.java | 1 + .../openwire/v9/LastPartialCommandTest.java | 1 + .../openwire/v9/LocalTransactionIdTest.java | 1 + .../activemq/openwire/v9/MessageAckTest.java | 1 + .../v9/MessageDispatchNotificationTest.java | 1 + .../openwire/v9/MessageDispatchTest.java | 1 + .../activemq/openwire/v9/MessageIdTest.java | 1 + .../activemq/openwire/v9/MessagePullTest.java | 1 + .../openwire/v9/MessageTestSupport.java | 1 + .../openwire/v9/NetworkBridgeFilterTest.java | 1 + .../openwire/v9/PartialCommandTest.java | 1 + .../activemq/openwire/v9/ProducerAckTest.java | 1 + .../activemq/openwire/v9/ProducerIdTest.java | 1 + .../activemq/openwire/v9/ProducerInfoTest.java | 1 + .../activemq/openwire/v9/RemoveInfoTest.java | 1 + .../openwire/v9/RemoveSubscriptionInfoTest.java | 1 + .../activemq/openwire/v9/ReplayCommandTest.java | 1 + .../activemq/openwire/v9/ResponseTest.java | 1 + .../activemq/openwire/v9/SessionIdTest.java | 1 + .../activemq/openwire/v9/SessionInfoTest.java | 1 + .../activemq/openwire/v9/ShutdownInfoTest.java | 1 + .../openwire/v9/SubscriptionInfoTest.java | 1 + .../openwire/v9/TransactionIdTestSupport.java | 1 + .../openwire/v9/TransactionInfoTest.java | 1 + .../openwire/v9/XATransactionIdTest.java | 1 + .../activemq/perf/ConnectionChurnTest.java | 105 ++ .../activemq/perf/InactiveDurableTopicTest.java | 190 ++ .../apache/activemq/perf/InactiveQueueTest.java | 114 ++ .../activemq/perf/KahaDBDurableTopicTest.java | 52 + .../perf/KahaDBDurableTransactedTopicTest.java | 42 + .../apache/activemq/perf/KahaDBQueueTest.java | 63 + .../org/apache/activemq/perf/KahaQueueTest.java | 37 + .../activemq/perf/LevelDBDurableTopicTest.java | 44 + .../activemq/perf/LevelDBStoreQueueTest.java | 42 + .../activemq/perf/MemoryAllocationTest.java | 117 ++ .../apache/activemq/perf/NetworkedSyncTest.java | 317 ++++ .../activemq/perf/NumberOfDestinationsTest.java | 127 ++ .../org/apache/activemq/perf/PerfConsumer.java | 140 ++ .../org/apache/activemq/perf/PerfProducer.java | 129 ++ .../java/org/apache/activemq/perf/PerfRate.java | 81 + .../perf/QueueConnectionMemoryTest.java | 83 + .../org/apache/activemq/perf/RunBroker.java | 66 + .../perf/SimpleDurableTopicNetworkTest.java | 45 + .../activemq/perf/SimpleDurableTopicTest.java | 74 + .../apache/activemq/perf/SimpleNetworkTest.java | 144 ++ .../SimpleNonPersistentQueueNetworkTest.java | 83 + .../perf/SimpleNonPersistentQueueTest.java | 78 + .../perf/SimpleNonPersistentTopicTest.java | 34 + .../apache/activemq/perf/SimpleQueueTest.java | 53 + .../apache/activemq/perf/SimpleTopicTest.java | 206 ++ .../org/apache/activemq/perf/SlowConsumer.java | 50 + .../activemq/perf/SlowConsumerTopicTest.java | 74 + .../perf/SlowDurableConsumerTopicTest.java | 35 + .../TemporaryTopicMemoryAllocationTest.java | 34 + .../org/apache/activemq/perf/kahaBroker.xml | 31 + .../org/apache/activemq/perf/kahadbBroker.xml | 30 + .../org/apache/activemq/perf/networkSync.xml | 49 + .../apache/activemq/perf/slowConsumerBroker.xml | 41 + .../plugin/BrokerStatisticsPluginTest.java | 214 +++ .../plugin/statistics-plugin-broker.xml | 36 + ...veTwoConnectionsWithSenderUsingPoolTest.java | 47 + .../org/apache/activemq/proxy/AMQ4889Test.java | 135 ++ .../activemq/proxy/ProxyConnectorTest.java | 103 + .../activemq/proxy/ProxyFailoverTest.java | 97 + .../apache/activemq/proxy/ProxyTestSupport.java | 137 ++ .../org/apache/activemq/security/AMQauth.ldif | 159 ++ ...actCachedLDAPAuthorizationMapLegacyTest.java | 434 +++++ ...stractCachedLDAPAuthorizationModuleTest.java | 63 + .../activemq/security/AuthorizationMapTest.java | 194 ++ ...APAuthorizationModuleLegacyOpenLDAPTest.java | 97 + ...CachedLDAPAuthorizationModuleLegacyTest.java | 65 + ...chedLDAPAuthorizationModuleOpenLDAPTest.java | 106 ++ .../CachedLDAPAuthorizationModuleTest.java | 71 + .../security/CachedLDAPSecurityLegacyTest.java | 129 ++ .../security/CachedLDAPSecurityTest.java | 45 + .../org/apache/activemq/security/DoSTest.java | 100 + ...JaasCertificateAuthenticationBrokerTest.java | 187 ++ .../JaasDualAuthenticationBrokerTest.java | 216 +++ .../activemq/security/JaasNetworkTest.java | 85 + .../security/LDAPAuthenticationTest.java | 83 + .../security/LDAPAuthorizationMap.properties | 33 + .../security/LDAPAuthorizationMapTest.java | 156 ++ .../activemq/security/LDAPSecurityTest.java | 152 ++ .../activemq/security/SecurityJMXTest.java | 108 ++ .../activemq/security/SecurityTestSupport.java | 263 +++ .../security/SimpleAnonymousPluginTest.java | 117 ++ ...SimpleAuthenticationPluginSeparatorTest.java | 120 ++ .../SimpleAuthenticationPluginTest.java | 149 ++ .../security/SimpleAuthorizationMapTest.java | 28 + .../SimpleSecurityBrokerSystemTest.java | 187 ++ .../security/StubDoNothingCallbackHandler.java | 31 + .../security/StubDualJaasConfiguration.java | 43 + .../security/StubJaasConfiguration.java | 37 + .../activemq/security/StubLoginModule.java | 98 + .../activemq/security/StubSecurityContext.java | 31 + .../activemq/security/XBeanSecurityTest.java | 53 + ...nSecurityWithGuestNoCredentialsOnlyTest.java | 139 ++ .../security/XBeanSecurityWithGuestTest.java | 137 ++ .../activemq/security/XBeanSslContextTest.java | 41 + .../security/activemq-apacheds-add.ldif | 47 + .../security/activemq-apacheds-delete.ldif | 40 + .../security/activemq-apacheds-legacy-add.ldif | 47 + .../activemq-apacheds-legacy-delete.ldif | 38 + .../security/activemq-apacheds-legacy.ldif | 264 +++ .../security/activemq-apacheds-legacy.xml | 49 + .../activemq/security/activemq-apacheds.ldif | 294 +++ .../activemq/security/activemq-apacheds.xml | 49 + .../activemq/security/activemq-ldap-auth.xml | 46 + .../apache/activemq/security/activemq-ldap.xml | 83 + .../security/activemq-openldap-add.ldif | 47 + .../security/activemq-openldap-delete.ldif | 38 + .../security/activemq-openldap-legacy-add.ldif | 47 + .../activemq-openldap-legacy-delete.ldif | 38 + .../security/activemq-openldap-legacy.ldif | 281 +++ .../activemq/security/activemq-openldap.ldif | 312 ++++ .../activemq/security/activemq-openldap.xml | 64 + .../activemq/security/activemq-sslcontext.xml | 45 + .../org/apache/activemq/security/activemq.ldif | 241 +++ .../org/apache/activemq/security/broker1.ks | 0 .../org/apache/activemq/security/broker1.ts | 0 .../org/apache/activemq/security/broker1.xml | 72 + .../org/apache/activemq/security/broker2.ks | 0 .../org/apache/activemq/security/broker2.ts | 0 .../org/apache/activemq/security/broker2.xml | 63 + .../java/org/apache/activemq/security/client.ks | 0 .../java/org/apache/activemq/security/client.ts | 0 .../org/apache/activemq/security/dos-broker.xml | 67 + .../apache/activemq/security/groups.properties | 21 + .../jaas-broker-guest-no-creds-only.xml | 56 + .../activemq/security/jaas-broker-guest.xml | 56 + .../apache/activemq/security/jaas-broker.xml | 63 + .../apache/activemq/security/ldap-spring.xml | 213 +++ .../security/simple-anonymous-broker.xml | 91 + .../activemq/security/simple-auth-broker.xml | 99 + .../activemq/security/simple-auth-separator.xml | 100 + .../activemq/security/sslcontext-client.ts | 0 .../activemq/security/sslcontext-keystore.ks | 0 .../apache/activemq/security/users.properties | 21 + .../apache/activemq/security/users1.properties | 19 + .../apache/activemq/security/users2.properties | 19 + .../activemq/selector/SelectorParserTest.java | 88 + .../apache/activemq/selector/SelectorTest.java | 397 ++++ .../selector/UnknownHandlingSelectorTest.java | 182 ++ ...ctiveMQConnectionFactoryFactoryBeanTest.java | 94 + .../apache/activemq/spring/ConsumerBean.java | 167 ++ .../spring/Spring2XmlNamespacesTest.java | 23 + ...ng2XmlNamespacesWithoutRemoteSchemaTest.java | 23 + .../apache/activemq/spring/SpringConsumer.java | 113 ++ .../apache/activemq/spring/SpringProducer.java | 79 + .../org/apache/activemq/spring/SpringTest.java | 98 + .../activemq/spring/SpringTestSupport.java | 97 + .../store/AutoStorePerDestinationTest.java | 42 + .../store/LevelDBStorePerDestinationTest.java | 45 + .../activemq/store/MessagePriorityTest.java | 587 ++++++ .../apache/activemq/store/StoreOrderTest.java | 273 +++ .../activemq/store/StorePerDestinationTest.java | 309 +++ .../store/jdbc/BrokenPersistenceAdapter.java | 47 + .../store/jdbc/DatabaseLockerConfigTest.java | 55 + .../store/jdbc/JDBCCommitExceptionTest.java | 175 ++ .../jdbc/JDBCIOExceptionHandlerMockeryTest.java | 109 ++ .../store/jdbc/JDBCIOExceptionHandlerTest.java | 321 ++++ .../activemq/store/jdbc/JDBCLockTablePrefix.xml | 58 + .../store/jdbc/JDBCLockTablePrefixTest.java | 42 + .../store/jdbc/JDBCMessagePriorityTest.java | 453 +++++ .../store/jdbc/JDBCNegativeQueueTest.java | 91 + .../store/jdbc/JDBCNetworkBrokerDetachTest.java | 36 + .../store/jdbc/JDBCPersistenceAdapterTest.java | 65 + .../store/jdbc/JDBCStoreAutoCommitTest.java | 502 +++++ .../store/jdbc/JDBCStoreBrokerTest.java | 60 + .../activemq/store/jdbc/JDBCStoreOrderTest.java | 63 + .../store/jdbc/JDBCTablePrefixAssignedTest.java | 132 ++ .../activemq/store/jdbc/JDBCTestMemory.java | 152 ++ .../store/jdbc/JDBCXACommitExceptionTest.java | 159 ++ .../store/jdbc/LeaseDatabaseLockerTest.java | 270 +++ .../activemq/store/kahadb/CustomLockerTest.java | 31 + .../store/kahadb/KahaDBFastEnqueueTest.java | 245 +++ .../store/kahadb/KahaDBIndexLocationTest.java | 165 ++ .../store/kahadb/KahaDBMessagePriorityTest.java | 40 + .../kahadb/KahaDBPersistenceAdapterTest.java | 39 + .../store/kahadb/KahaDBStoreBrokerTest.java | 67 + .../store/kahadb/KahaDBStoreOrderTest.java | 35 + .../kahadb/KahaDBStoreRecoveryBrokerTest.java | 213 +++ .../kahadb/KahaDBStoreRecoveryExpiryTest.java | 113 ++ .../activemq/store/kahadb/KahaDBStoreTest.java | 109 ++ .../activemq/store/kahadb/KahaDBTest.java | 241 +++ .../store/kahadb/KahaDBVersion1/db-1.log | 0 .../store/kahadb/KahaDBVersion1/db.data | 0 .../store/kahadb/KahaDBVersion1/db.redo | 0 .../store/kahadb/KahaDBVersion2/db-1.log | 0 .../store/kahadb/KahaDBVersion2/db.data | 0 .../store/kahadb/KahaDBVersion2/db.redo | 0 .../store/kahadb/KahaDBVersion3/db-1.log | 0 .../store/kahadb/KahaDBVersion3/db.data | 0 .../store/kahadb/KahaDBVersion3/db.redo | 0 .../store/kahadb/KahaDBVersion4/db-1.log | 0 .../store/kahadb/KahaDBVersion4/db.data | 0 .../store/kahadb/KahaDBVersion4/db.redo | 0 .../store/kahadb/KahaDBVersionTest.java | 179 ++ .../activemq/store/kahadb/NoSpaceIOTest.java | 120 ++ .../activemq/store/kahadb/PBMesssagesTest.java | 56 + .../store/kahadb/TempKahaDBStoreBrokerTest.java | 59 + .../store/kahadb/perf/KahaBulkLoadingTest.java | 152 ++ .../kahadb/perf/KahaStoreDurableTopicTest.java | 42 + .../store/kahadb/perf/KahaStoreQueueTest.java | 44 + .../kahadb/perf/TempKahaStoreQueueTest.java | 45 + .../KahaDBFilePendingMessageCursorTest.java | 97 + .../activemq/store/kahadb/plist/PListTest.java | 660 +++++++ .../org/apache/activemq/store/kahadb/shared.xml | 59 + .../store/leveldb/LevelDBNegativeQueueTest.java | 38 + .../store/leveldb/LevelDBStoreBrokerTest.java | 68 + .../activemq/store/schedulerDB/legacy/db-1.log | 0 .../store/schedulerDB/legacy/scheduleDB.data | 0 .../store/schedulerDB/legacy/scheduleDB.redo | 0 .../activemq/streams/JMSInputStreamTest.java | 281 +++ .../test/JmsSendReceiveTestSupport.java | 260 +++ .../activemq/test/JmsTopicSendReceiveTest.java | 119 ++ ...dReceiveWithEmbeddedBrokerAndUserIDTest.java | 111 ++ ...veWithTwoConnectionsAndByteSelectorTest.java | 37 + ...WithTwoConnectionsAndEmbeddedBrokerTest.java | 69 + ...sTopicSendReceiveWithTwoConnectionsTest.java | 133 ++ .../TemporaryDestinationToFromNameTest.java | 58 + .../message/NestedMapAndListPropertyTest.java | 95 + .../test/message/NestedMapMessageTest.java | 98 + .../test/retroactive/DummyMessageQuery.java | 50 + ...sumerTestWithDestinationBasedBufferTest.java | 27 + ...TestWithLastImagePolicyWithWildcardTest.java | 48 + ...veConsumerTestWithSimpleMessageListTest.java | 127 ++ ...troactiveConsumerTestWithTimePolicyTest.java | 27 + ...RetroactiveConsumerWithMessageQueryTest.java | 114 ++ .../test/retroactive/activemq-fixed-buffer.xml | 46 + .../activemq-fixed-destination-buffer.xml | 46 + .../retroactive/activemq-lastimage-policy.xml | 47 + .../test/retroactive/activemq-message-query.xml | 48 + .../test/retroactive/activemq-timed-policy.xml | 47 + .../CloseRollbackRedeliveryQueueTest.java | 134 ++ .../DelegatingTransactionalMessageListener.java | 70 + .../RollbacksWhileConsumingLargeQueueTest.java | 182 ++ .../activemq/transport/QueueClusterTest.java | 33 + .../transport/SoWriteTimeoutClientTest.java | 111 ++ .../activemq/transport/SoWriteTimeoutTest.java | 170 ++ .../transport/StubCompositeTransport.java | 51 + .../activemq/transport/StubTransport.java | 57 + .../transport/StubTransportListener.java | 58 + .../activemq/transport/TopicClusterTest.java | 179 ++ .../transport/TransportBrokerTestSupport.java | 78 + .../DiscoveryNetworkReconnectTest.java | 240 +++ .../discovery/DiscoveryTransportBrokerTest.java | 162 ++ .../DiscoveryTransportNoBrokerTest.java | 179 ++ .../transport/discovery/DiscoveryUriTest.java | 65 + .../ZeroconfDiscoverTransportTest.java | 29 + .../transport/failover/AMQ1925Test.java | 408 ++++ .../transport/failover/BadConnectionTest.java | 77 + .../failover/ConnectionHangOnStartupTest.java | 110 ++ .../failover/FailoverBackupLeakTest.java | 127 ++ .../transport/failover/FailoverClusterTest.java | 163 ++ .../failover/FailoverClusterTestSupport.java | 202 ++ .../failover/FailoverComplexClusterTest.java | 380 ++++ .../FailoverConsumerOutstandingCommitTest.java | 372 ++++ .../FailoverConsumerUnconsumedTest.java | 382 ++++ .../failover/FailoverDuplicateTest.java | 252 +++ .../failover/FailoverPrefetchZeroTest.java | 162 ++ .../failover/FailoverPriorityTest.java | 226 +++ .../transport/failover/FailoverRandomTest.java | 77 + .../FailoverRedeliveryTransactionTest.java | 88 + .../transport/failover/FailoverTimeoutTest.java | 136 ++ .../failover/FailoverTransactionTest.java | 1181 ++++++++++++ .../failover/FailoverTransportBackupsTest.java | 227 +++ .../failover/FailoverTransportBrokerTest.java | 182 ++ .../failover/FailoverTransportTest.java | 180 ++ .../FailoverTransportUriHandlingTest.java | 146 ++ .../failover/FailoverUpdateURIsTest.java | 156 ++ .../transport/failover/FailoverUriTest.java | 48 + .../failover/InitalReconnectDelayTest.java | 187 ++ .../transport/failover/ReconnectTest.java | 232 +++ .../transport/failover/SlowConnectionTest.java | 99 + .../failover/TwoBrokerFailoverClusterTest.java | 92 + .../activemq/transport/fanout/FanoutTest.java | 97 + .../fanout/FanoutTransportBrokerTest.java | 203 ++ .../multicast/MulticastTransportTest.java | 71 + .../nio/NIOJmsDurableTopicSendReceiveTest.java | 56 + .../transport/nio/NIOJmsSendAndReceiveTest.java | 59 + .../nio/NIOPersistentSendAndReceiveTest.java | 38 + .../activemq/transport/nio/NIOSSLBasicTest.java | 115 ++ .../transport/nio/NIOSSLConcurrencyTest.java | 251 +++ .../activemq/transport/nio/NIOSSLLoadTest.java | 115 ++ .../nio/NIOSSLTransportBrokerTest.java | 67 + .../transport/nio/NIOSSLWindowSizeTest.java | 113 ++ .../transport/nio/NIOTransportBrokerTest.java | 37 + .../transport/peer/PeerTransportTest.java | 157 ++ .../transport/reliable/DropCommandStrategy.java | 33 + .../reliable/ReliableTransportTest.java | 133 ++ .../UnreliableCommandDatagramChannel.java | 59 + .../UnreliableCommandDatagramSocket.java | 57 + .../reliable/UnreliableUdpTransport.java | 68 + .../reliable/UnreliableUdpTransportTest.java | 92 + .../transport/tcp/InactivityMonitorTest.java | 255 +++ .../tcp/QualityOfServiceUtilsTest.java | 170 ++ .../transport/tcp/ServerSocketTstFactory.java | 81 + .../transport/tcp/SocketTstFactory.java | 178 ++ .../transport/tcp/SslBrokerServiceTest.java | 194 ++ .../tcp/SslContextBrokerServiceTest.java | 66 + .../tcp/SslContextNBrokerServiceTest.java | 147 ++ .../activemq/transport/tcp/SslSocketHelper.java | 44 + .../transport/tcp/SslTransportBrokerTest.java | 62 + .../transport/tcp/SslTransportFactoryTest.java | 147 ++ .../transport/tcp/SslTransportServerTest.java | 92 + .../transport/tcp/SslTransportTest.java | 96 + .../transport/tcp/StubSSLServerSocket.java | 97 + .../activemq/transport/tcp/StubSSLSession.java | 133 ++ .../activemq/transport/tcp/StubSSLSocket.java | 124 ++ .../transport/tcp/StubSSLSocketFactory.java | 55 + .../transport/tcp/StubSslTransport.java | 51 + .../transport/tcp/StubX509Certificate.java | 138 ++ .../transport/tcp/TcpFaultyTransport.java | 49 + .../tcp/TcpFaultyTransportFactory.java | 97 + .../transport/tcp/TcpFaultyTransportServer.java | 46 + .../transport/tcp/TcpTransportBindTest.java | 73 + .../transport/tcp/TcpTransportBrokerTest.java | 41 + .../transport/tcp/TcpTransportServerTest.java | 79 + ...nsportConnectorInvalidSocketOptionsTest.java | 65 + .../transport/tcp/TransportUriTest.java | 204 ++ .../tcp/WireformatNegociationTest.java | 236 +++ .../activemq/transport/tcp/activemq-ssl.xml | 44 + .../activemq/transport/tcp/n-brokers-ssl.xml | 51 + ...eWithTwoConnectionsAndLargeMessagesTest.java | 31 + .../UdpSendReceiveWithTwoConnectionsTest.java | 56 + .../activemq/transport/udp/UdpTestSupport.java | 272 +++ .../transport/udp/UdpTransportTest.java | 64 + .../udp/UdpTransportUsingServerTest.java | 66 + .../transport/udp/UpdTransportBindTest.java | 43 + .../transport/vm/VMTransportBrokerNameTest.java | 50 + .../transport/vm/VMTransportBrokerTest.java | 37 + .../vm/VMTransportEmbeddedBrokerTest.java | 100 + .../transport/vm/VMTransportThreadSafeTest.java | 920 +++++++++ .../transport/vm/VMTransportWaitForTest.java | 137 ++ .../vm/VmTransportNetworkBrokerTest.java | 155 ++ .../usage/CompositeMessageCursorUsageTest.java | 90 + .../usage/JobSchedulerStoreUsageTest.java | 107 ++ .../activemq/usage/StoreUsageLimitsTest.java | 75 + .../apache/activemq/usage/StoreUsageTest.java | 71 + .../apache/activemq/usecases/AMQ2927Test.java | 135 ++ .../activemq/usecases/AMQStackOverFlowTest.java | 148 ++ ...rWildcardIncludedDestinationTestSupport.java | 147 ++ .../usecases/AdvisoryTopicCleanUpTest.java | 162 ++ .../usecases/AdvisoryTopicDeletionTest.java | 125 ++ .../AuthorizationFromAdminViewTest.java | 65 + .../usecases/BacklogNetworkCrossTalkTest.java | 96 + .../BatchedMessagePriorityConsumerTest.java | 81 + .../BrokerQueueNetworkWithDisconnectTest.java | 259 +++ .../apache/activemq/usecases/BrowseDLQTest.java | 108 ++ .../usecases/BrowseOverNetworkTest.java | 250 +++ .../usecases/ChangeSentMessageTest.java | 67 + .../usecases/ChangeSessionDeliveryModeTest.java | 63 + .../activemq/usecases/ClientRebalanceTest.java | 90 + .../activemq/usecases/CompositeConsumeTest.java | 74 + .../activemq/usecases/CompositePublishTest.java | 153 ++ .../ConcurrentDestinationCreationTest.java | 152 ++ .../ConcurrentProducerDurableConsumerTest.java | 491 +++++ .../ConcurrentProducerQueueConsumerTest.java | 435 +++++ .../usecases/ConsumeQueuePrefetchTest.java | 57 + .../usecases/ConsumeTopicPrefetchTest.java | 154 ++ ...onsumeUncompressedCompressedMessageTest.java | 194 ++ .../CreateLotsOfTemporaryQueuesTest.java | 67 + .../CreateTemporaryQueueBeforeStartTest.java | 131 ++ .../DiscriminatingConsumerLoadTest.java | 310 +++ .../usecases/DispatchMultipleConsumersTest.java | 227 +++ ...DurableConsumerCloseAndReconnectTcpTest.java | 193 ++ .../DurableConsumerCloseAndReconnectTest.java | 246 +++ .../DurableSubDelayedUnsubscribeTest.java | 780 ++++++++ .../usecases/DurableSubInBrokerNetworkTest.java | 187 ++ ...ConcurrentCommitActivateNoDuplicateTest.java | 935 ++++++++++ .../DurableSubProcessMultiRestartTest.java | 409 ++++ .../usecases/DurableSubProcessTest.java | 678 +++++++ .../DurableSubProcessWithRestartTest.java | 832 +++++++++ .../usecases/DurableSubSelectorDelayTest.java | 309 +++ .../DurableSubSelectorDelayWithRestartTest.java | 342 ++++ ...neSelectorConcurrentConsumeIndexUseTest.java | 257 +++ .../DurableSubsOfflineSelectorIndexUseTest.java | 225 +++ ...rableSubscriberNonPersistentMessageTest.java | 322 ++++ ...ableSubscriberWithNetworkDisconnectTest.java | 234 +++ ...DurableSubscriberWithNetworkRestartTest.java | 231 +++ .../DurableSubscriptionActivationTest.java | 122 ++ .../DurableSubscriptionHangTestCase.java | 135 ++ .../DurableSubscriptionOffline1Test.java | 247 +++ .../DurableSubscriptionOffline2Test.java | 171 ++ .../DurableSubscriptionOffline3Test.java | 424 +++++ .../DurableSubscriptionOffline4Test.java | 131 ++ .../DurableSubscriptionOfflineTest.java | 878 +++++++++ .../DurableSubscriptionOfflineTestBase.java | 221 +++ .../DurableSubscriptionReactivationTest.java | 95 + .../DurableSubscriptionRemoveOfflineTest.java | 118 ++ .../DurableSubscriptionSelectorTest.java | 177 ++ .../DurableSubscriptionTestSupport.java | 534 ++++++ .../DurableSubscriptionUnsubscribeTest.java | 340 ++++ .../usecases/DurableUnsubscribeTest.java | 119 ++ .../usecases/ExceptionListenerTest.java | 118 ++ .../activemq/usecases/ExpiredMessagesTest.java | 321 ++++ .../ExpiredMessagesWithNoConsumerTest.java | 614 ++++++ .../usecases/JDBCDurableSubscriptionTest.java | 40 + .../JMXRemoveQueueThenSendIgnoredTest.java | 155 ++ .../usecases/JdbcDurableSubDupTest.java | 297 +++ .../JournalDurableSubscriptionTest.java | 38 + .../usecases/KahaDBDurableSubscriptionTest.java | 27 + .../usecases/LargeQueueSparseDeleteTest.java | 200 ++ .../LevelDBDurableSubscriptionTest.java | 37 + .../ManagedDurableSubscriptionTest.java | 119 ++ .../activemq/usecases/MemoryLimitTest.java | 202 ++ .../usecases/MessageGroupCloseTest.java | 235 +++ .../usecases/MessageGroupDelayedTest.java | 243 +++ .../usecases/MessageGroupLateArrivalsTest.java | 303 +++ .../usecases/MessageGroupNewConsumerTest.java | 178 ++ .../MessageGroupReconnectDistributionTest.java | 218 +++ .../activemq/usecases/MessageReroutingTest.java | 87 + .../usecases/MultiBrokersMultiClientsTest.java | 166 ++ .../MultiBrokersMultiClientsUsingTcpTest.java | 86 + .../MulticastDiscoveryOnFaultyNetworkTest.java | 130 ++ .../org/apache/activemq/usecases/MyObject.java | 68 + .../usecases/NetworkAsyncStartTest.java | 120 ++ .../NetworkBridgeProducerFlowControlTest.java | 387 ++++ .../usecases/NetworkOfTwentyBrokersTest.java | 217 +++ .../NewConsumerCreatesDestinationTest.java | 63 + .../usecases/NoDuplicateOnTopicNetworkTest.java | 374 ++++ .../NonBlockingConsumerRedeliveryTest.java | 465 +++++ .../ObjectMessageNotSerializableTest.java | 273 +++ .../usecases/ProducerConsumerTestSupport.java | 56 + ...ublishOnDurableTopicConsumedMessageTest.java | 28 + ...OnQueueConsumedMessageInTransactionTest.java | 186 ++ .../PublishOnQueueConsumedMessageTest.java | 28 + ...ueueConsumedMessageUsingActivemqXMLTest.java | 90 + ...lishOnTemporaryQueueConsumedMessageTest.java | 31 + .../PublishOnTopicConsumedMessageTest.java | 67 + ...opicConsumerMessageUsingActivemqXMLTest.java | 91 + .../usecases/QueueBrowsingLevelDBTest.java | 36 + .../usecases/QueueBrowsingLimitTest.java | 113 ++ .../activemq/usecases/QueueBrowsingTest.java | 216 +++ .../QueueConsumerCloseAndReconnectTest.java | 26 + .../activemq/usecases/QueueDuplicatesTest.java | 158 ++ .../QueueMemoryFullMultiBrokersTest.java | 100 + .../activemq/usecases/QueueRedeliverTest.java | 29 + .../activemq/usecases/QueueRepeaterTest.java | 119 ++ .../usecases/ReliableReconnectTest.java | 179 ++ .../RequestReplyNoAdvisoryNetworkTest.java | 281 +++ ...estReplyTempDestRemovalAdvisoryRaceTest.java | 486 +++++ ...uestReplyToTopicViaThreeNetworkHopsTest.java | 977 ++++++++++ ...tualDestinationsWithWildcardLevelDBTest.java | 44 + ...okerVirtualDestinationsWithWildcardTest.java | 126 ++ .../usecases/StartAndStopBrokerTest.java | 78 + ...AndBrokerDoesNotLeaveThreadsRunningTest.java | 93 + .../activemq/usecases/StaticNetworkTest.java | 71 + .../SubscribeClosePublishThenConsumeTest.java | 111 ++ .../TempTopicProducerFlowControlTest.java | 43 + ...kerConnectionDuplexExcludedDestinations.java | 171 ++ .../apache/activemq/usecases/TestSupport.java | 147 ++ .../usecases/ThreeBrokerQueueNetworkTest.java | 666 +++++++ .../ThreeBrokerQueueNetworkUsingTcpTest.java | 70 + .../ThreeBrokerStompTemporaryQueueTest.java | 176 ++ ...erTempDestDemandSubscriptionCleanupTest.java | 264 +++ .../ThreeBrokerTempQueueNetworkTest.java | 118 ++ .../usecases/ThreeBrokerTopicNetworkTest.java | 411 ++++ .../ThreeBrokerTopicNetworkUsingTcpTest.java | 70 + ...reeBrokerVirtualTopicNetworkLevelDBTest.java | 34 + .../ThreeBrokerVirtualTopicNetworkTest.java | 186 ++ .../usecases/TopicDurableConnectStatsTest.java | 273 +++ .../usecases/TopicProducerFlowControlTest.java | 189 ++ .../activemq/usecases/TopicRedeliverTest.java | 278 +++ .../activemq/usecases/TopicReplicationTest.java | 116 ++ .../TopicSubscriptionSlowConsumerTest.java | 128 ++ .../TopicSubscriptionZeroPrefetchTest.java | 116 ++ .../usecases/TransactionRollbackOrderTest.java | 159 ++ .../activemq/usecases/TransactionTest.java | 122 ++ .../usecases/TransientQueueRedeliverTest.java | 32 + ...essageNotSentToRemoteWhenNoConsumerTest.java | 131 ++ .../usecases/TwoBrokerMulticastQueueTest.java | 267 +++ ...dcardDynamicallyIncludedDestinationTest.java | 33 + ...ldcardStaticallyIncludedDestinationTest.java | 33 + .../TwoBrokerNetworkLoadBalanceTest.java | 77 + .../TwoBrokerQueueClientsReconnectTest.java | 606 ++++++ .../usecases/TwoBrokerQueueSendReceiveTest.java | 60 + .../TwoBrokerTempQueueAdvisoryTest.java | 197 ++ ...icSendReceiveLotsOfMessagesUsingTcpTest.java | 30 + .../usecases/TwoBrokerTopicSendReceiveTest.java | 102 + ...icSendReceiveUsingJavaConfigurationTest.java | 77 + .../TwoBrokerTopicSendReceiveUsingTcpTest.java | 80 + ...rVirtualDestDinamicallyIncludedDestTest.java | 229 +++ .../TwoBrokerVirtualTopicForwardingTest.java | 203 ++ ...castDiscoveryBrokerTopicSendReceiveTest.java | 41 + .../TwoSecureBrokerRequestReplyTest.java | 89 + .../activemq/usecases/UnlimitedEnqueueTest.java | 137 ++ .../VerifyNetworkConsumersDisconnectTest.java | 264 +++ ...tualTopicNetworkClusterReactivationTest.java | 176 ++ .../org/apache/activemq/usecases/activemq.xml | 108 ++ .../apache/activemq/usecases/browse-broker1.xml | 60 + .../activemq/usecases/browse-broker1A.xml | 193 ++ .../activemq/usecases/browse-broker1B.xml | 194 ++ .../apache/activemq/usecases/browse-broker2.xml | 52 + .../activemq/usecases/browse-broker2A.xml | 193 ++ .../activemq/usecases/browse-broker2B.xml | 195 ++ .../activemq/usecases/browse-broker3A.xml | 192 ++ .../activemq/usecases/browse-broker3B.xml | 191 ++ .../activemq/usecases/multicast-broker-1.xml | 44 + .../activemq/usecases/multicast-broker-2.xml | 41 + .../activemq/usecases/multicast-broker-auto.xml | 44 + .../activemq/usecases/rebalance-broker1.xml | 30 + .../activemq/usecases/rebalance-broker2.xml | 31 + .../activemq/usecases/rebalance-broker3.xml | 30 + .../usecases/receiver-activecluster.xml | 37 + .../activemq/usecases/receiver-discovery.xml | 44 + .../activemq/usecases/receiver-duplex.xml | 46 + .../apache/activemq/usecases/receiver-http.xml | 41 + .../activemq/usecases/receiver-secured.xml | 78 + .../activemq/usecases/receiver-zeroconf.xml | 42 + .../org/apache/activemq/usecases/receiver.xml | 41 + .../activemq/usecases/replication-broker1.xml | 121 ++ .../activemq/usecases/replication-broker2.xml | 120 ++ .../activemq/usecases/replication-broker3.xml | 120 ++ .../activemq/usecases/replication-broker4.xml | 120 ++ .../activemq/usecases/rerouting-activemq-A.xml | 54 + .../activemq/usecases/rerouting-activemq-B.xml | 41 + .../activemq/usecases/rerouting-activemq-C.xml | 42 + .../activemq/usecases/rerouting-activemq-D.xml | 45 + .../activemq/usecases/sender-activecluster.xml | 42 + .../activemq/usecases/sender-discovery.xml | 43 + .../apache/activemq/usecases/sender-duplex.xml | 63 + .../apache/activemq/usecases/sender-http.xml | 39 + .../apache/activemq/usecases/sender-secured.xml | 82 + .../activemq/usecases/sender-zeroconf.xml | 42 + .../org/apache/activemq/usecases/sender.xml | 45 + .../apache/activemq/util/ConsumerThread.java | 80 + .../activemq/util/DefaultTestAppender.java | 83 + .../apache/activemq/util/LinkedNodeTest.java | 173 ++ .../org/apache/activemq/util/MessageIdList.java | 273 +++ .../apache/activemq/util/ProducerThread.java | 82 + .../activemq/util/ReflectionSupportTest.java | 115 ++ .../org/apache/activemq/util/SimplePojo.java | 84 + .../org/apache/activemq/util/plugin-broker.xml | 45 + .../xbean/ConnectorXBeanConfigTest.java | 213 +++ .../JDBCPersistenceAdapterXBeanConfigTest.java | 60 + .../xbean/JDBCPersistenceXBeanConfigTest.java | 62 + .../xbean/ManagementContextXBeanConfigTest.java | 106 ++ ...stsWithEmbeddedBrokerAndPersistenceTest.java | 29 + .../MultipleTestsWithEmbeddedBrokerTest.java | 57 + .../MultipleTestsWithSpringFactoryBeanTest.java | 81 + ...ipleTestsWithSpringXBeanFactoryBeanTest.java | 44 + .../MultipleTestsWithXBeanFactoryBeanTest.java | 36 + .../apache/activemq/xbean/XBeanConfigTest.java | 121 ++ .../activemq/xbean/XBeanStartFalseTest.java | 33 + .../org/apache/activemq/xbean/XBeanXmlTest.java | 26 + .../apache/activemq/xbean/activemq-policy.xml | 77 + .../java/org/apache/activemq/xbean/activemq.xml | 65 + .../org/apache/activemq/xbean/activemq2.xml | 56 + .../apache/activemq/xbean/connector-test.xml | 61 + .../xbean/jdbc-persistence-adapter-test.xml | 44 + .../activemq/xbean/jdbc-persistence-test.xml | 42 + .../activemq/xbean/management-context-test.xml | 44 + .../java/org/apache/activemq/xbean/spring.xml | 74 + .../java/org/apache/activemq/xbean/spring2.xml | 24 + .../src/test/java/provider.properties | 20 + .../src/test/java/server.keystore | 0 .../java/spring-embedded-xbean-bean-ref.xml | 101 + .../test/java/spring-embedded-xbean-local.xml | 80 + .../java/spring-embedded-xbean-noversion.xml | 80 + .../src/test/java/spring-embedded-xbean.xml | 80 + .../src/test/java/spring-embedded.xml | 83 + .../src/test/java/spring-jndi.xml | 119 ++ .../src/test/java/spring-queue.xml | 86 + .../src/test/java/spring-start-false.xml | 55 + .../src/test/java/spring.xml | 79 + .../src/test/java/test.properties | 20 + .../test/resources/activemq-browse.properties | 61 + .../src/test/resources/activemq-partition.xml | 58 + .../src/test/resources/activemq.xml | 37 + .../src/test/resources/client.keystore | 0 .../src/test/resources/credentials.properties | 24 + .../src/test/resources/dummy.keystore | 0 .../src/test/resources/jmx.access | 18 + .../src/test/resources/jmx.password | 18 + .../src/test/resources/jndi.properties | 38 + .../src/test/resources/log4j.properties | 46 + .../src/test/resources/login.config | 87 + .../src/test/resources/provider.properties | 20 + .../src/test/resources/server.keystore | 0 .../spring-embedded-xbean-bean-ref.xml | 101 + .../resources/spring-embedded-xbean-local.xml | 80 + .../spring-embedded-xbean-noversion.xml | 80 + .../test/resources/spring-embedded-xbean.xml | 80 + .../src/test/resources/spring-embedded.xml | 83 + .../src/test/resources/spring-jndi.xml | 119 ++ .../src/test/resources/spring-queue.xml | 86 + .../src/test/resources/spring-start-false.xml | 55 + .../src/test/resources/spring.xml | 79 + .../src/test/resources/test.properties | 20 + tests/pom.xml | 9 + 1630 files changed, 190668 insertions(+) ----------------------------------------------------------------------
