This closes #258
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/8abf9cfa Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/8abf9cfa Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/8abf9cfa Branch: refs/heads/master Commit: 8abf9cfaa6fa4b09a418f4d40e91517746d4427a Parents: b0007c4 6288f37 Author: Clebert Suconic <clebertsuco...@apache.org> Authored: Mon Dec 7 19:09:05 2015 -0500 Committer: Clebert Suconic <clebertsuco...@apache.org> Committed: Mon Dec 7 19:09:05 2015 -0500 ---------------------------------------------------------------------- .../apache/activemq/artemis/boot/Artemis.java | 8 +- .../apache/activemq/artemis/cli/Artemis.java | 3 +- .../activemq/artemis/cli/commands/Create.java | 4 +- .../cli/commands/tools/DecodeJournal.java | 2 +- .../artemis/cli/commands/tools/PrintData.java | 12 +- .../artemis/integration/FileBroker.java | 2 +- .../artemis/api/core/ActiveMQExceptionType.java | 2 +- .../activemq/artemis/api/core/SimpleString.java | 2 +- .../artemis/utils/ConcurrentHashSet.java | 2 +- .../activemq/artemis/utils/FactoryFinder.java | 2 +- .../apache/activemq/artemis/utils/FileUtil.java | 3 +- .../artemis/utils/PasswordMaskingUtil.java | 2 +- .../activemq/artemis/utils/TypedProperties.java | 8 +- .../apache/activemq/artemis/utils/UTF8Util.java | 6 +- .../activemq/artemis/utils/UUIDGenerator.java | 4 +- .../activemq/artemis/utils/uri/URISchema.java | 2 +- .../apache/activemq/artemis/utils/PairTest.java | 2 +- .../api/core/JGroupsBroadcastEndpoint.java | 4 +- .../api/core/TransportConfiguration.java | 2 +- .../api/core/management/ManagementHelper.java | 4 +- .../core/client/impl/AddressQueryImpl.java | 2 +- .../core/client/impl/ClientConsumerImpl.java | 2 +- .../impl/ClientProducerCreditManagerImpl.java | 4 +- .../client/impl/ClientSessionFactoryImpl.java | 18 +-- .../core/client/impl/ClientSessionImpl.java | 12 +- .../core/client/impl/DelegatingSession.java | 2 +- .../core/client/impl/ServerLocatorImpl.java | 14 +- .../artemis/core/client/impl/Topology.java | 2 +- .../core/client/impl/TopologyMemberImpl.java | 2 +- .../artemis/core/cluster/DiscoveryGroup.java | 8 +- .../artemis/core/message/impl/MessageImpl.java | 2 +- .../core/protocol/core/impl/ChannelImpl.java | 2 +- .../core/impl/RemotingConnectionImpl.java | 4 +- .../ClusterTopologyChangeMessage.java | 2 +- .../ClusterTopologyChangeMessage_V2.java | 2 +- .../SessionBindingQueryResponseMessage.java | 2 +- .../SessionXAGetInDoubtXidsResponseMessage.java | 2 +- .../impl/TransportConfigurationUtil.java | 2 +- .../remoting/impl/netty/NettyConnection.java | 2 +- .../remoting/impl/netty/NettyConnector.java | 4 +- .../impl/netty/SharedNioEventLoopGroup.java | 2 +- .../remoting/impl/netty/TransportConstants.java | 4 +- .../activemq/artemis/reader/MessageUtil.java | 4 +- .../protocol/AbstractRemotingConnection.java | 12 +- .../artemis/utils/ConfigurationHelper.java | 4 +- .../activemq/artemis/utils/LinkedListImpl.java | 6 +- .../activemq/artemis/utils/MemorySize.java | 2 +- .../artemis/utils/OrderedExecutorFactory.java | 2 +- .../artemis/utils/PriorityLinkedListImpl.java | 2 +- .../artemis/utils/SecurityFormatter.java | 6 +- .../artemis/utils/SoftValueHashMap.java | 12 +- .../activemq/artemis/utils/VersionLoader.java | 2 +- .../apache/activemq/artemis/utils/XMLUtil.java | 2 +- .../activemq/artemis/utils/json/JSONArray.java | 6 +- .../artemis/util/CompressionUtilTest.java | 6 +- .../artemis/util/ConcurrentHashSetTest.java | 2 +- .../util/TimeAndCounterIDGeneratorTest.java | 2 +- .../artemis/jms/client/ActiveMQConnection.java | 12 +- .../jms/client/ActiveMQConnectionMetaData.java | 2 +- .../artemis/jms/client/ActiveMQDestination.java | 2 +- .../artemis/jms/client/ActiveMQJMSProducer.java | 2 +- .../artemis/jms/client/ActiveMQMapMessage.java | 2 +- .../artemis/jms/client/ActiveMQMessage.java | 4 +- .../artemis/jms/client/ActiveMQSession.java | 4 +- .../artemis/jms/client/SelectorTranslator.java | 2 +- .../artemis/jms/client/ThreadAwareContext.java | 2 +- .../activemq/artemis/jndi/ReadOnlyContext.java | 22 +-- .../artemis/uri/ConnectionFactoryURITest.java | 2 +- .../artemis/jms/bridge/impl/JMSBridgeImpl.java | 5 +- .../management/impl/JMSQueueControlImpl.java | 2 +- .../management/impl/JMSServerControlImpl.java | 10 +- .../management/impl/JMSTopicControlImpl.java | 4 +- .../persistence/config/PersistedBindings.java | 4 +- .../journal/JMSJournalStorageManagerImpl.java | 30 ++-- .../ConnectionFactoryConfigurationImpl.java | 2 +- .../config/impl/JMSConfigurationImpl.java | 6 +- .../TransportConfigurationEncodingSupport.java | 6 +- .../jms/server/impl/JMSServerManagerImpl.java | 35 ++-- .../core/io/aio/AIOSequentialFileFactory.java | 2 +- .../artemis/core/io/buffer/TimedBuffer.java | 4 +- .../core/io/nio/NIOSequentialFileFactory.java | 2 +- .../core/journal/PreparedTransactionInfo.java | 4 +- .../journal/impl/AbstractJournalUpdateTask.java | 4 +- .../core/journal/impl/FileWrapperJournal.java | 2 +- .../core/journal/impl/JournalCompactor.java | 12 +- .../core/journal/impl/JournalFileImpl.java | 2 +- .../journal/impl/JournalFilesRepository.java | 6 +- .../artemis/core/journal/impl/JournalImpl.java | 30 ++-- .../core/journal/impl/JournalRecord.java | 4 +- .../core/journal/impl/JournalTransaction.java | 14 +- .../artemis/maven/ArtemisAbstractPlugin.java | 2 +- .../converter/jms/ServerJMSMapMessage.java | 2 +- .../core/protocol/proton/TestConversions.java | 2 +- .../hornetq/util/HQPropertiesConverter.java | 2 +- .../core/protocol/mqtt/MQTTConnection.java | 4 +- .../protocol/mqtt/MQTTConnectionManager.java | 2 +- .../core/protocol/mqtt/MQTTSessionState.java | 4 +- .../protocol/openwire/OpenWireConnection.java | 24 +-- .../openwire/OpenWireProtocolManager.java | 14 +- .../core/protocol/openwire/amq/AMQConsumer.java | 2 +- .../protocol/openwire/amq/AMQServerSession.java | 8 +- .../core/protocol/openwire/amq/AMQSession.java | 2 +- .../context/AbstractProtonSessionContext.java | 4 +- .../server/ProtonServerSessionContext.java | 2 +- .../org/proton/plug/test/AbstractJMSTest.java | 2 +- .../protocol/stomp/ActiveMQStompException.java | 2 +- .../core/protocol/stomp/StompConnection.java | 14 +- .../core/protocol/stomp/StompDecoder.java | 2 +- .../artemis/core/protocol/stomp/StompFrame.java | 2 +- .../protocol/stomp/StompProtocolManager.java | 6 +- .../core/protocol/stomp/StompSession.java | 6 +- .../artemis/core/protocol/stomp/StompUtils.java | 2 +- .../core/protocol/stomp/v11/StompFrameV11.java | 2 +- .../ra/ActiveMQRAConnectionMetaData.java | 2 +- .../artemis/ra/ActiveMQRAManagedConnection.java | 2 +- .../ra/ActiveMQRAManagedConnectionFactory.java | 2 +- .../activemq/artemis/ra/ActiveMQRASession.java | 4 +- .../ra/ActiveMQRASessionFactoryImpl.java | 6 +- .../activemq/artemis/ra/ActiveMQRaUtils.java | 8 +- .../artemis/ra/ActiveMQResourceAdapter.java | 12 +- .../artemis/ra/inflow/ActiveMQActivation.java | 8 +- .../ra/inflow/ActiveMQActivationSpec.java | 4 +- .../ra/inflow/ActiveMQMessageHandler.java | 2 +- .../artemis/ra/recovery/RecoveryManager.java | 2 +- .../artemis/rest/MessageServiceManager.java | 2 +- .../artemis/rest/queue/ConsumersResource.java | 2 +- .../artemis/rest/queue/PostMessage.java | 2 +- .../rest/queue/QueueDestinationsResource.java | 2 +- .../artemis/rest/queue/QueueServiceManager.java | 2 +- .../artemis/rest/queue/push/FilePushStore.java | 8 +- .../artemis/rest/queue/push/PushConsumer.java | 4 +- .../rest/queue/push/PushConsumerResource.java | 2 +- .../rest/queue/push/xml/PushRegistration.java | 2 +- .../artemis/rest/topic/FileTopicPushStore.java | 2 +- .../rest/topic/PushSubscriptionsResource.java | 2 +- .../rest/topic/SubscriptionsResource.java | 2 +- .../rest/topic/TopicDestinationsResource.java | 2 +- .../artemis/rest/topic/TopicServiceManager.java | 2 +- .../activemq/artemis/rest/util/TimeoutTask.java | 10 +- .../activemq/artemis/rest/test/RawAckTest.java | 2 +- .../selector/filter/ComparisonExpression.java | 4 +- .../selector/filter/UnaryExpression.java | 4 +- .../activemq/artemis/selector/SelectorTest.java | 10 +- .../activemq/artemis/osgi/OsgiBroker.java | 4 +- .../activemq/artemis/osgi/ProtocolTracker.java | 4 +- .../core/config/impl/ConfigurationImpl.java | 30 ++-- .../core/config/impl/SecurityConfiguration.java | 4 +- .../deployers/impl/FileConfigurationParser.java | 36 ++--- .../impl/ActiveMQServerControlImpl.java | 13 +- .../management/impl/AddressControlImpl.java | 4 +- .../core/management/impl/MBeanInfoHelper.java | 2 +- .../core/management/impl/QueueControlImpl.java | 6 +- .../core/messagecounter/MessageCounter.java | 4 +- .../impl/MessageCounterManagerImpl.java | 4 +- .../core/paging/cursor/PagedReferenceImpl.java | 4 +- .../paging/cursor/impl/LivePageCacheImpl.java | 2 +- .../cursor/impl/PageCursorProviderImpl.java | 8 +- .../impl/PageSubscriptionCounterImpl.java | 14 +- .../cursor/impl/PageSubscriptionImpl.java | 18 +-- .../activemq/artemis/core/paging/impl/Page.java | 4 +- .../artemis/core/paging/impl/PageSyncTimer.java | 2 +- .../paging/impl/PageTransactionInfoImpl.java | 2 +- .../core/paging/impl/PagingManagerImpl.java | 4 +- .../core/paging/impl/PagingStoreFactoryNIO.java | 2 +- .../core/paging/impl/PagingStoreImpl.java | 6 +- .../impl/journal/DescribeJournal.java | 10 +- .../impl/journal/JournalStorageManager.java | 50 +++--- .../impl/journal/OperationContextImpl.java | 4 +- .../core/postoffice/impl/AddressImpl.java | 2 +- .../core/postoffice/impl/BindingsImpl.java | 10 +- .../postoffice/impl/DuplicateIDCacheImpl.java | 8 +- .../core/postoffice/impl/PostOfficeImpl.java | 20 +-- .../postoffice/impl/SimpleAddressManager.java | 6 +- .../postoffice/impl/WildcardAddressManager.java | 4 +- .../protocol/core/impl/CoreProtocolManager.java | 8 +- .../BackupReplicationStartFailedMessage.java | 2 +- .../core/registry/MapBindingRegistry.java | 2 +- .../core/remoting/impl/invm/InVMAcceptor.java | 2 +- .../core/remoting/impl/invm/InVMConnection.java | 2 +- .../core/remoting/impl/invm/InVMConnector.java | 4 +- .../core/remoting/impl/invm/InVMRegistry.java | 2 +- .../impl/netty/HttpAcceptorHandler.java | 4 +- .../impl/netty/HttpKeepAliveRunnable.java | 2 +- .../core/remoting/impl/netty/NettyAcceptor.java | 2 +- .../server/impl/RemotingServiceImpl.java | 12 +- .../core/replication/ReplicationEndpoint.java | 10 +- .../core/replication/ReplicationManager.java | 6 +- .../core/security/impl/SecurityStoreImpl.java | 4 +- .../core/server/cluster/ClusterManager.java | 12 +- .../core/server/cluster/impl/BridgeImpl.java | 6 +- .../server/cluster/impl/BroadcastGroupImpl.java | 2 +- .../cluster/impl/ClusterConnectionBridge.java | 6 +- .../cluster/impl/ClusterConnectionImpl.java | 12 +- .../cluster/impl/RemoteQueueBindingImpl.java | 4 +- .../server/group/impl/LocalGroupingHandler.java | 16 +- .../group/impl/RemoteGroupingHandler.java | 6 +- .../core/server/impl/ActiveMQServerImpl.java | 18 +-- .../impl/AnyLiveNodeLocatorForReplication.java | 6 +- .../core/server/impl/ConnectorsService.java | 2 +- .../core/server/impl/LastValueQueue.java | 2 +- .../impl/LegacyLDAPSecuritySettingPlugin.java | 4 +- .../NamedLiveNodeLocatorForReplication.java | 2 +- .../impl/NamedLiveNodeLocatorForScaleDown.java | 2 +- .../server/impl/PostOfficeJournalLoader.java | 6 +- .../artemis/core/server/impl/QueueImpl.java | 22 +-- .../artemis/core/server/impl/RefsOperation.java | 12 +- .../core/server/impl/RoutingContextImpl.java | 6 +- .../core/server/impl/ScaleDownHandler.java | 2 +- .../impl/ScheduledDeliveryHandlerImpl.java | 8 +- .../core/server/impl/ServerConsumerImpl.java | 6 +- .../core/server/impl/ServerSessionImpl.java | 28 ++-- .../management/impl/ManagementServiceImpl.java | 16 +- .../impl/HierarchicalObjectRepository.java | 18 +-- .../transaction/impl/ResourceManagerImpl.java | 12 +- .../core/transaction/impl/TransactionImpl.java | 6 +- .../security/jaas/CertificateLoginModule.java | 2 +- .../core/security/jaas/GuestLoginModule.java | 2 +- .../spi/core/security/jaas/InVMLoginModule.java | 2 +- .../spi/core/security/jaas/LDAPLoginModule.java | 14 +- .../core/security/jaas/PropertiesLoader.java | 2 +- .../security/jaas/PropertiesLoginModule.java | 2 +- .../jaas/TextFileCertificateLoginModule.java | 2 +- .../impl/FileConfigurationParserTest.java | 2 +- .../core/list/PriorityLinkedListTest.java | 2 +- .../jaas/CertificateLoginModuleTest.java | 8 +- .../PropertiesLoginModuleRaceConditionTest.java | 6 +- .../core/security/jaas/StubX509Certificate.java | 4 +- .../group/impl/ClusteredResetMockTest.java | 4 +- .../impl/ScheduledDeliveryHandlerTest.java | 2 +- .../artemis/core/settings/RepositoryTest.java | 18 +-- .../artemis/tests/util/ActiveMQTestBase.java | 52 +++--- .../xa/recovery/ActiveMQXAResourceRecovery.java | 2 +- .../xa/ActiveMQXAResourceWrapperImplTest.java | 2 +- .../jms/example/ClusteredJgroupsExample.java | 4 +- .../ColocatedFailoverScaleDownExample.java | 4 +- .../jms/example/ColocatedFailoverExample.java | 4 +- .../jms/example/HAPolicyAutoBackupExample.java | 2 +- .../artemis/jms/example/ScaleDownExample.java | 4 +- .../artemis/jms/example/BridgeExample.java | 4 +- .../jms/example/ClientKickoffExample.java | 2 +- .../artemis/jms/example/EmbeddedExample.java | 2 +- .../artemis/jms/example/EmbeddedExample.java | 2 +- .../artemis/jms/example/JMSBridgeExample.java | 2 +- .../jms/example/MessageGroupExample.java | 2 +- .../jms/example/MessageGroup2Example.java | 2 +- .../jms/example/MessagePriorityExample.java | 2 +- .../jms/example/RequestReplyExample.java | 2 +- .../jms-to-rest/src/main/java/JmsReceive.java | 2 +- .../rest/jms-to-rest/src/main/java/JmsSend.java | 2 +- .../rest/push/src/main/java/PostOrder.java | 2 +- .../push/src/main/java/ReceiveShipping.java | 2 +- .../artemis/jms/example/XAHeuristicExample.java | 2 +- .../artemis/jms/example/XASendExample.java | 2 +- .../integration/vertx/VertxConstants.java | 8 +- .../activemq/ActiveMQConnectionFactory.java | 3 +- .../apache/activemq/broker/BrokerService.java | 4 +- .../activemq/broker/SslBrokerService.java | 3 - .../artemiswrapper/ArtemisBrokerWrapper.java | 12 +- .../artemiswrapper/InVMNamingContext.java | 6 +- .../artemiswrapper/NonSerializableFactory.java | 1 - .../transport/tcp/TcpTransportFactory.java | 4 +- .../org/apache/activemq/usage/SystemUsage.java | 2 +- .../activemq/ActiveMQInputStreamTest.java | 2 - .../activemq/ActiveMQMessageAuditTest.java | 8 +- .../ActiveMQXAConnectionFactoryTest.java | 2 +- .../apache/activemq/CombinationTestSupport.java | 18 +-- .../org/apache/activemq/JMSConsumerTest.java | 1 - .../org/apache/activemq/JMSMessageTest.java | 4 +- .../activemq/JmsConnectionStartStopTest.java | 2 +- .../JmsConsumerResetActiveListenerTest.java | 4 +- .../activemq/JmsMultipleBrokersTestSupport.java | 6 +- .../activemq/JmsMultipleClientsTestSupport.java | 2 +- .../apache/activemq/JmsQueueBrowserTest.java | 5 +- ...eiveTwoConnectionsStartBeforeBrokerTest.java | 2 +- .../org/apache/activemq/JmsRedeliveredTest.java | 2 - .../activemq/JmsRollbackRedeliveryTest.java | 6 +- ...JmsSendReceiveWithMessageExpirationTest.java | 6 +- .../apache/activemq/JmsTempDestinationTest.java | 2 +- .../activemq/JmsTopicRequestReplyTest.java | 2 +- .../org/apache/activemq/LoadTestBurnIn.java | 3 +- .../apache/activemq/MessageEvictionTest.java | 2 +- .../activemq/MessageListenerRedeliveryTest.java | 2 +- .../activemq/MessageTransformationTest.java | 30 ++-- .../activemq/PerDestinationStoreLimitTest.java | 2 +- .../activemq/ProducerFlowControlTest.java | 2 +- .../org/apache/activemq/SpringTestSupport.java | 4 +- .../java/org/apache/activemq/TestSupport.java | 2 - .../advisory/AdvisoryTempDestinationTests.java | 2 +- .../activemq/advisory/ConsumerListenerTest.java | 2 +- .../advisory/DestinationListenerTest.java | 2 +- .../activemq/advisory/ProducerListenerTest.java | 2 +- .../activemq/advisory/TempDestDeleteTest.java | 2 +- .../activemq/advisory/TempQueueMemoryTest.java | 2 +- .../apache/activemq/blob/FTPTestSupport.java | 2 +- .../org/apache/activemq/broker/AMQ4351Test.java | 2 +- .../apache/activemq/broker/BrokerBenchmark.java | 2 - .../activemq/broker/BrokerRedeliveryTest.java | 1 - .../org/apache/activemq/broker/BrokerTest.java | 6 +- .../activemq/broker/BrokerTestSupport.java | 4 +- .../DurablePersistentFalseRestartTest.java | 2 +- .../activemq/broker/MarshallingBrokerTest.java | 4 +- .../broker/NioQueueSubscriptionTest.java | 2 +- .../activemq/broker/OutOfOrderXMLTest.java | 1 - .../activemq/broker/QueueMbeanRestartTest.java | 2 +- .../activemq/broker/RecoveryBrokerTest.java | 6 +- .../org/apache/activemq/broker/StubBroker.java | 4 +- .../apache/activemq/broker/StubConnection.java | 4 +- .../activemq/broker/TopicSubscriptionTest.java | 6 - .../activemq/broker/XARecoveryBrokerTest.java | 2 +- .../broker/advisory/AdvisoryJmxTest.java | 2 +- .../broker/ft/JDBCQueueMasterSlaveTest.java | 6 - .../broker/ft/QueueMasterSlaveTestSupport.java | 2 +- .../broker/jmx/MBeanOperationTimeoutTest.java | 2 +- .../apache/activemq/broker/jmx/MBeanTest.java | 2 +- .../apache/activemq/broker/jmx/PurgeTest.java | 12 +- .../broker/mLevelDBXARecoveryBrokerTest.java | 1 - .../policy/AbortSlowAckConsumer0Test.java | 1 - .../broker/policy/AbortSlowConsumer0Test.java | 1 - .../broker/policy/AbortSlowConsumerBase.java | 18 +-- .../policy/MessageListenerDeadLetterTest.java | 2 - .../broker/policy/NoConsumerDeadLetterTest.java | 9 +- .../PriorityNetworkDispatchPolicyTest.java | 2 +- .../policy/StrictOrderDispatchPolicyTest.java | 4 +- .../region/QueueDuplicatesFromStoreTest.java | 5 +- .../region/QueueResendDuringShutdownTest.java | 3 - .../region/SubscriptionAddRemoveQueueTest.java | 4 +- ...iquePropertyMessageEvictionStrategyTest.java | 2 +- .../broker/region/cursors/CursorSupport.java | 8 +- .../region/cursors/NegativeQueueTest.java | 6 +- .../region/cursors/OrderPendingListTest.java | 2 +- .../StoreQueueCursorLevelDBNoDuplicateTest.java | 3 - .../broker/scheduler/JobSchedulerStoreTest.java | 2 +- .../KahaDBSchedulerMissingJournalLogsTest.java | 4 +- .../memory/InMemoryJobSchedulerStoreTest.java | 2 +- .../store/RecoverExpiredMessagesTest.java | 2 +- .../DestinationInterceptorDurableSubTest.java | 2 +- .../MirroredQueueCorrectMemoryUsageTest.java | 2 +- .../broker/virtual/VirtualDestPerfTest.java | 11 +- .../broker/virtual/VirtualTopicDLQTest.java | 2 +- .../broker/virtual/VirtualTopicPubSubTest.java | 2 +- .../org/apache/activemq/bugs/AMQ1853Test.java | 4 +- .../java/org/apache/activemq/bugs/AMQ1866.java | 2 +- .../org/apache/activemq/bugs/AMQ1917Test.java | 2 +- .../org/apache/activemq/bugs/AMQ1936Test.java | 3 +- .../org/apache/activemq/bugs/AMQ2021Test.java | 4 +- .../org/apache/activemq/bugs/AMQ2103Test.java | 3 +- .../org/apache/activemq/bugs/AMQ2149Test.java | 9 +- .../org/apache/activemq/bugs/AMQ2171Test.java | 5 +- .../org/apache/activemq/bugs/AMQ2401Test.java | 2 +- .../org/apache/activemq/bugs/AMQ2413Test.java | 6 +- .../org/apache/activemq/bugs/AMQ2489Test.java | 4 +- .../org/apache/activemq/bugs/AMQ2512Test.java | 2 +- .../activemq/bugs/AMQ2584ConcurrentDlqTest.java | 2 +- .../org/apache/activemq/bugs/AMQ2584Test.java | 2 +- .../org/apache/activemq/bugs/AMQ2616Test.java | 2 +- .../org/apache/activemq/bugs/AMQ2801Test.java | 2 +- .../org/apache/activemq/bugs/AMQ2870Test.java | 2 +- .../org/apache/activemq/bugs/AMQ2910Test.java | 2 +- .../org/apache/activemq/bugs/AMQ2983Test.java | 2 +- .../org/apache/activemq/bugs/AMQ3014Test.java | 1 - .../org/apache/activemq/bugs/AMQ3140Test.java | 2 +- .../org/apache/activemq/bugs/AMQ3167Test.java | 2 +- .../org/apache/activemq/bugs/AMQ3274Test.java | 6 +- .../org/apache/activemq/bugs/AMQ3405Test.java | 2 - .../org/apache/activemq/bugs/AMQ3622Test.java | 2 +- .../org/apache/activemq/bugs/AMQ3625Test.java | 1 - .../org/apache/activemq/bugs/AMQ3674Test.java | 2 +- .../org/apache/activemq/bugs/AMQ3732Test.java | 2 +- .../org/apache/activemq/bugs/AMQ3841Test.java | 2 +- .../org/apache/activemq/bugs/AMQ3961Test.java | 6 +- .../org/apache/activemq/bugs/AMQ4062Test.java | 1 - .../org/apache/activemq/bugs/AMQ4083Test.java | 6 +- .../org/apache/activemq/bugs/AMQ4092Test.java | 2 +- .../org/apache/activemq/bugs/AMQ4157Test.java | 2 +- .../org/apache/activemq/bugs/AMQ4220Test.java | 2 +- .../org/apache/activemq/bugs/AMQ4221Test.java | 2 +- .../org/apache/activemq/bugs/AMQ4361Test.java | 4 +- .../org/apache/activemq/bugs/AMQ4407Test.java | 2 +- .../org/apache/activemq/bugs/AMQ4413Test.java | 2 +- .../org/apache/activemq/bugs/AMQ4475Test.java | 2 +- .../activemq/bugs/AMQ4485LowLimitTest.java | 11 +- ...XBrokersWithNDestsFanoutTransactionTest.java | 10 +- .../org/apache/activemq/bugs/AMQ4485Test.java | 6 +- .../org/apache/activemq/bugs/AMQ4607Test.java | 4 +- .../org/apache/activemq/bugs/AMQ4677Test.java | 2 - .../org/apache/activemq/bugs/AMQ4853Test.java | 2 +- .../org/apache/activemq/bugs/AMQ4950Test.java | 2 +- .../org/apache/activemq/bugs/AMQ4952Test.java | 6 +- .../activemq/bugs/AMQ5266SingleDestTest.java | 10 +- .../bugs/AMQ5266StarvedConsumerTest.java | 14 +- .../org/apache/activemq/bugs/AMQ5266Test.java | 11 +- .../org/apache/activemq/bugs/AMQ5450Test.java | 2 +- .../activemq/bugs/DurableConsumerTest.java | 4 +- .../bugs/MemoryUsageBlockResumeTest.java | 4 +- .../OptimizeAcknowledgeWithExpiredMsgsTest.java | 2 +- .../activemq/bugs/QueueWorkerPrefetchTest.java | 2 +- .../bugs/RawRollbackSharedConsumerTests.java | 4 +- .../apache/activemq/bugs/RawRollbackTests.java | 4 +- .../bugs/TrapMessageInJDBCStoreTest.java | 7 +- .../activemq/bugs/amq1095/ActiveMQTestCase.java | 2 +- .../command/ActiveMQDestinationTest.java | 4 +- .../command/ActiveMQMapMessageTest.java | 3 +- .../command/ActiveMQStreamMessageTest.java | 4 +- .../config/BrokerXmlConfigFromJNDITest.java | 2 +- .../activemq/console/command/AMQ3410Test.java | 10 +- .../activemq/console/command/AMQ3411Test.java | 10 +- .../console/command/PurgeCommandTest.java | 12 +- .../ActiveMQWASInitialContextFactoryTest.java | 3 +- .../apache/activemq/jndi/JNDITestSupport.java | 2 +- .../activemq/joramtests/ActiveMQAdmin.java | 3 +- .../BrokerNetworkWithStuckMessagesTest.java | 10 +- .../CheckDuplicateMessagesOnDuplexTest.java | 4 +- .../network/FailoverStaticNetworkTest.java | 12 +- .../network/NetworkDestinationFilterTest.java | 2 +- .../activemq/network/NetworkFailoverTest.java | 1 - .../activemq/network/NetworkLoadTest.java | 4 +- .../activemq/network/NetworkReconnectTest.java | 2 +- .../activemq/network/NetworkTestSupport.java | 2 +- .../network/SSHTunnelNetworkReconnectTest.java | 2 +- .../jms/QueueBridgeStandaloneReconnectTest.java | 2 +- .../jms/QueueOutboundBridgeReconnectTest.java | 2 +- .../jms/TopicBridgeStandaloneReconnectTest.java | 2 +- .../jms/TopicOutboundBridgeReconnectTest.java | 2 +- .../activemq/openwire/DataFileGenerator.java | 2 +- .../openwire/DataFileGeneratorTestSupport.java | 2 +- .../activemq/openwire/v4/BrokerIdTest.java | 4 - .../activemq/openwire/v4/BrokerInfoTest.java | 5 - .../openwire/v4/ConnectionControlTest.java | 5 - .../openwire/v4/ConnectionErrorTest.java | 5 - .../activemq/openwire/v4/ConnectionIdTest.java | 4 - .../openwire/v4/ConnectionInfoTest.java | 5 - .../openwire/v4/ConsumerControlTest.java | 5 - .../activemq/openwire/v4/ConsumerIdTest.java | 4 - .../activemq/openwire/v4/ConsumerInfoTest.java | 5 - .../openwire/v4/ControlCommandTest.java | 5 - .../openwire/v4/DataArrayResponseTest.java | 5 - .../activemq/openwire/v4/DataResponseTest.java | 5 - .../openwire/v4/DestinationInfoTest.java | 5 - .../openwire/v4/DiscoveryEventTest.java | 4 - .../openwire/v4/ExceptionResponseTest.java | 5 - .../activemq/openwire/v4/FlushCommandTest.java | 5 - .../openwire/v4/IntegerResponseTest.java | 5 - .../openwire/v4/JournalQueueAckTest.java | 4 - .../openwire/v4/JournalTopicAckTest.java | 4 - .../activemq/openwire/v4/JournalTraceTest.java | 4 - .../openwire/v4/JournalTransactionTest.java | 4 - .../activemq/openwire/v4/KeepAliveInfoTest.java | 5 - .../openwire/v4/LastPartialCommandTest.java | 5 - .../openwire/v4/LocalTransactionIdTest.java | 5 - .../activemq/openwire/v4/MessageAckTest.java | 5 - .../v4/MessageDispatchNotificationTest.java | 5 - .../openwire/v4/MessageDispatchTest.java | 5 - .../activemq/openwire/v4/MessageIdTest.java | 4 - .../activemq/openwire/v4/MessagePullTest.java | 5 - .../openwire/v4/NetworkBridgeFilterTest.java | 4 - .../openwire/v4/PartialCommandTest.java | 4 - .../activemq/openwire/v4/ProducerAckTest.java | 5 - .../activemq/openwire/v4/ProducerIdTest.java | 4 - .../activemq/openwire/v4/ProducerInfoTest.java | 5 - .../activemq/openwire/v4/RemoveInfoTest.java | 5 - .../openwire/v4/RemoveSubscriptionInfoTest.java | 5 - .../activemq/openwire/v4/ReplayCommandTest.java | 5 - .../activemq/openwire/v4/ResponseTest.java | 5 - .../activemq/openwire/v4/SessionIdTest.java | 4 - .../activemq/openwire/v4/SessionInfoTest.java | 5 - .../activemq/openwire/v4/ShutdownInfoTest.java | 5 - .../openwire/v4/SubscriptionInfoTest.java | 4 - .../openwire/v4/TransactionIdTestSupport.java | 4 - .../openwire/v4/TransactionInfoTest.java | 5 - .../openwire/v4/XATransactionIdTest.java | 5 - .../activemq/openwire/v5/BrokerIdTest.java | 4 - .../activemq/openwire/v5/BrokerInfoTest.java | 5 - .../openwire/v5/ConnectionControlTest.java | 5 - .../openwire/v5/ConnectionErrorTest.java | 5 - .../activemq/openwire/v5/ConnectionIdTest.java | 4 - .../openwire/v5/ConnectionInfoTest.java | 5 - .../openwire/v5/ConsumerControlTest.java | 5 - .../activemq/openwire/v5/ConsumerIdTest.java | 4 - .../activemq/openwire/v5/ConsumerInfoTest.java | 5 - .../openwire/v5/ControlCommandTest.java | 5 - .../openwire/v5/DataArrayResponseTest.java | 5 - .../activemq/openwire/v5/DataResponseTest.java | 5 - .../openwire/v5/DestinationInfoTest.java | 5 - .../openwire/v5/DiscoveryEventTest.java | 4 - .../openwire/v5/ExceptionResponseTest.java | 5 - .../activemq/openwire/v5/FlushCommandTest.java | 5 - .../openwire/v5/IntegerResponseTest.java | 5 - .../openwire/v5/JournalQueueAckTest.java | 4 - .../openwire/v5/JournalTopicAckTest.java | 4 - .../activemq/openwire/v5/JournalTraceTest.java | 4 - .../openwire/v5/JournalTransactionTest.java | 4 - .../activemq/openwire/v5/KeepAliveInfoTest.java | 5 - .../openwire/v5/LastPartialCommandTest.java | 5 - .../openwire/v5/LocalTransactionIdTest.java | 5 - .../activemq/openwire/v5/MessageAckTest.java | 5 - .../v5/MessageDispatchNotificationTest.java | 5 - .../openwire/v5/MessageDispatchTest.java | 5 - .../activemq/openwire/v5/MessageIdTest.java | 4 - .../activemq/openwire/v5/MessagePullTest.java | 5 - .../openwire/v5/NetworkBridgeFilterTest.java | 4 - .../openwire/v5/PartialCommandTest.java | 4 - .../activemq/openwire/v5/ProducerAckTest.java | 5 - .../activemq/openwire/v5/ProducerIdTest.java | 4 - .../activemq/openwire/v5/ProducerInfoTest.java | 5 - .../activemq/openwire/v5/RemoveInfoTest.java | 5 - .../openwire/v5/RemoveSubscriptionInfoTest.java | 5 - .../activemq/openwire/v5/ReplayCommandTest.java | 5 - .../activemq/openwire/v5/ResponseTest.java | 5 - .../activemq/openwire/v5/SessionIdTest.java | 4 - .../activemq/openwire/v5/SessionInfoTest.java | 5 - .../activemq/openwire/v5/ShutdownInfoTest.java | 5 - .../openwire/v5/SubscriptionInfoTest.java | 4 - .../openwire/v5/TransactionIdTestSupport.java | 4 - .../openwire/v5/TransactionInfoTest.java | 5 - .../openwire/v5/XATransactionIdTest.java | 5 - .../activemq/openwire/v6/BrokerIdTest.java | 4 - .../activemq/openwire/v6/BrokerInfoTest.java | 5 - .../openwire/v6/ConnectionControlTest.java | 5 - .../openwire/v6/ConnectionErrorTest.java | 5 - .../activemq/openwire/v6/ConnectionIdTest.java | 4 - .../openwire/v6/ConnectionInfoTest.java | 5 - .../openwire/v6/ConsumerControlTest.java | 5 - .../activemq/openwire/v6/ConsumerIdTest.java | 4 - .../activemq/openwire/v6/ConsumerInfoTest.java | 5 - .../openwire/v6/ControlCommandTest.java | 5 - .../openwire/v6/DataArrayResponseTest.java | 5 - .../activemq/openwire/v6/DataResponseTest.java | 5 - .../openwire/v6/DestinationInfoTest.java | 5 - .../openwire/v6/DiscoveryEventTest.java | 4 - .../openwire/v6/ExceptionResponseTest.java | 5 - .../activemq/openwire/v6/FlushCommandTest.java | 5 - .../openwire/v6/IntegerResponseTest.java | 5 - .../openwire/v6/JournalQueueAckTest.java | 4 - .../openwire/v6/JournalTopicAckTest.java | 4 - .../activemq/openwire/v6/JournalTraceTest.java | 4 - .../openwire/v6/JournalTransactionTest.java | 4 - .../activemq/openwire/v6/KeepAliveInfoTest.java | 5 - .../openwire/v6/LastPartialCommandTest.java | 5 - .../openwire/v6/LocalTransactionIdTest.java | 5 - .../activemq/openwire/v6/MessageAckTest.java | 5 - .../v6/MessageDispatchNotificationTest.java | 5 - .../openwire/v6/MessageDispatchTest.java | 5 - .../activemq/openwire/v6/MessageIdTest.java | 4 - .../activemq/openwire/v6/MessagePullTest.java | 5 - .../openwire/v6/NetworkBridgeFilterTest.java | 4 - .../openwire/v6/PartialCommandTest.java | 4 - .../activemq/openwire/v6/ProducerAckTest.java | 5 - .../activemq/openwire/v6/ProducerIdTest.java | 4 - .../activemq/openwire/v6/ProducerInfoTest.java | 5 - .../activemq/openwire/v6/RemoveInfoTest.java | 5 - .../openwire/v6/RemoveSubscriptionInfoTest.java | 5 - .../activemq/openwire/v6/ReplayCommandTest.java | 5 - .../activemq/openwire/v6/ResponseTest.java | 5 - .../activemq/openwire/v6/SessionIdTest.java | 4 - .../activemq/openwire/v6/SessionInfoTest.java | 5 - .../activemq/openwire/v6/ShutdownInfoTest.java | 5 - .../openwire/v6/SubscriptionInfoTest.java | 4 - .../openwire/v6/TransactionIdTestSupport.java | 4 - .../openwire/v6/TransactionInfoTest.java | 5 - .../openwire/v6/XATransactionIdTest.java | 5 - .../activemq/openwire/v7/BrokerIdTest.java | 51 +++++- .../activemq/openwire/v7/BrokerInfoTest.java | 67 +++++++- .../openwire/v7/ConnectionControlTest.java | 57 ++++++- .../openwire/v7/ConnectionErrorTest.java | 51 +++++- .../activemq/openwire/v7/ConnectionIdTest.java | 51 +++++- .../openwire/v7/ConnectionInfoTest.java | 65 +++++++- .../openwire/v7/ConsumerControlTest.java | 56 ++++++- .../activemq/openwire/v7/ConsumerIdTest.java | 53 +++++- .../activemq/openwire/v7/ConsumerInfoTest.java | 79 ++++++++- .../openwire/v7/ControlCommandTest.java | 50 +++++- .../openwire/v7/DataArrayResponseTest.java | 56 ++++++- .../activemq/openwire/v7/DataResponseTest.java | 50 +++++- .../openwire/v7/DestinationInfoTest.java | 60 ++++++- .../openwire/v7/DiscoveryEventTest.java | 52 +++++- .../openwire/v7/ExceptionResponseTest.java | 50 +++++- .../activemq/openwire/v7/FlushCommandTest.java | 49 +++++- .../openwire/v7/IntegerResponseTest.java | 50 +++++- .../openwire/v7/JournalQueueAckTest.java | 52 +++++- .../openwire/v7/JournalTopicAckTest.java | 56 ++++++- .../activemq/openwire/v7/JournalTraceTest.java | 51 +++++- .../openwire/v7/JournalTransactionTest.java | 53 +++++- .../activemq/openwire/v7/KeepAliveInfoTest.java | 49 +++++- .../openwire/v7/LastPartialCommandTest.java | 49 +++++- .../openwire/v7/LocalTransactionIdTest.java | 51 +++++- .../activemq/openwire/v7/MessageAckTest.java | 57 ++++++- .../v7/MessageDispatchNotificationTest.java | 53 +++++- .../openwire/v7/MessageDispatchTest.java | 53 +++++- .../activemq/openwire/v7/MessageIdTest.java | 53 +++++- .../activemq/openwire/v7/MessagePullTest.java | 54 ++++++- .../openwire/v7/MessageTestSupport.java | 87 +++++++++- .../openwire/v7/NetworkBridgeFilterTest.java | 52 +++++- .../openwire/v7/PartialCommandTest.java | 52 +++++- .../activemq/openwire/v7/ProducerAckTest.java | 51 +++++- .../activemq/openwire/v7/ProducerIdTest.java | 53 +++++- .../activemq/openwire/v7/ProducerInfoTest.java | 60 ++++++- .../activemq/openwire/v7/RemoveInfoTest.java | 51 +++++- .../openwire/v7/RemoveSubscriptionInfoTest.java | 52 +++++- .../activemq/openwire/v7/ReplayCommandTest.java | 51 +++++- .../activemq/openwire/v7/ResponseTest.java | 50 +++++- .../activemq/openwire/v7/SessionIdTest.java | 52 +++++- .../activemq/openwire/v7/SessionInfoTest.java | 50 +++++- .../activemq/openwire/v7/ShutdownInfoTest.java | 49 +++++- .../openwire/v7/SubscriptionInfoTest.java | 55 ++++++- .../openwire/v7/TransactionIdTestSupport.java | 41 ++++- .../openwire/v7/TransactionInfoTest.java | 52 +++++- .../openwire/v7/XATransactionIdTest.java | 52 +++++- .../activemq/openwire/v8/BrokerIdTest.java | 51 +++++- .../activemq/openwire/v8/BrokerInfoTest.java | 67 +++++++- .../openwire/v8/ConnectionControlTest.java | 58 ++++++- .../openwire/v8/ConnectionErrorTest.java | 51 +++++- .../activemq/openwire/v8/ConnectionIdTest.java | 51 +++++- .../openwire/v8/ConnectionInfoTest.java | 66 +++++++- .../openwire/v8/ConsumerControlTest.java | 56 ++++++- .../activemq/openwire/v8/ConsumerIdTest.java | 53 +++++- .../activemq/openwire/v8/ConsumerInfoTest.java | 79 ++++++++- .../openwire/v8/ControlCommandTest.java | 50 +++++- .../openwire/v8/DataArrayResponseTest.java | 56 ++++++- .../activemq/openwire/v8/DataResponseTest.java | 50 +++++- .../openwire/v8/DestinationInfoTest.java | 60 ++++++- .../openwire/v8/DiscoveryEventTest.java | 52 +++++- .../openwire/v8/ExceptionResponseTest.java | 50 +++++- .../activemq/openwire/v8/FlushCommandTest.java | 49 +++++- .../openwire/v8/IntegerResponseTest.java | 50 +++++- .../openwire/v8/JournalQueueAckTest.java | 52 +++++- .../openwire/v8/JournalTopicAckTest.java | 56 ++++++- .../activemq/openwire/v8/JournalTraceTest.java | 51 +++++- .../openwire/v8/JournalTransactionTest.java | 53 +++++- .../activemq/openwire/v8/KeepAliveInfoTest.java | 49 +++++- .../openwire/v8/LastPartialCommandTest.java | 49 +++++- .../openwire/v8/LocalTransactionIdTest.java | 51 +++++- .../activemq/openwire/v8/MessageAckTest.java | 57 ++++++- .../v8/MessageDispatchNotificationTest.java | 53 +++++- .../openwire/v8/MessageDispatchTest.java | 53 +++++- .../activemq/openwire/v8/MessageIdTest.java | 53 +++++- .../activemq/openwire/v8/MessagePullTest.java | 54 ++++++- .../openwire/v8/MessageTestSupport.java | 87 +++++++++- .../openwire/v8/NetworkBridgeFilterTest.java | 52 +++++- .../openwire/v8/PartialCommandTest.java | 52 +++++- .../activemq/openwire/v8/ProducerAckTest.java | 51 +++++- .../activemq/openwire/v8/ProducerIdTest.java | 53 +++++- .../activemq/openwire/v8/ProducerInfoTest.java | 60 ++++++- .../activemq/openwire/v8/RemoveInfoTest.java | 51 +++++- .../openwire/v8/RemoveSubscriptionInfoTest.java | 52 +++++- .../activemq/openwire/v8/ReplayCommandTest.java | 51 +++++- .../activemq/openwire/v8/ResponseTest.java | 50 +++++- .../activemq/openwire/v8/SessionIdTest.java | 52 +++++- .../activemq/openwire/v8/SessionInfoTest.java | 50 +++++- .../activemq/openwire/v8/ShutdownInfoTest.java | 49 +++++- .../openwire/v8/SubscriptionInfoTest.java | 55 ++++++- .../openwire/v8/TransactionIdTestSupport.java | 41 ++++- .../openwire/v8/TransactionInfoTest.java | 52 +++++- .../openwire/v8/XATransactionIdTest.java | 52 +++++- .../activemq/openwire/v9/BrokerIdTest.java | 51 +++++- .../activemq/openwire/v9/BrokerInfoTest.java | 67 +++++++- .../openwire/v9/ConnectionControlTest.java | 58 ++++++- .../openwire/v9/ConnectionErrorTest.java | 51 +++++- .../activemq/openwire/v9/ConnectionIdTest.java | 51 +++++- .../openwire/v9/ConnectionInfoTest.java | 66 +++++++- .../openwire/v9/ConsumerControlTest.java | 56 ++++++- .../activemq/openwire/v9/ConsumerIdTest.java | 53 +++++- .../activemq/openwire/v9/ConsumerInfoTest.java | 79 ++++++++- .../openwire/v9/ControlCommandTest.java | 50 +++++- .../openwire/v9/DataArrayResponseTest.java | 56 ++++++- .../activemq/openwire/v9/DataResponseTest.java | 50 +++++- .../openwire/v9/DestinationInfoTest.java | 60 ++++++- .../openwire/v9/DiscoveryEventTest.java | 52 +++++- .../openwire/v9/ExceptionResponseTest.java | 50 +++++- .../activemq/openwire/v9/FlushCommandTest.java | 49 +++++- .../openwire/v9/IntegerResponseTest.java | 50 +++++- .../openwire/v9/JournalQueueAckTest.java | 52 +++++- .../openwire/v9/JournalTopicAckTest.java | 56 ++++++- .../activemq/openwire/v9/JournalTraceTest.java | 51 +++++- .../openwire/v9/JournalTransactionTest.java | 53 +++++- .../activemq/openwire/v9/KeepAliveInfoTest.java | 49 +++++- .../openwire/v9/LastPartialCommandTest.java | 49 +++++- .../openwire/v9/LocalTransactionIdTest.java | 51 +++++- .../activemq/openwire/v9/MessageAckTest.java | 57 ++++++- .../v9/MessageDispatchNotificationTest.java | 53 +++++- .../openwire/v9/MessageDispatchTest.java | 53 +++++- .../activemq/openwire/v9/MessageIdTest.java | 53 +++++- .../activemq/openwire/v9/MessagePullTest.java | 54 ++++++- .../openwire/v9/MessageTestSupport.java | 87 +++++++++- .../openwire/v9/NetworkBridgeFilterTest.java | 52 +++++- .../openwire/v9/PartialCommandTest.java | 52 +++++- .../activemq/openwire/v9/ProducerAckTest.java | 51 +++++- .../activemq/openwire/v9/ProducerIdTest.java | 53 +++++- .../activemq/openwire/v9/ProducerInfoTest.java | 60 ++++++- .../activemq/openwire/v9/RemoveInfoTest.java | 51 +++++- .../openwire/v9/RemoveSubscriptionInfoTest.java | 52 +++++- .../activemq/openwire/v9/ReplayCommandTest.java | 51 +++++- .../activemq/openwire/v9/ResponseTest.java | 50 +++++- .../activemq/openwire/v9/SessionIdTest.java | 52 +++++- .../activemq/openwire/v9/SessionInfoTest.java | 50 +++++- .../activemq/openwire/v9/ShutdownInfoTest.java | 49 +++++- .../openwire/v9/SubscriptionInfoTest.java | 55 ++++++- .../openwire/v9/TransactionIdTestSupport.java | 41 ++++- .../openwire/v9/TransactionInfoTest.java | 52 +++++- .../openwire/v9/XATransactionIdTest.java | 52 +++++- .../activemq/perf/ConnectionChurnTest.java | 2 +- .../apache/activemq/perf/NetworkedSyncTest.java | 1 - .../SimpleNonPersistentQueueNetworkTest.java | 2 +- .../perf/SimpleNonPersistentQueueTest.java | 2 +- ...veTwoConnectionsWithSenderUsingPoolTest.java | 2 - .../org/apache/activemq/proxy/AMQ4889Test.java | 4 +- .../apache/activemq/proxy/ProxyTestSupport.java | 2 +- ...actCachedLDAPAuthorizationMapLegacyTest.java | 2 +- .../activemq/security/AuthorizationMapTest.java | 6 +- ...JaasCertificateAuthenticationBrokerTest.java | 10 +- .../JaasDualAuthenticationBrokerTest.java | 4 +- .../security/LDAPAuthenticationTest.java | 7 - .../security/LDAPAuthorizationMapTest.java | 2 +- .../activemq/security/SecurityJMXTest.java | 2 +- .../SimpleSecurityBrokerSystemTest.java | 11 +- .../apache/activemq/spring/ConsumerBean.java | 4 +- .../org/apache/activemq/spring/SpringTest.java | 2 +- .../store/AutoStorePerDestinationTest.java | 2 +- .../activemq/store/StorePerDestinationTest.java | 6 +- .../jdbc/JDBCIOExceptionHandlerMockeryTest.java | 2 +- .../store/jdbc/JDBCIOExceptionHandlerTest.java | 2 +- .../store/jdbc/JDBCMessagePriorityTest.java | 6 +- .../store/jdbc/JDBCTablePrefixAssignedTest.java | 2 +- .../store/jdbc/LeaseDatabaseLockerTest.java | 2 +- .../store/kahadb/KahaDBFastEnqueueTest.java | 2 +- .../kahadb/KahaDBStoreRecoveryBrokerTest.java | 3 +- .../activemq/store/kahadb/KahaDBStoreTest.java | 2 +- .../activemq/store/kahadb/plist/PListTest.java | 16 +- .../activemq/streams/JMSInputStreamTest.java | 4 +- .../test/JmsSendReceiveTestSupport.java | 1 - .../TemporaryDestinationToFromNameTest.java | 1 - .../message/NestedMapAndListPropertyTest.java | 4 +- .../test/message/NestedMapMessageTest.java | 4 +- .../transport/StubCompositeTransport.java | 2 +- .../activemq/transport/StubTransport.java | 2 +- .../transport/StubTransportListener.java | 4 +- .../activemq/transport/TopicClusterTest.java | 2 +- .../transport/TransportBrokerTestSupport.java | 3 +- .../DiscoveryNetworkReconnectTest.java | 4 +- .../discovery/DiscoveryTransportBrokerTest.java | 2 +- .../DiscoveryTransportNoBrokerTest.java | 2 +- .../transport/failover/AMQ1925Test.java | 2 +- .../failover/ConnectionHangOnStartupTest.java | 4 +- .../transport/failover/FailoverClusterTest.java | 6 +- .../failover/FailoverClusterTestSupport.java | 10 +- .../failover/FailoverComplexClusterTest.java | 2 - .../FailoverConsumerOutstandingCommitTest.java | 2 +- .../FailoverConsumerUnconsumedTest.java | 4 +- .../failover/FailoverPrefetchZeroTest.java | 2 +- .../failover/FailoverPriorityTest.java | 2 +- .../failover/FailoverTransactionTest.java | 12 +- .../transport/failover/SlowConnectionTest.java | 2 +- .../fanout/FanoutTransportBrokerTest.java | 2 +- .../tcp/QualityOfServiceUtilsTest.java | 2 +- .../transport/tcp/ServerSocketTstFactory.java | 2 - .../transport/tcp/SocketTstFactory.java | 4 +- .../transport/tcp/SslTransportFactoryTest.java | 2 +- .../tcp/TcpFaultyTransportFactory.java | 2 +- .../tcp/WireformatNegociationTest.java | 6 +- .../udp/UdpTransportUsingServerTest.java | 1 - .../transport/vm/VMTransportThreadSafeTest.java | 4 +- .../vm/VmTransportNetworkBrokerTest.java | 2 +- .../activemq/usecases/AMQStackOverFlowTest.java | 2 +- .../usecases/ChangeSentMessageTest.java | 2 +- .../activemq/usecases/CompositeConsumeTest.java | 1 - .../ConcurrentDestinationCreationTest.java | 2 +- .../ConcurrentProducerDurableConsumerTest.java | 7 +- .../ConcurrentProducerQueueConsumerTest.java | 5 +- .../usecases/ConsumeTopicPrefetchTest.java | 2 +- .../DurableConsumerCloseAndReconnectTest.java | 3 - .../DurableSubDelayedUnsubscribeTest.java | 8 +- ...ConcurrentCommitActivateNoDuplicateTest.java | 12 +- .../DurableSubProcessMultiRestartTest.java | 3 +- .../usecases/DurableSubProcessTest.java | 12 +- .../DurableSubProcessWithRestartTest.java | 12 +- ...neSelectorConcurrentConsumeIndexUseTest.java | 2 +- .../DurableSubsOfflineSelectorIndexUseTest.java | 2 +- ...ableSubscriberWithNetworkDisconnectTest.java | 2 +- .../DurableSubscriptionOffline1Test.java | 4 +- .../DurableSubscriptionOffline2Test.java | 2 +- .../DurableSubscriptionOffline3Test.java | 2 +- .../DurableSubscriptionOffline4Test.java | 2 +- .../DurableSubscriptionOfflineTest.java | 3 +- .../DurableSubscriptionOfflineTestBase.java | 2 +- .../usecases/ExceptionListenerTest.java | 2 +- .../activemq/usecases/ExpiredMessagesTest.java | 3 - .../usecases/JdbcDurableSubDupTest.java | 3 +- .../usecases/MessageGroupCloseTest.java | 8 +- .../usecases/MessageGroupDelayedTest.java | 4 +- .../usecases/MessageGroupLateArrivalsTest.java | 7 +- .../MessageGroupReconnectDistributionTest.java | 4 +- .../usecases/MultiBrokersMultiClientsTest.java | 6 +- .../MultiBrokersMultiClientsUsingTcpTest.java | 2 +- .../MulticastDiscoveryOnFaultyNetworkTest.java | 2 +- .../NetworkBridgeProducerFlowControlTest.java | 2 +- .../usecases/NoDuplicateOnTopicNetworkTest.java | 4 +- .../NonBlockingConsumerRedeliveryTest.java | 26 +-- .../ObjectMessageNotSerializableTest.java | 17 +- .../activemq/usecases/QueueDuplicatesTest.java | 2 +- .../QueueMemoryFullMultiBrokersTest.java | 2 +- .../usecases/ReliableReconnectTest.java | 2 - .../RequestReplyNoAdvisoryNetworkTest.java | 2 +- ...estReplyTempDestRemovalAdvisoryRaceTest.java | 12 +- ...uestReplyToTopicViaThreeNetworkHopsTest.java | 2 +- ...tualDestinationsWithWildcardLevelDBTest.java | 10 -- ...kerConnectionDuplexExcludedDestinations.java | 1 - .../usecases/ThreeBrokerQueueNetworkTest.java | 4 +- .../ThreeBrokerQueueNetworkUsingTcpTest.java | 2 +- .../usecases/ThreeBrokerTopicNetworkTest.java | 2 +- .../ThreeBrokerTopicNetworkUsingTcpTest.java | 2 +- .../usecases/TopicDurableConnectStatsTest.java | 2 +- .../activemq/usecases/TopicRedeliverTest.java | 2 +- .../usecases/TransactionRollbackOrderTest.java | 8 +- .../usecases/TwoBrokerQueueSendReceiveTest.java | 2 +- .../usecases/TwoBrokerTopicSendReceiveTest.java | 2 +- .../TwoBrokerTopicSendReceiveUsingTcpTest.java | 5 +- .../TwoBrokerVirtualTopicForwardingTest.java | 2 +- .../activemq/usecases/UnlimitedEnqueueTest.java | 2 +- .../VerifyNetworkConsumersDisconnectTest.java | 6 +- .../apache/activemq/util/LinkedNodeTest.java | 2 - .../org/apache/activemq/util/MessageIdList.java | 6 +- .../activemq/util/ReflectionSupportTest.java | 6 +- .../org/apache/activemq/util/SimplePojo.java | 6 +- .../xbean/ConnectorXBeanConfigTest.java | 1 - .../xbean/ManagementContextXBeanConfigTest.java | 4 +- .../BridgeServerLocatorConfigurationTest.java | 14 +- .../byteman/ConcurrentDeliveryCancelTest.java | 6 +- .../HierarchicalObjectRepositoryTest.java | 2 +- .../tests/extras/byteman/MessageCopyTest.java | 2 +- .../tests/extras/byteman/PagingLeakTest.java | 4 +- .../tests/extras/byteman/TimeoutXATest.java | 2 +- .../tests/extras/jms/bridge/BridgeTestBase.java | 4 +- .../jms/bridge/ClusteredBridgeTestBase.java | 6 +- .../tests/extras/jms/bridge/JMSBridgeTest.java | 8 +- ...MDBMultipleHandlersServerDisconnectTest.java | 4 +- .../protocols/hornetq/HornetQProtocolTest.java | 6 +- .../integration/SimpleNotificationService.java | 4 +- .../client/AutoCreateJmsQueueTest.java | 4 +- .../tests/integration/client/ConsumerTest.java | 2 +- .../client/ConsumerWindowSizeTest.java | 12 +- .../client/DeadLetterAddressTest.java | 2 +- .../integration/client/HangConsumerTest.java | 2 +- .../client/JmsNettyNioStressTest.java | 4 +- .../integration/client/JournalCrashTest.java | 4 +- .../integration/client/LargeMessageTest.java | 6 +- .../client/MessageConcurrencyTest.java | 10 +- .../client/MessageConsumerRollbackTest.java | 2 +- .../MessageGroupingConnectionFactoryTest.java | 2 +- .../integration/client/MessageGroupingTest.java | 2 +- .../tests/integration/client/NIOvsOIOTest.java | 4 +- .../tests/integration/client/PagingTest.java | 28 ++-- .../client/ProducerFlowControlTest.java | 2 +- .../client/SessionCloseOnGCTest.java | 32 ++-- .../integration/cluster/NodeManagerTest.java | 2 +- .../cluster/RealNodeManagerTest.java | 2 +- .../cluster/bridge/BridgeFailoverTest.java | 6 +- .../cluster/bridge/BridgeReconnectTest.java | 52 +++--- .../cluster/bridge/BridgeStartTest.java | 56 +++---- .../integration/cluster/bridge/BridgeTest.java | 162 +++++++++---------- .../BridgeWithDiscoveryGroupStartTest.java | 16 +- .../cluster/distribution/ClusterTestBase.java | 26 +-- .../distribution/ClusteredGroupingTest.java | 2 +- .../distribution/MessageRedistributionTest.java | 2 +- .../MessageRedistributionWithDiscoveryTest.java | 2 +- .../failover/AsynchronousFailoverTest.java | 6 +- .../cluster/failover/BackupSyncJournalTest.java | 4 +- .../failover/BackupSyncLargeMessageTest.java | 2 +- .../cluster/failover/BackupSyncPagingTest.java | 2 +- .../ClusterWithBackupFailoverTestBase.java | 2 +- .../cluster/failover/FailoverListenerTest.java | 2 +- .../failover/FailoverOnFlowControlTest.java | 2 +- .../cluster/failover/FailoverTest.java | 8 +- .../cluster/failover/FailoverTestBase.java | 4 +- ...ultipleLivesMultipleBackupsFailoverTest.java | 2 +- .../MultipleServerFailoverTestBase.java | 20 +-- .../cluster/failover/NettyFailoverTest.java | 2 +- .../cluster/failover/QuorumFailOverTest.java | 4 +- ...dMultipleServerFailoverExtraBackupsTest.java | 2 +- .../cluster/failover/SecurityFailoverTest.java | 2 +- .../SingleLiveMultipleBackupsFailoverTest.java | 2 +- .../MultiThreadRandomReattachTestBase.java | 46 +++--- .../MultiThreadReattachSupportTestBase.java | 2 +- .../cluster/reattach/OrderReattachTest.java | 8 +- .../cluster/reattach/RandomReattachTest.java | 42 ++--- .../cluster/topology/IsolatedTopologyTest.java | 16 +- .../cluster/topology/NonHATopologyTest.java | 2 +- .../cluster/util/MultiServerTestBase.java | 6 +- .../discovery/DiscoveryBaseTest.java | 6 +- .../http/CoreClientOverHttpTest.java | 2 +- .../interceptors/InterceptorTest.java | 5 +- .../jms/ActiveMQConnectionFactoryTest.java | 6 +- .../tests/integration/jms/FloodServerTest.java | 2 +- .../ManualReconnectionToSingleServerTest.java | 2 +- .../integration/jms/SimpleJNDIClientTest.java | 6 +- .../jms/client/ReSendMessageTest.java | 4 +- ...onClosedOnRemotingConnectionFailureTest.java | 2 +- .../integration/jms/client/StoreConfigTest.java | 6 +- .../jms/client/TopicCleanupTest.java | 2 +- .../jms/cluster/JMSFailoverListenerTest.java | 2 +- .../jms/cluster/JMSFailoverTest.java | 2 +- .../jms/connection/CloseConnectionOnGCTest.java | 14 +- .../ConnectionFactorySerializationTest.java | 8 +- .../jms/connection/InvalidConnectorTest.java | 4 +- .../JmsProducerCompletionListenerTest.java | 2 +- .../jms/server/JMSServerStartStopTest.java | 2 +- .../jms/server/config/JMSConfigurationTest.java | 2 +- .../ConnectionFactoryControlTest.java | 2 +- .../server/management/JMSQueueControlTest.java | 2 +- .../server/management/JMSServerControlTest.java | 6 +- .../jms/server/management/TopicControlTest.java | 2 +- .../journal/NIOJournalCompactTest.java | 48 +++--- .../management/AddressControlTest.java | 4 +- .../management/AddressControlUsingCoreTest.java | 2 +- .../management/BridgeControlTest.java | 4 +- .../management/BridgeControlUsingCoreTest.java | 4 +- .../management/BroadcastGroupControlTest.java | 2 +- .../ClusterConnectionControl2Test.java | 4 +- .../ClusterConnectionControlTest.java | 4 +- .../integration/management/JMXDomainTest.java | 2 +- .../management/ManagementActivationTest.java | 2 +- .../management/ManagementHelperTest.java | 8 +- .../management/ManagementWithStompTest.java | 2 +- .../management/SecurityNotificationTest.java | 4 +- .../integration/mqtt/imported/MQTTTest.java | 10 +- .../mqtt/imported/MQTTTestSupport.java | 6 +- .../integration/mqtt/imported/PahoMQTTTest.java | 2 +- .../util/ResourceLoadingSslContext.java | 4 +- .../integration/openwire/BasicOpenWireTest.java | 2 +- .../integration/openwire/OpenWireTestBase.java | 6 +- .../openwire/amq/JMSConsumer3Test.java | 3 +- .../openwire/amq/JMSMessageTest.java | 4 +- .../amq/JmsConnectionStartStopTest.java | 2 +- .../amq/JmsConsumerResetActiveListenerTest.java | 4 +- .../openwire/amq/JmsResourceProvider.java | 4 +- .../openwire/amq/JmsTopicRedeliverTest.java | 3 +- .../openwire/amq/JmsTopicRequestReplyTest.java | 2 +- .../openwire/amq/JmsTransactionTestSupport.java | 20 +-- .../amq/MessageListenerRedeliveryTest.java | 2 +- .../openwire/amq/ProducerFlowControlTest.java | 2 +- .../openwire/interop/GeneralInteropTest.java | 4 +- .../paging/MultipleProducersPagingTest.java | 2 +- .../integration/paging/PagingSendTest.java | 4 +- .../PagingWithFailoverAndCountersTest.java | 2 +- .../paging/SpawnedServerSupport.java | 4 +- ...AddressSettingsConfigurationStorageTest.java | 2 +- .../DeleteMessagesOnStartupTest.java | 4 +- ...nnectionFactoryConfigurationStorageTest.java | 14 +- .../persistence/JMSDynamicConfigTest.java | 2 +- .../integration/persistence/RestartSMTest.java | 8 +- .../RolesConfigurationStorageTest.java | 2 +- ...ansportConfigurationEncodingSupportTest.java | 12 +- .../persistence/XmlImportExportTest.java | 2 +- .../tests/integration/proton/ProtonTest.java | 2 +- .../ra/ActiveMQMessageHandlerSecurityTest.java | 2 +- .../tests/integration/ra/JMSContextTest.java | 2 +- .../integration/ra/OutgoingConnectionTest.java | 2 +- .../ra/OutgoingConnectionTestJTA.java | 2 +- .../integration/ra/ResourceAdapterTest.java | 2 +- .../integration/remoting/BatchDelayTest.java | 4 +- .../integration/remoting/DirectDeliverTest.java | 2 +- .../remoting/NetworkAddressTestBase.java | 8 +- .../integration/remoting/ReconnectTest.java | 4 +- .../replication/ReplicationTest.java | 4 +- .../scheduling/ScheduledMessageTest.java | 2 +- .../integration/security/SecurityTest.java | 60 +++---- .../integration/server/ExpiryRunnerTest.java | 2 +- .../integration/server/FakeStorageManager.java | 4 +- .../integration/server/PredefinedQueueTest.java | 4 +- .../ssl/CoreClientOverOneWaySSLTest.java | 2 +- .../ssl/CoreClientOverTwoWaySSLTest.java | 2 +- .../tests/integration/stomp/ExtraStompTest.java | 20 +-- .../tests/integration/stomp/StompTestBase.java | 2 +- .../integration/stomp/StompWebSocketTest.java | 2 +- .../stomp/util/AbstractClientStompFrame.java | 6 +- .../util/AbstractStompClientConnection.java | 4 +- .../integration/stomp/v11/StompV11TestBase.java | 2 +- .../netty/ActiveMQFrameDecoder2Test.java | 2 +- .../NettyConnectorWithHTTPUpgradeTest.java | 4 +- .../vertx/ActiveMQVertxUnitTest.java | 10 +- .../integration/xa/BasicXaRecoveryTest.java | 2 +- .../tests/integration/xa/BasicXaTest.java | 2 +- .../tests/integration/xa/XaTimeoutTest.java | 4 +- .../artemis/tests/util/JMSTestBase.java | 4 +- .../tests/util/TransportConfigurationUtils.java | 10 +- .../jms/tests/ActiveMQServerTestCase.java | 10 +- .../artemis/jms/tests/CTSMiscellaneousTest.java | 2 +- .../jms/tests/ConnectionFactoryTest.java | 2 +- .../activemq/artemis/jms/tests/JMSTest.java | 4 +- .../activemq/artemis/jms/tests/JMSTestCase.java | 2 +- .../activemq/artemis/jms/tests/QueueTest.java | 2 +- .../tests/message/BodyIsAssignableFromTest.java | 2 +- .../jms/tests/message/MessageBodyTest.java | 3 +- .../jms/tests/message/MessageHeaderTest.java | 2 +- .../tests/message/MessageHeaderTestBase.java | 1 - .../jms/tests/message/ObjectMessageTest.java | 6 +- .../jms/tests/message/SimpleJMSMessage.java | 2 +- .../tests/message/SimpleJMSStreamMessage.java | 2 +- .../jms/tests/selector/SelectorTest.java | 4 +- .../jms/tests/tools/ServerManagement.java | 2 +- .../jms/tests/tools/container/InVMContext.java | 4 +- .../container/InVMInitialContextFactory.java | 2 +- .../tests/tools/container/LocalTestServer.java | 8 +- .../activemq/artemis/jms/ActiveMQAdmin.java | 2 +- .../paging/MeasurePagingMultiThreadTest.java | 2 +- .../sends/AbstractSendReceivePerfTest.java | 2 +- .../tests/soak/client/ClientSoakTest.java | 2 +- .../stress/journal/AddAndRemoveStressTest.java | 8 +- .../JournalCleanupCompactStressTest.java | 6 +- .../journal/JournalRestartStressTest.java | 2 +- .../journal/MultiThreadConsumerStressTest.java | 2 +- .../NIOMultiThreadCompactorStressTest.java | 6 +- .../paging/MultipleConsumersPageStressTest.java | 8 +- .../stress/paging/PageCursorStressTest.java | 2 +- .../tests/stress/paging/PageStressTest.java | 2 +- .../tests/stress/stomp/StompStressTest.java | 2 +- .../core/server/impl/QueueConcurrentTest.java | 2 +- .../timing/core/server/impl/QueueImplTest.java | 4 +- .../jms/bridge/impl/JMSBridgeImplTest.java | 10 +- .../MultiThreadAsynchronousFileTest.java | 4 +- .../core/config/impl/ConnectorsServiceTest.java | 2 +- .../impl/fakes/FakeConnectorServiceFactory.java | 4 +- .../journal/impl/AlignedJournalImplTest.java | 12 +- .../core/journal/impl/JournalAsyncTest.java | 4 +- .../core/journal/impl/JournalImplTestBase.java | 14 +- .../unit/core/journal/impl/ReclaimerTest.java | 8 +- .../impl/SequentialFileFactoryTestBase.java | 2 +- .../unit/core/journal/impl/TimedBufferTest.java | 4 +- .../impl/fakes/FakeSequentialFileFactory.java | 6 +- .../unit/core/message/impl/MessageImplTest.java | 2 +- .../tests/unit/core/paging/impl/PageTest.java | 2 +- .../core/paging/impl/PagingManagerImplTest.java | 2 +- .../core/paging/impl/PagingStoreImplTest.java | 14 +- .../impl/BatchIDGeneratorUnitTest.java | 4 +- .../impl/DuplicateDetectionUnitTest.java | 2 +- .../impl/WildcardAddressManagerUnitTest.java | 2 +- .../impl/invm/InVMConnectorFactoryTest.java | 2 +- .../impl/netty/NettyAcceptorFactoryTest.java | 2 +- .../remoting/impl/netty/NettyAcceptorTest.java | 2 +- .../impl/netty/NettyConnectorFactoryTest.java | 2 +- .../remoting/impl/netty/NettyConnectorTest.java | 12 +- .../impl/ActiveMQSecurityManagerImplTest.java | 28 ++-- .../unit/core/server/impl/QueueImplTest.java | 38 ++--- .../core/server/impl/fakes/FakeConsumer.java | 2 +- .../ra/ActiveMQResourceAdapterConfigTest.java | 2 +- .../ra/ConnectionFactoryPropertiesTest.java | 46 +++--- .../tests/unit/ra/ResourceAdapterTest.java | 14 +- .../artemis/tests/unit/util/InVMContext.java | 6 +- .../tests/unit/util/InVMNamingContext.java | 6 +- .../artemis/tests/unit/util/LinkedListTest.java | 12 +- .../ObjectInputStreamWithClassLoaderTest.java | 2 +- .../tests/unit/util/SoftValueMapTest.java | 6 +- .../artemis/tests/unit/util/UUIDTest.java | 2 +- 1050 files changed, 9371 insertions(+), 2990 deletions(-) ----------------------------------------------------------------------
