activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [41/42] activemq-artemis git commit: Add missing @Override annotations
Date Mon, 07 Dec 2015 18:39:53 GMT
Add missing @Override annotations


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/25ae4724
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/25ae4724
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/25ae4724

Branch: refs/heads/master
Commit: 25ae47245524d05a6eb0804ec7c96309cbbe2a02
Parents: fd38ddd
Author: Ville Skyttä <ville.skytta@iki.fi>
Authored: Sun Dec 6 01:27:35 2015 +0200
Committer: Ville Skyttä <ville.skytta@iki.fi>
Committed: Sun Dec 6 01:27:35 2015 +0200

----------------------------------------------------------------------
 .../apache/activemq/artemis/boot/Artemis.java   |   1 +
 .../artemis/cli/commands/ActionAbstract.java    |   3 +
 .../activemq/artemis/cli/commands/Create.java   |   1 +
 .../activemq/artemis/cli/commands/Run.java      |   1 +
 .../cli/commands/tools/DecodeJournal.java       |   1 +
 .../cli/commands/tools/EncodeJournal.java       |  11 ++
 .../cli/commands/util/ProducerThread.java       |   1 +
 .../artemis/cli/process/ProcessBuilder.java     |   1 +
 .../artemis/integration/FileBroker.java         |   1 +
 .../activemq/artemis/util/ServerUtil.java       |   1 +
 .../artemis/api/core/ActiveMQBuffer.java        |  12 ++
 .../activemq/artemis/api/core/SimpleString.java |   4 +
 .../core/buffers/impl/ChannelBufferWrapper.java |  96 ++++++++++++
 .../artemis/utils/ActiveMQThreadFactory.java    |   2 +
 .../artemis/utils/ConcurrentHashSet.java        |   1 +
 .../utils/DefaultSensitiveStringCodec.java      |   2 +
 .../activemq/artemis/utils/FactoryFinder.java   |   1 +
 .../artemis/utils/PasswordMaskingUtil.java      |   1 +
 .../activemq/artemis/utils/UUIDGenerator.java   |   1 +
 .../artemis/utils/ReferenceCounterTest.java     |   3 +
 .../api/core/JGroupsBroadcastEndpoint.java      |   6 +
 .../api/core/JGroupsFileBroadcastEndpoint.java  |   1 +
 .../api/core/UDPBroadcastEndpointFactory.java   |   7 +
 .../artemis/api/core/client/ClientConsumer.java |   1 +
 .../artemis/api/core/client/ClientMessage.java  |  22 +++
 .../artemis/api/core/client/ClientProducer.java |   1 +
 .../artemis/api/core/client/ClientSession.java  |   1 +
 .../api/core/client/ClientSessionFactory.java   |   1 +
 .../artemis/api/core/client/ServerLocator.java  |   1 +
 ...rstElementConnectionLoadBalancingPolicy.java |   1 +
 .../RandomConnectionLoadBalancingPolicy.java    |   1 +
 ...ndomStickyConnectionLoadBalancingPolicy.java |   1 +
 ...RoundRobinConnectionLoadBalancingPolicy.java |   1 +
 .../core/management/CoreNotificationType.java   |   1 +
 .../core/client/impl/AddressQueryImpl.java      |   3 +
 .../core/client/impl/ClientConsumerImpl.java    |  33 ++++
 .../client/impl/ClientLargeMessageImpl.java     |   4 +
 .../impl/ClientProducerCreditManagerImpl.java   |  18 +++
 .../client/impl/ClientProducerCreditsImpl.java  |  10 ++
 .../core/client/impl/ClientProducerImpl.java    |  11 ++
 .../client/impl/ClientSessionFactoryImpl.java   |  39 +++++
 .../core/client/impl/ClientSessionImpl.java     | 100 ++++++++++++
 .../CompressedLargeMessageControllerImpl.java   |  70 +++++++++
 .../core/client/impl/DelegatingSession.java     |  92 +++++++++++
 .../client/impl/LargeMessageControllerImpl.java |  71 +++++++++
 .../core/client/impl/QueueQueryImpl.java        |   9 ++
 .../core/client/impl/ServerLocatorImpl.java     |  99 ++++++++++++
 .../core/client/impl/ServerLocatorInternal.java |   1 +
 .../artemis/core/client/impl/Topology.java      |   4 +
 .../core/client/impl/TopologyMemberImpl.java    |   2 +
 .../artemis/core/cluster/DiscoveryGroup.java    |   4 +
 .../artemis/core/message/impl/MessageImpl.java  |  87 +++++++++++
 .../impl/ActiveMQClientProtocolManager.java     |  11 ++
 .../ActiveMQClientProtocolManagerFactory.java   |   1 +
 .../core/impl/ActiveMQSessionContext.java       |  39 +++++
 .../core/protocol/core/impl/ChannelImpl.java    |  25 +++
 .../core/protocol/core/impl/PacketImpl.java     |   8 +
 .../core/impl/RemotingConnectionImpl.java       |  19 +++
 .../core/impl/wireformat/MessagePacket.java     |   2 +
 .../SessionQueueQueryResponseMessage_V2.java    |   1 +
 .../impl/TransportConfigurationUtil.java        |   1 +
 .../remoting/impl/netty/NettyConnection.java    |  15 ++
 .../remoting/impl/netty/NettyConnector.java     |  16 ++
 .../impl/netty/NettyConnectorFactory.java       |   1 +
 .../core/remoting/impl/ssl/SSLSupport.java      |   1 +
 .../artemis/core/transaction/impl/XidImpl.java  |   3 +
 .../artemis/core/version/impl/VersionImpl.java  |   7 +
 .../protocol/AbstractRemotingConnection.java    |  17 ++
 .../activemq/artemis/utils/FutureLatch.java     |   1 +
 .../activemq/artemis/utils/InflaterReader.java  |   1 +
 .../activemq/artemis/utils/LinkedListImpl.java  |  13 ++
 .../artemis/utils/LinkedListIterator.java       |   1 +
 .../artemis/utils/OrderedExecutorFactory.java   |   4 +
 .../artemis/utils/PriorityLinkedListImpl.java   |  12 ++
 .../artemis/utils/SimpleIDGenerator.java        |   2 +
 .../artemis/utils/SoftValueHashMap.java         |  16 ++
 .../utils/TimeAndCounterIDGenerator.java        |   2 +
 .../artemis/utils/TokenBucketLimiterImpl.java   |   3 +
 .../activemq/artemis/utils/VersionLoader.java   |   1 +
 .../apache/activemq/artemis/utils/XMLUtil.java  |   1 +
 .../api/jms/management/JMSQueueControl.java     |   1 +
 .../jms/client/ActiveMQBytesMessage.java        |  27 ++++
 .../artemis/jms/client/ActiveMQConnection.java  |  18 +++
 .../jms/client/ActiveMQConnectionFactory.java   |   8 +
 .../ActiveMQConnectionForContextImpl.java       |   3 +
 .../jms/client/ActiveMQConnectionMetaData.java  |   8 +
 .../artemis/jms/client/ActiveMQDestination.java |   1 +
 .../artemis/jms/client/ActiveMQMapMessage.java  |  25 +++
 .../artemis/jms/client/ActiveMQMessage.java     |  44 ++++++
 .../jms/client/ActiveMQMessageConsumer.java     |  10 ++
 .../jms/client/ActiveMQMessageProducer.java     |  24 +++
 .../jms/client/ActiveMQObjectMessage.java       |   2 +
 .../artemis/jms/client/ActiveMQQueue.java       |   1 +
 .../jms/client/ActiveMQQueueBrowser.java        |   6 +
 .../client/ActiveMQQueueConnectionFactory.java  |   1 +
 .../artemis/jms/client/ActiveMQSession.java     |  36 +++++
 .../jms/client/ActiveMQStreamMessage.java       |  24 +++
 .../artemis/jms/client/ActiveMQTextMessage.java |   2 +
 .../artemis/jms/client/ActiveMQTopic.java       |   1 +
 .../client/ActiveMQTopicConnectionFactory.java  |   1 +
 .../ActiveMQXAQueueConnectionFactory.java       |   1 +
 .../ActiveMQXATopicConnectionFactory.java       |   1 +
 .../jms/client/JMSMessageListenerWrapper.java   |   1 +
 .../ConnectionFactoryObjectFactory.java         |   1 +
 .../referenceable/DestinationObjectFactory.java |   1 +
 .../jndi/ActiveMQInitialContextFactory.java     |   3 +
 .../artemis/jndi/LazyCreateContext.java         |   1 +
 .../activemq/artemis/jndi/NameParserImpl.java   |   1 +
 .../activemq/artemis/jndi/ReadOnlyContext.java  |  36 +++++
 .../jms/bridge/impl/JMSBridgeControlImpl.java   |  33 ++++
 .../artemis/jms/bridge/impl/JMSBridgeImpl.java  |  49 ++++++
 .../impl/JNDIConnectionFactoryFactory.java      |   1 +
 .../jms/bridge/impl/JNDIDestinationFactory.java |   1 +
 .../impl/JMSConnectionFactoryControlImpl.java   |  69 +++++++++
 .../management/impl/JMSQueueControlImpl.java    |  42 +++++
 .../management/impl/JMSServerControlImpl.java   |  38 +++++
 .../management/impl/JMSTopicControlImpl.java    |  24 +++
 .../config/PersistedDestination.java            |   3 +
 .../journal/JMSJournalStorageManagerImpl.java   |   7 +
 .../artemis/jms/server/JMSServerManager.java    |   1 +
 .../ConnectionFactoryConfigurationImpl.java     |  72 +++++++++
 .../config/impl/JMSConfigurationImpl.java       |   8 +
 .../config/impl/JMSQueueConfigurationImpl.java  |   8 +
 .../config/impl/TopicConfigurationImpl.java     |   4 +
 .../jms/server/impl/JMSServerManagerImpl.java   |  45 ++++++
 .../impl/JMSManagementServiceImpl.java          |   9 ++
 .../artemis/core/io/AbstractSequentialFile.java |  19 +++
 .../core/io/AbstractSequentialFileFactory.java  |   9 ++
 .../activemq/artemis/core/io/DummyCallback.java |   2 +
 .../artemis/core/io/aio/AIOSequentialFile.java  |  13 ++
 .../core/io/aio/AIOSequentialFileFactory.java   |  13 ++
 .../artemis/core/io/buffer/TimedBuffer.java     |   1 +
 .../artemis/core/io/nio/NIOSequentialFile.java  |  14 ++
 .../core/io/nio/NIOSequentialFileFactory.java   |   9 ++
 .../artemis/core/journal/TestableJournal.java   |   3 +
 .../artemis/core/journal/impl/JournalBase.java  |  27 ++++
 .../core/journal/impl/JournalCompactor.java     |  10 ++
 .../core/journal/impl/JournalFileImpl.java      |  10 ++
 .../journal/impl/JournalFilesRepository.java    |   1 +
 .../artemis/core/journal/impl/JournalImpl.java  |  67 ++++++++
 .../impl/JournalReaderCallbackAbstract.java     |  10 ++
 .../core/journal/impl/SimpleWaitIOCallback.java |   2 +
 .../core/journal/impl/TransactionCallback.java  |   2 +
 .../impl/dataformat/ByteArrayEncoding.java      |   3 +
 .../impl/dataformat/JournalDeleteRecord.java    |   1 +
 .../impl/dataformat/JournalInternalRecord.java  |   2 +
 .../artemis/maven/ArtemisAbstractPlugin.java    |   1 +
 .../artemis/maven/ArtemisCLIPlugin.java         |   2 +
 .../maven/ArtemisDependencyScanPlugin.java      |   1 +
 .../activemq/artemis/jlibaio/LibaioContext.java |   1 +
 .../artemis/jlibaio/test/LibaioTest.java        |   1 +
 .../jlibaio/test/OpenCloseContextTest.java      |   2 +
 .../ActiveMQProtonRemotingConnection.java       |   1 +
 .../converter/jms/ServerJMSBytesMessage.java    |   2 +
 .../converter/jms/ServerJMSMapMessage.java      |  27 ++++
 .../proton/converter/jms/ServerJMSMessage.java  |   1 +
 .../converter/jms/ServerJMSStreamMessage.java   |  26 ++++
 .../converter/jms/ServerJMSTextMessage.java     |   4 +
 .../plug/ActiveMQProtonConnectionCallback.java  |   1 +
 .../client/HornetQClientProtocolManager.java    |   2 +
 .../client/HornetQClientSessionContext.java     |   4 +
 .../core/protocol/mqtt/MQTTConnection.java      |   1 +
 .../core/protocol/mqtt/MQTTMessageInfo.java     |   1 +
 .../core/protocol/mqtt/MQTTProtocolHandler.java |   1 +
 .../openwire/OpenWireMessageConverter.java      |   1 +
 .../openwire/OpenWireProtocolManager.java       |   3 +
 .../OpenWireProtocolManagerFactory.java         |   1 +
 .../amq/AMQCompositeConsumerBrokerExchange.java |   3 +
 .../protocol/openwire/amq/AMQServerSession.java |   1 +
 .../amq/AMQSingleConsumerBrokerExchange.java    |   3 +
 .../plug/context/AbstractConnectionContext.java |   7 +
 .../context/AbstractProtonContextSender.java    |   2 +
 .../context/AbstractProtonSessionContext.java   |   1 +
 .../plug/context/ProtonTransactionHandler.java  |   1 +
 .../client/ProtonClientConnectionContext.java   |   2 +
 .../ProtonClientConnectionContextFactory.java   |   1 +
 .../context/client/ProtonClientContext.java     |   1 +
 .../client/ProtonClientReceiverContext.java     |   2 +
 .../client/ProtonClientSessionContext.java      |   2 +
 .../server/ProtonServerConnectionContext.java   |   2 +
 .../ProtonServerConnectionContextFactory.java   |   1 +
 .../server/ProtonServerReceiverContext.java     |   2 +
 .../server/ProtonServerSenderContext.java       |   5 +
 .../server/ProtonServerSessionContext.java      |   1 +
 .../plug/handler/impl/ProtonHandlerImpl.java    |   2 +
 .../org/proton/plug/sasl/ClientSASLPlain.java   |   2 +
 .../org/proton/plug/util/FutureRunnable.java    |   1 +
 .../proton/plug/util/ProtonServerMessage.java   |   1 +
 .../java/org/proton/plug/test/ProtonTest.java   |   1 +
 .../proton/plug/test/invm/ProtonINVMSPI.java    |   4 +
 .../plug/test/minimalclient/AMQPClientSPI.java  |   2 +
 .../test/minimalclient/SimpleAMQPConnector.java |   3 +
 .../minimalserver/MinimalConnectionSPI.java     |   2 +
 .../test/minimalserver/MinimalSessionSPI.java   |   2 +
 .../SimpleServerThreadFactory.java              |   3 +
 .../plug/test/util/CreditsSemaphoreTest.java    |   1 +
 .../core/protocol/stomp/StompConnection.java    |  13 ++
 .../protocol/stomp/StompProtocolManager.java    |   6 +
 .../stomp/StompProtocolManagerFactory.java      |   1 +
 .../core/protocol/stomp/StompSession.java       |   8 +
 .../core/protocol/stomp/StompVersions.java      |   1 +
 .../stomp/v11/StompFrameHandlerV11.java         |   1 +
 .../stomp/v12/StompFrameHandlerV12.java         |   1 +
 .../artemis/ra/ActiveMQRABytesMessage.java      |  27 ++++
 .../ra/ActiveMQRAConnectionFactoryImpl.java     |  14 ++
 .../artemis/ra/ActiveMQRAConnectionManager.java |   1 +
 .../ra/ActiveMQRAConnectionMetaData.java        |   8 +
 .../artemis/ra/ActiveMQRACredential.java        |   1 +
 .../artemis/ra/ActiveMQRALocalTransaction.java  |   3 +
 .../artemis/ra/ActiveMQRAManagedConnection.java |  12 ++
 .../ra/ActiveMQRAManagedConnectionFactory.java  |   8 +
 .../artemis/ra/ActiveMQRAMapMessage.java        |  25 +++
 .../activemq/artemis/ra/ActiveMQRAMessage.java  |  45 ++++++
 .../artemis/ra/ActiveMQRAMessageConsumer.java   |   7 +
 .../artemis/ra/ActiveMQRAMessageListener.java   |   1 +
 .../artemis/ra/ActiveMQRAMessageProducer.java   |  16 ++
 .../activemq/artemis/ra/ActiveMQRAMetaData.java |   4 +
 .../artemis/ra/ActiveMQRAObjectMessage.java     |   2 +
 .../artemis/ra/ActiveMQRAQueueReceiver.java     |   1 +
 .../artemis/ra/ActiveMQRAQueueSender.java       |   3 +
 .../activemq/artemis/ra/ActiveMQRASession.java  |  40 +++++
 .../ra/ActiveMQRASessionFactoryImpl.java        |  14 ++
 .../artemis/ra/ActiveMQRAStreamMessage.java     |  24 +++
 .../artemis/ra/ActiveMQRATextMessage.java       |   2 +
 .../artemis/ra/ActiveMQRATopicPublisher.java    |   5 +
 .../artemis/ra/ActiveMQRATopicSubscriber.java   |   2 +
 .../artemis/ra/ActiveMQRAXAResource.java        |  10 ++
 .../activemq/artemis/ra/ActiveMQRaUtils.java    |   2 +
 .../artemis/ra/ActiveMQResourceAdapter.java     |   5 +
 .../artemis/ra/inflow/ActiveMQActivation.java   |   3 +
 .../ra/inflow/ActiveMQActivationSpec.java       |   3 +
 .../ra/inflow/ActiveMQMessageHandler.java       |   1 +
 .../integration/ActiveMQBootstrapListener.java  |   2 +
 .../RestMessagingBootstrapListener.java         |   2 +
 .../ServletContextBindingRegistry.java          |   4 +
 .../rest/queue/AcknowledgedQueueConsumer.java   |   1 +
 .../artemis/rest/queue/ConsumersResource.java   |   2 +
 .../rest/queue/push/ActiveMQPushStrategy.java   |   1 +
 .../artemis/rest/queue/push/FilePushStore.java  |   5 +
 .../artemis/rest/queue/push/UriStrategy.java    |   5 +
 .../rest/queue/push/UriTemplateStrategy.java    |   1 +
 .../topic/AcknowledgedSubscriptionResource.java |   6 +
 .../rest/topic/SubscriptionResource.java        |   6 +
 .../rest/topic/SubscriptionsResource.java       |   2 +
 .../artemis/rest/topic/TopicServiceManager.java |   2 +
 .../rest/util/CustomHeaderLinkStrategy.java     |   1 +
 .../rest/util/LinkHeaderLinkStrategy.java       |   1 +
 .../activemq/artemis/rest/util/TimeoutTask.java |   1 +
 .../artemis/rest/test/AutoAckTopicTest.java     |   2 +
 .../activemq/artemis/rest/test/JMSTest.java     |   1 +
 .../artemis/rest/test/TransformTest.java        |   1 +
 .../selector/filter/ArithmeticExpression.java   |  11 ++
 .../selector/filter/BinaryExpression.java       |   3 +
 .../selector/filter/ComparisonExpression.java   |  16 ++
 .../selector/filter/ConstantExpression.java     |   5 +
 .../selector/filter/LogicExpression.java        |   6 +
 .../selector/filter/PropertyExpression.java     |   4 +
 .../selector/filter/UnaryExpression.java        |  14 ++
 .../selector/filter/XPathExpression.java        |   4 +
 .../selector/filter/XQueryExpression.java       |   3 +
 .../selector/filter/XalanXPathEvaluator.java    |   1 +
 .../artemis/selector/impl/LRUCache.java         |   1 +
 .../activemq/artemis/selector/SelectorTest.java |   3 +
 .../core/config/impl/ConfigurationImpl.java     | 155 +++++++++++++++++++
 .../artemis/core/config/impl/Validators.java    |  12 ++
 .../deployers/impl/FileConfigurationParser.java |   1 +
 .../artemis/core/filter/impl/FilterImpl.java    |   2 +
 .../management/impl/AcceptorControlImpl.java    |   6 +
 .../impl/ActiveMQServerControlImpl.java         |  99 ++++++++++++
 .../management/impl/AddressControlImpl.java     |  10 ++
 .../core/management/impl/BridgeControlImpl.java |  15 ++
 .../impl/BroadcastGroupControlImpl.java         |  10 ++
 .../impl/ClusterConnectionControlImpl.java      |  15 ++
 .../core/management/impl/DivertControlImpl.java |   7 +
 .../core/management/impl/QueueControlImpl.java  |  51 ++++++
 .../core/messagecounter/MessageCounter.java     |   1 +
 .../impl/MessageCounterManagerImpl.java         |  12 ++
 .../artemis/core/paging/cursor/PageCache.java   |   1 +
 .../core/paging/cursor/PagedReferenceImpl.java  |   6 +
 .../core/paging/cursor/impl/PageCacheImpl.java  |   6 +
 .../cursor/impl/PageCursorProviderImpl.java     |  18 +++
 .../paging/cursor/impl/PagePositionImpl.java    |   7 +
 .../impl/PageSubscriptionCounterImpl.java       |   9 ++
 .../cursor/impl/PageSubscriptionImpl.java       |  35 +++++
 .../activemq/artemis/core/paging/impl/Page.java |   1 +
 .../artemis/core/paging/impl/PageSyncTimer.java |   1 +
 .../paging/impl/PageTransactionInfoImpl.java    |  17 ++
 .../core/paging/impl/PagedMessageImpl.java      |   7 +
 .../core/paging/impl/PagingManagerImpl.java     |  13 ++
 .../core/paging/impl/PagingStoreFactoryNIO.java |   5 +
 .../core/paging/impl/PagingStoreImpl.java       |  38 +++++
 .../impl/journal/BatchingIDGenerator.java       |   5 +
 .../impl/journal/DescribeJournal.java           |  11 ++
 .../impl/journal/JournalStorageManager.java     | 131 ++++++++++++++++
 .../impl/journal/LargeServerMessageImpl.java    |  12 ++
 .../impl/journal/OperationContextImpl.java      |   8 +
 .../nullpm/NullStorageLargeServerMessage.java   |   1 +
 .../impl/nullpm/NullStorageManager.java         |   3 +
 .../core/postoffice/impl/AddressImpl.java       |   7 +
 .../core/postoffice/impl/BindingsImpl.java      |   7 +
 .../core/postoffice/impl/DivertBinding.java     |  13 ++
 .../postoffice/impl/DuplicateIDCacheImpl.java   |   6 +
 .../core/postoffice/impl/LocalQueueBinding.java |  16 ++
 .../core/postoffice/impl/PostOfficeImpl.java    |  37 +++++
 .../postoffice/impl/SimpleAddressManager.java   |   7 +
 .../core/ServerSessionPacketHandler.java        |   3 +
 .../core/impl/ActiveMQPacketHandler.java        |   1 +
 .../protocol/core/impl/CoreProtocolManager.java |   8 +
 .../core/impl/CoreProtocolManagerFactory.java   |   1 +
 .../protocol/core/impl/CoreSessionCallback.java |   7 +
 .../core/registry/JndiBindingRegistry.java      |   4 +
 .../core/registry/MapBindingRegistry.java       |   4 +
 .../core/remoting/impl/invm/InVMAcceptor.java   |  15 ++
 .../remoting/impl/invm/InVMAcceptorFactory.java |   1 +
 .../core/remoting/impl/invm/InVMConnection.java |  17 ++
 .../core/remoting/impl/invm/InVMConnector.java  |  11 ++
 .../impl/invm/InVMConnectorFactory.java         |   1 +
 .../impl/netty/HttpAcceptorHandler.java         |   1 +
 .../impl/netty/HttpKeepAliveRunnable.java       |   1 +
 .../core/remoting/impl/netty/NettyAcceptor.java |  16 ++
 .../impl/netty/NettyAcceptorFactory.java        |   1 +
 .../server/impl/RemotingServiceImpl.java        |  16 ++
 .../core/replication/ReplicatedJournal.java     |  30 ++++
 .../core/replication/ReplicationEndpoint.java   |   3 +
 .../core/replication/ReplicationManager.java    |   6 +
 .../core/security/impl/SecurityStoreImpl.java   |   4 +
 .../artemis/core/server/LargeServerMessage.java |   3 +
 .../artemis/core/server/MemoryManager.java      |   4 +
 .../artemis/core/server/NodeManager.java        |   2 +
 .../artemis/core/server/ServerSession.java      |   1 +
 .../core/server/cluster/BackupManager.java      |   7 +
 .../artemis/core/server/cluster/Bridge.java     |   1 +
 .../core/server/cluster/ClusterControl.java     |   1 +
 .../core/server/cluster/ClusterManager.java     |   3 +
 .../server/cluster/ha/ColocatedHAManager.java   |   3 +
 .../core/server/cluster/ha/ReplicaPolicy.java   |   3 +
 .../server/cluster/ha/ReplicatedPolicy.java     |   1 +
 .../core/server/cluster/impl/BridgeImpl.java    |  27 ++++
 .../server/cluster/impl/BroadcastGroupImpl.java |  10 ++
 .../cluster/impl/ClusterConnectionBridge.java   |   1 +
 .../cluster/impl/ClusterConnectionImpl.java     |  30 ++++
 .../core/server/cluster/impl/Redistributor.java |  10 ++
 .../cluster/impl/RemoteQueueBindingImpl.java    |  18 +++
 .../core/server/cluster/qourum/BooleanVote.java |   1 +
 .../group/impl/GroupHandlingAbstract.java       |   4 +
 .../server/group/impl/LocalGroupingHandler.java |  14 ++
 .../group/impl/RemoteGroupingHandler.java       |   9 ++
 .../core/server/impl/ActiveMQServerImpl.java    |  61 ++++++++
 .../impl/AutoCreatedQueueManagerImpl.java       |   1 +
 .../core/server/impl/ConnectorsService.java     |   3 +
 .../artemis/core/server/impl/DivertImpl.java    |   6 +
 .../core/server/impl/LastValueQueue.java        |  14 ++
 .../core/server/impl/LiveOnlyActivation.java    |   2 +
 .../core/server/impl/MessageReferenceImpl.java  |  15 ++
 .../server/impl/PostOfficeJournalLoader.java    |   3 +
 .../core/server/impl/QueueFactoryImpl.java      |   2 +
 .../artemis/core/server/impl/QueueImpl.java     |  97 ++++++++++++
 .../core/server/impl/RoutingContextImpl.java    |  11 ++
 .../impl/ScheduledDeliveryHandlerImpl.java      |   7 +
 .../core/server/impl/ServerConsumerImpl.java    |  29 ++++
 .../core/server/impl/ServerMessageImpl.java     |  22 +++
 .../core/server/impl/ServerSessionImpl.java     |  57 +++++++
 .../core/server/impl/ServiceRegistryImpl.java   |   4 +
 .../impl/SharedNothingBackupActivation.java     |   2 +
 .../impl/SharedNothingLiveActivation.java       |   5 +
 .../impl/SharedStoreBackupActivation.java       |   4 +
 .../server/impl/SharedStoreLiveActivation.java  |   2 +
 .../server/impl/TransientQueueManagerImpl.java  |   1 +
 .../management/impl/ManagementServiceImpl.java  |  35 +++++
 .../core/settings/impl/AddressSettings.java     |   1 +
 .../impl/HierarchicalObjectRepository.java      |  13 ++
 .../TransactionOperationAbstract.java           |   6 +
 .../impl/BindingsTransactionImpl.java           |   1 +
 .../transaction/impl/ResourceManagerImpl.java   |  11 ++
 .../core/transaction/impl/TransactionImpl.java  |  27 ++++
 .../security/ActiveMQSecurityManagerImpl.java   |   2 +
 .../core/security/jaas/PropertiesLoader.java    |   2 +
 ...nVMAcceptorTransportConfigurationSchema.java |   1 +
 ...TCPAcceptorTransportConfigurationSchema.java |   1 +
 .../security/jaas/GuestLoginModuleTest.java     |   2 +
 .../core/security/jaas/LDAPLoginModuleTest.java |   2 +
 .../jaas/LDAPModuleRoleExpansionTest.java       |   1 +
 .../jaas/PropertiesLoginModuleTest.java         |   3 +
 .../jaas/StubCertificateLoginModule.java        |   2 +
 .../core/security/jaas/StubX509Certificate.java |  16 ++
 .../group/impl/ClusteredResetMockTest.java      |   1 +
 .../impl/ScheduledDeliveryHandlerTest.java      |   1 +
 .../artemis/core/settings/RepositoryTest.java   |   1 +
 .../artemis/tests/util/ActiveMQTestBase.java    |  12 ++
 .../artemis/tests/util/RemoveFolder.java        |   1 +
 .../xa/recovery/ActiveMQXAResourceWrapper.java  |  12 ++
 .../artemis/component/WebServerComponent.java   |   3 +
 .../cli/test/WebServerComponentTest.java        |   1 +
 .../ApplicationLayerFailoverExample.java        |   1 +
 .../ClientSideFailoverListerExample.java        |   1 +
 .../activemq/artemis/jms/example/PerfBase.java  |   1 +
 .../artemis/jms/soak/example/SoakReceiver.java  |   2 +
 .../artemis/jms/soak/example/SoakSender.java    |   1 +
 .../jms/example/HatColourChangeTransformer.java |   1 +
 .../example/AddForwardingTimeTransformer.java   |   1 +
 .../artemis/jms/example/SimpleInterceptor.java  |   1 +
 .../artemis/jms/example/SimpleInterceptor.java  |   1 +
 .../example/ManagementNotificationExample.java  |   1 +
 .../jms/example/MessageGroupExample.java        |   1 +
 .../jms/example/MessageGroup2Example.java       |   1 +
 .../jms/example/MessagePriorityExample.java     |   1 +
 .../jms/example/TextReverserService.java        |   1 +
 .../jms/example/QueueSelectorExample.java       |   1 +
 .../jms/example/RequestReplyExample.java        |   1 +
 .../example/SendAcknowledgementsExample.java    |   1 +
 .../artemis/jms/example/ExampleListener.java    |   1 +
 .../jms/example/StaticSelectorExample.java      |   1 +
 .../jms/example/TopicSelectorExample2.java      |   1 +
 .../activemq/artemis/jms/example/DummyXid.java  |   3 +
 .../artemis/jms/example/XAHeuristicExample.java |   1 +
 .../activemq/artemis/jms/example/DummyXid.java  |   3 +
 .../activemq/artemis/jms/example/DummyXid.java  |   3 +
 .../artemis/jms/example/XASendExample.java      |   1 +
 .../activemq/artemis/openwire/example/Chat.java |   1 +
 .../artemis/jms/example/MyStompInterceptor.java |   1 +
 .../spring/SpringBindingRegistry.java           |   4 +
 .../integration/spring/SpringJmsBootstrap.java  |   1 +
 .../broker/artemiswrapper/InVMNameParser.java   |   1 +
 .../artemiswrapper/InVMNamingContext.java       |  34 ++++
 .../artemiswrapper/NonSerializableFactory.java  |   1 +
 .../broker/region/policy/PolicyMap.java         |   1 +
 .../transport/tcp/TcpTransportFactory.java      |   3 +
 .../activemq/ActiveMQMessageAuditTest.java      |   2 +
 .../ActiveMQXAConnectionFactoryTest.java        |   3 +
 .../apache/activemq/ConnectionCleanupTest.java  |   2 +
 ...nectionCloseMultipleTimesConcurrentTest.java |   2 +
 .../ConnectionCloseMultipleTimesTest.java       |   2 +
 .../ConsumerReceiveWithTimeoutTest.java         |   3 +
 .../activemq/EmbeddedBrokerTestSupport.java     |   2 +
 .../java/org/apache/activemq/ExpiryHogTest.java |   2 +
 .../activemq/JMSDurableTopicRedeliverTest.java  |   1 +
 .../apache/activemq/JMSQueueRedeliverTest.java  |   1 +
 .../org/apache/activemq/JMSXAConsumerTest.java  |   4 +
 .../apache/activemq/JmsAutoAckListenerTest.java |   3 +
 .../org/apache/activemq/JmsAutoAckTest.java     |   2 +
 .../activemq/JmsClientAckListenerTest.java      |   3 +
 .../org/apache/activemq/JmsClientAckTest.java   |   2 +
 .../JmsConsumerResetActiveListenerTest.java     |   4 +
 .../JmsCreateConsumerInOnMessageTest.java       |   3 +
 .../JmsDurableQueueWildcardSendReceiveTest.java |   3 +
 .../activemq/JmsDurableTopicSelectorTest.java   |   1 +
 .../JmsDurableTopicSendReceiveTest.java         |   1 +
 .../JmsDurableTopicTransactionTest.java         |   1 +
 .../JmsDurableTopicWildcardSendReceiveTest.java |   3 +
 .../activemq/JmsMultipleBrokersTestSupport.java |   5 +
 .../activemq/JmsMultipleClientsTestSupport.java |   1 +
 .../JmsQueueCompositeSendReceiveTest.java       |   4 +
 .../activemq/JmsQueueRequestReplyTest.java      |   1 +
 .../apache/activemq/JmsQueueSelectorTest.java   |   1 +
 .../activemq/JmsQueueSendReceiveTest.java       |   1 +
 ...eiveTwoConnectionsStartBeforeBrokerTest.java |   4 +
 ...JmsQueueSendReceiveUsingTwoSessionsTest.java |   1 +
 .../JmsQueueTopicCompositeSendReceiveTest.java  |   4 +
 .../JmsQueueWildcardSendReceiveTest.java        |   3 +
 .../org/apache/activemq/JmsRedeliveredTest.java |   4 +
 .../activemq/JmsSendReceiveTestSupport.java     |   2 +
 ...JmsSendReceiveWithMessageExpirationTest.java |   2 +
 .../apache/activemq/JmsSessionRecoverTest.java  |   4 +
 .../org/apache/activemq/JmsTestSupport.java     |   2 +
 .../JmsTopicCompositeSendReceiveTest.java       |   4 +
 .../apache/activemq/JmsTopicRedeliverTest.java  |   4 +
 .../activemq/JmsTopicRequestReplyTest.java      |   4 +
 .../apache/activemq/JmsTopicSelectorTest.java   |   2 +
 .../JmsTopicSendReceiveSubscriberTest.java      |   1 +
 .../activemq/JmsTopicSendReceiveTest.java       |   2 +
 ...sTopicSendReceiveWithTwoConnectionsTest.java |   3 +
 ...endReceiveWithTwoConnectionsWithJMXTest.java |   1 +
 .../activemq/JmsTopicSendSameMessageTest.java   |   1 +
 .../activemq/JmsTopicTransactionTest.java       |   1 +
 .../JmsTopicWildcardSendReceiveTest.java        |   3 +
 .../activemq/LargeMessageTestSupport.java       |   3 +
 .../org/apache/activemq/LoadTestBurnIn.java     |   5 +
 .../activemq/MessageTransformationTest.java     |   2 +
 .../activemq/OnePrefetchAsyncConsumerTest.java  |   2 +
 .../activemq/PerDestinationStoreLimitTest.java  |   4 +
 .../ProducerFlowControlSendFailTest.java        |   2 +
 .../activemq/ProducerFlowControlTest.java       |   6 +
 .../activemq/ReconnectWithSameClientIDTest.java |   2 +
 .../activemq/advisory/ConsumerListenerTest.java |   4 +
 .../advisory/DestinationListenerTest.java       |   3 +
 .../activemq/advisory/TempDestDeleteTest.java   |   4 +
 .../apache/activemq/blob/FTPTestSupport.java    |   2 +
 .../org/apache/activemq/broker/AMQ4351Test.java |   1 +
 .../apache/activemq/broker/BrokerBenchmark.java |   2 +
 .../activemq/broker/BrokerRedeliveryTest.java   |   1 +
 ...CreateDestinationsOnStartupViaXBeanTest.java |   1 +
 .../broker/DedicatedTaskRunnerBrokerTest.java   |   1 +
 .../activemq/broker/DoubleSubscriptionTest.java |   1 +
 .../activemq/broker/MarshallingBrokerTest.java  |   3 +
 .../activemq/broker/MessageExpirationTest.java  |   2 +
 .../activemq/broker/QueueMbeanRestartTest.java  |   2 +
 .../broker/ReconnectWithJMXEnabledTest.java     |   3 +
 .../org/apache/activemq/broker/SpringTest.java  |   2 +
 .../org/apache/activemq/broker/StubBroker.java  |   2 +
 .../apache/activemq/broker/StubConnection.java  |   4 +
 .../activemq/broker/TopicSubscriptionTest.java  |  10 ++
 .../AdvisoryDuplexNetworkBridgeTest.java        |   1 +
 .../broker/advisory/AdvisoryJmxTest.java        |   1 +
 ...artJDBCQueueMasterSlaveLeaseQuiesceTest.java |   1 +
 .../ft/DbRestartJDBCQueueMasterSlaveTest.java   |   3 +
 .../broker/ft/DbRestartJDBCQueueTest.java       |   6 +
 .../broker/ft/JDBCQueueMasterSlaveTest.java     |   4 +
 ...QueueMasterSlaveTestUsingSharedFileTest.java |   4 +
 .../broker/ft/SyncCreateDataSource.java         |   1 +
 .../ft/kahaDbJdbcLeaseQueueMasterSlaveTest.java |   4 +
 .../broker/ft/mKahaDbQueueMasterSlaveTest.java  |   3 +
 .../apache/activemq/broker/jmx/PurgeTest.java   |   4 +
 .../broker/mKahaDBXARecoveryBrokerTest.java     |   1 +
 .../broker/mLevelDBXARecoveryBrokerTest.java    |   3 +
 .../security/MessageAuthenticationTest.java     |   1 +
 .../activemq/broker/policy/DeadLetterTest.java  |   4 +
 .../broker/policy/DeadLetterTestSupport.java    |   2 +
 .../policy/IndividualDeadLetterViaXmlTest.java  |   2 +
 .../policy/MessageListenerDeadLetterTest.java   |   5 +
 .../broker/policy/NoConsumerDeadLetterTest.java |   5 +
 .../policy/RoundRobinDispatchPolicyTest.java    |   8 +
 .../activemq/broker/policy/SecureDLQTest.java   |   2 +
 .../region/QueueDuplicatesFromStoreTest.java    |   2 +
 .../activemq/broker/region/QueuePurgeTest.java  |   2 +
 .../region/QueueResendDuringShutdownTest.java   |   1 +
 .../region/SubscriptionAddRemoveQueueTest.java  |  37 +++++
 .../region/cursors/CursorDurableTest.java       |   4 +
 .../region/cursors/CursorQueueStoreTest.java    |   4 +
 .../broker/region/cursors/CursorSupport.java    |   3 +
 .../region/cursors/StoreBasedCursorTest.java    |   2 +
 .../StoreQueueCursorJDBCNoDuplicateTest.java    |   1 +
 .../StoreQueueCursorMemoryNoDuplicateTest.java  |   1 +
 .../group/MessageGroupHashBucketTest.java       |   1 +
 .../region/group/MessageGroupMapTest.java       |   1 +
 .../broker/store/DefaultStoreBrokerTest.java    |   1 +
 .../store/DefaultStoreRecoveryBrokerTest.java   |   2 +
 .../activemq/broker/util/PluginBrokerTest.java  |   4 +
 .../util/TimeStampingBrokerPluginTest.java      |   2 +
 .../broker/util/TraceBrokerPathPluginTest.java  |   2 +
 .../broker/virtual/CompositeQueueTest.java      |   2 +
 .../broker/virtual/CompositeTopicTest.java      |   4 +
 .../DestinationInterceptorDurableSubTest.java   |   6 +
 .../MirroredQueueCorrectMemoryUsageTest.java    |   2 +
 .../broker/virtual/VirtualTopicDLQTest.java     |   6 +
 .../VirtualTopicDisconnectSelectorTest.java     |   3 +
 .../broker/virtual/VirtualTopicPubSubTest.java  |   2 +
 .../VirtualTopicPubSubUsingXBeanTest.java       |   3 +
 .../virtual/VirtualTopicSelectorTest.java       |   3 +
 .../VirtualTopicsAndDurableSubsTest.java        |   6 +
 .../org/apache/activemq/bugs/AMQ1687Test.java   |   2 +
 .../org/apache/activemq/bugs/AMQ1853Test.java   |   4 +
 .../java/org/apache/activemq/bugs/AMQ1866.java  |   1 +
 .../org/apache/activemq/bugs/AMQ1893Test.java   |   1 +
 .../org/apache/activemq/bugs/AMQ1917Test.java   |   5 +
 .../org/apache/activemq/bugs/AMQ2084Test.java   |   2 +
 .../org/apache/activemq/bugs/AMQ2149Test.java   |  10 ++
 .../org/apache/activemq/bugs/AMQ2171Test.java   |   1 +
 .../org/apache/activemq/bugs/AMQ2314Test.java   |   5 +
 .../org/apache/activemq/bugs/AMQ2439Test.java   |   2 +
 .../org/apache/activemq/bugs/AMQ2489Test.java   |   4 +
 .../org/apache/activemq/bugs/AMQ2512Test.java   |   1 +
 .../org/apache/activemq/bugs/AMQ2528Test.java   |   1 +
 .../org/apache/activemq/bugs/AMQ2571Test.java   |   1 +
 .../org/apache/activemq/bugs/AMQ2580Test.java   |   2 +
 .../activemq/bugs/AMQ2584ConcurrentDlqTest.java |   4 +
 .../org/apache/activemq/bugs/AMQ2645Test.java   |   1 +
 .../org/apache/activemq/bugs/AMQ2751Test.java   |   1 +
 .../org/apache/activemq/bugs/AMQ3014Test.java   |   1 +
 .../org/apache/activemq/bugs/AMQ3274Test.java   |   4 +
 .../org/apache/activemq/bugs/AMQ3436Test.java   |   1 +
 .../org/apache/activemq/bugs/AMQ3465Test.java   |   3 +
 .../org/apache/activemq/bugs/AMQ3678Test.java   |   1 +
 .../org/apache/activemq/bugs/AMQ3932Test.java   |   3 +
 .../org/apache/activemq/bugs/AMQ4083Test.java   |   3 +
 .../org/apache/activemq/bugs/AMQ4092Test.java   |   1 +
 .../org/apache/activemq/bugs/AMQ4160Test.java   |   2 +
 .../org/apache/activemq/bugs/AMQ4221Test.java   |   1 +
 .../bugs/AMQ4485LowLimitLevelDBTest.java        |   1 +
 .../activemq/bugs/AMQ4485LowLimitTest.java      |   1 +
 ...XBrokersWithNDestsFanoutTransactionTest.java |   1 +
 .../org/apache/activemq/bugs/AMQ4485Test.java   |   3 +
 .../org/apache/activemq/bugs/AMQ4607Test.java   |   2 +
 .../org/apache/activemq/bugs/AMQ4636Test.java   |   1 +
 .../org/apache/activemq/bugs/AMQ4930Test.java   |   2 +
 .../org/apache/activemq/bugs/AMQ4950Test.java   |   3 +
 .../activemq/bugs/AMQ5266SingleDestTest.java    |   2 +
 .../bugs/AMQ5266StarvedConsumerTest.java        |   2 +
 .../org/apache/activemq/bugs/AMQ5266Test.java   |   2 +
 .../org/apache/activemq/bugs/AMQ5567Test.java   |   1 +
 .../activemq/bugs/ConnectionPerMessageTest.java |   4 +
 .../org/apache/activemq/bugs/CraigsBugTest.java |   2 +
 .../apache/activemq/bugs/DoubleExpireTest.java  |   1 +
 .../activemq/bugs/DurableConsumerTest.java      |   6 +
 .../bugs/JMSDurableTopicNoLocalTest.java        |   1 +
 .../bugs/JmsDurableTopicSlowReceiveTest.java    |   4 +
 .../apache/activemq/bugs/JmsTimeoutTest.java    |   3 +
 .../activemq/bugs/MemoryUsageBrokerTest.java    |   2 +
 .../OptimizeAcknowledgeWithExpiredMsgsTest.java |   2 +
 .../activemq/bugs/OutOfOrderTestCase.java       |   2 +
 .../activemq/bugs/QueueWorkerPrefetchTest.java  |   4 +
 .../apache/activemq/bugs/SlowConsumerTest.java  |   2 +
 .../bugs/TransactionNotStartedErrorTest.java    |   9 ++
 .../bugs/TrapMessageInJDBCStoreTest.java        |   2 +
 .../activemq/bugs/VMTransportClosureTest.java   |   5 +
 .../activemq/bugs/amq1974/TryJmsClient.java     |   2 +
 .../activemq/bugs/amq1974/TryJmsManager.java    |   2 +
 .../command/ActiveMQBytesMessageTest.java       |   2 +
 .../command/ActiveMQDestinationTest.java        |   3 +
 .../command/ActiveMQMapMessageTest.java         |   2 +
 .../command/ActiveMQObjectMessageTest.java      |   2 +
 .../command/ActiveMQStreamMessageTest.java      |   2 +
 .../command/DataStructureTestSupport.java       |   1 +
 .../command/MessageCompressionTest.java         |   2 +
 .../activemq/config/BrokerXmlConfigTest.java    |   1 +
 .../activemq/console/command/AMQ3410Test.java   |   2 +
 .../activemq/console/command/AMQ3411Test.java   |   2 +
 .../activemq/filter/DummyPolicyEntry.java       |   1 +
 .../activemq/jndi/XAConnectionFactoryTest.java  |   1 +
 .../activemq/joramtests/ActiveMQAdmin.java      |  16 ++
 .../org/apache/activemq/load/LoadClient.java    |   1 +
 .../java/org/apache/activemq/load/LoadTest.java |   2 +
 .../management/BoundedRangeStatisticTest.java   |   1 +
 .../activemq/memory/buffer/DummyMessage.java    |   2 +
 .../memory/buffer/MemoryBufferTestSupport.java  |   1 +
 .../buffer/OrderBasedMemoryBufferTest.java      |   1 +
 .../buffer/SizeBasedMessageBufferTest.java      |   1 +
 .../DemandForwardingBridgeFilterTest.java       |   2 +
 .../activemq/network/ForwardingBridgeTest.java  |   2 +
 .../activemq/network/MulticastNetworkTest.java  |   2 +
 .../activemq/network/NetworkLoadTest.java       |   4 +
 .../activemq/network/NetworkReconnectTest.java  |   3 +
 .../activemq/network/NetworkRestartTest.java    |   2 +
 .../activemq/network/jms/QueueBridgeTest.java   |   3 +
 .../network/jms/QueueBridgeXBeanTest.java       |   1 +
 .../network/jms/TopicBridgeSpringTest.java      |   3 +
 .../network/jms/TopicBridgeXBeanTest.java       |   1 +
 .../activemq/openwire/BrokerInfoData.java       |   1 +
 .../activemq/openwire/WireFormatInfoData.java   |   1 +
 .../openwire/v1/ActiveMQBytesMessageTest.java   |   2 +
 .../v1/ActiveMQDestinationTestSupport.java      |   1 +
 .../openwire/v1/ActiveMQMapMessageTest.java     |   2 +
 .../openwire/v1/ActiveMQMessageTest.java        |   2 +
 .../openwire/v1/ActiveMQObjectMessageTest.java  |   2 +
 .../activemq/openwire/v1/ActiveMQQueueTest.java |   2 +
 .../openwire/v1/ActiveMQStreamMessageTest.java  |   2 +
 .../v1/ActiveMQTempDestinationTestSupport.java  |   1 +
 .../openwire/v1/ActiveMQTempQueueTest.java      |   2 +
 .../openwire/v1/ActiveMQTempTopicTest.java      |   2 +
 .../openwire/v1/ActiveMQTextMessageTest.java    |   2 +
 .../activemq/openwire/v1/ActiveMQTopicTest.java |   2 +
 .../openwire/v1/BaseCommandTestSupport.java     |   1 +
 .../activemq/openwire/v1/BrokerIdTest.java      |   2 +
 .../activemq/openwire/v1/BrokerInfoTest.java    |   2 +
 .../openwire/v1/ConnectionControlTest.java      |   2 +
 .../openwire/v1/ConnectionErrorTest.java        |   2 +
 .../activemq/openwire/v1/ConnectionIdTest.java  |   2 +
 .../openwire/v1/ConnectionInfoTest.java         |   2 +
 .../openwire/v1/ConsumerControlTest.java        |   2 +
 .../activemq/openwire/v1/ConsumerIdTest.java    |   2 +
 .../activemq/openwire/v1/ConsumerInfoTest.java  |   2 +
 .../openwire/v1/ControlCommandTest.java         |   2 +
 .../openwire/v1/DataArrayResponseTest.java      |   2 +
 .../activemq/openwire/v1/DataResponseTest.java  |   2 +
 .../openwire/v1/DestinationInfoTest.java        |   2 +
 .../openwire/v1/DiscoveryEventTest.java         |   2 +
 .../openwire/v1/ExceptionResponseTest.java      |   2 +
 .../activemq/openwire/v1/FlushCommandTest.java  |   2 +
 .../openwire/v1/IntegerResponseTest.java        |   2 +
 .../openwire/v1/JournalQueueAckTest.java        |   2 +
 .../openwire/v1/JournalTopicAckTest.java        |   2 +
 .../activemq/openwire/v1/JournalTraceTest.java  |   2 +
 .../openwire/v1/JournalTransactionTest.java     |   2 +
 .../activemq/openwire/v1/KeepAliveInfoTest.java |   2 +
 .../openwire/v1/LastPartialCommandTest.java     |   2 +
 .../openwire/v1/LocalTransactionIdTest.java     |   2 +
 .../activemq/openwire/v1/MessageAckTest.java    |   2 +
 .../v1/MessageDispatchNotificationTest.java     |   2 +
 .../openwire/v1/MessageDispatchTest.java        |   2 +
 .../activemq/openwire/v1/MessageIdTest.java     |   2 +
 .../openwire/v1/MessageTestSupport.java         |   1 +
 .../openwire/v1/NetworkBridgeFilterTest.java    |   2 +
 .../openwire/v1/PartialCommandTest.java         |   2 +
 .../activemq/openwire/v1/ProducerIdTest.java    |   2 +
 .../activemq/openwire/v1/ProducerInfoTest.java  |   2 +
 .../activemq/openwire/v1/RemoveInfoTest.java    |   2 +
 .../openwire/v1/RemoveSubscriptionInfoTest.java |   2 +
 .../activemq/openwire/v1/ReplayCommandTest.java |   2 +
 .../activemq/openwire/v1/ResponseTest.java      |   2 +
 .../activemq/openwire/v1/SessionIdTest.java     |   2 +
 .../activemq/openwire/v1/SessionInfoTest.java   |   2 +
 .../activemq/openwire/v1/ShutdownInfoTest.java  |   2 +
 .../openwire/v1/SubscriptionInfoTest.java       |   2 +
 .../openwire/v1/TransactionIdTestSupport.java   |   1 +
 .../openwire/v1/TransactionInfoTest.java        |   2 +
 .../openwire/v1/WireFormatInfoTest.java         |   2 +
 .../openwire/v1/XATransactionIdTest.java        |   2 +
 .../openwire/v2/ActiveMQBytesMessageTest.java   |   2 +
 .../v2/ActiveMQDestinationTestSupport.java      |   1 +
 .../openwire/v2/ActiveMQMapMessageTest.java     |   2 +
 .../openwire/v2/ActiveMQMessageTest.java        |   2 +
 .../openwire/v2/ActiveMQObjectMessageTest.java  |   2 +
 .../activemq/openwire/v2/ActiveMQQueueTest.java |   2 +
 .../openwire/v2/ActiveMQStreamMessageTest.java  |   2 +
 .../v2/ActiveMQTempDestinationTestSupport.java  |   1 +
 .../openwire/v2/ActiveMQTempQueueTest.java      |   2 +
 .../openwire/v2/ActiveMQTempTopicTest.java      |   2 +
 .../openwire/v2/ActiveMQTextMessageTest.java    |   2 +
 .../activemq/openwire/v2/ActiveMQTopicTest.java |   2 +
 .../openwire/v2/BaseCommandTestSupport.java     |   1 +
 .../activemq/openwire/v2/BrokerIdTest.java      |   2 +
 .../activemq/openwire/v2/BrokerInfoTest.java    |   2 +
 .../openwire/v2/ConnectionControlTest.java      |   2 +
 .../openwire/v2/ConnectionErrorTest.java        |   2 +
 .../activemq/openwire/v2/ConnectionIdTest.java  |   2 +
 .../openwire/v2/ConnectionInfoTest.java         |   2 +
 .../openwire/v2/ConsumerControlTest.java        |   2 +
 .../activemq/openwire/v2/ConsumerIdTest.java    |   2 +
 .../activemq/openwire/v2/ConsumerInfoTest.java  |   2 +
 .../openwire/v2/ControlCommandTest.java         |   2 +
 .../openwire/v2/DataArrayResponseTest.java      |   2 +
 .../activemq/openwire/v2/DataResponseTest.java  |   2 +
 .../openwire/v2/DestinationInfoTest.java        |   2 +
 .../openwire/v2/DiscoveryEventTest.java         |   2 +
 .../openwire/v2/ExceptionResponseTest.java      |   2 +
 .../activemq/openwire/v2/FlushCommandTest.java  |   2 +
 .../openwire/v2/IntegerResponseTest.java        |   2 +
 .../openwire/v2/JournalQueueAckTest.java        |   2 +
 .../openwire/v2/JournalTopicAckTest.java        |   2 +
 .../activemq/openwire/v2/JournalTraceTest.java  |   2 +
 .../openwire/v2/JournalTransactionTest.java     |   2 +
 .../activemq/openwire/v2/KeepAliveInfoTest.java |   2 +
 .../openwire/v2/LastPartialCommandTest.java     |   2 +
 .../openwire/v2/LocalTransactionIdTest.java     |   2 +
 .../activemq/openwire/v2/MessageAckTest.java    |   2 +
 .../v2/MessageDispatchNotificationTest.java     |   2 +
 .../openwire/v2/MessageDispatchTest.java        |   2 +
 .../activemq/openwire/v2/MessageIdTest.java     |   2 +
 .../activemq/openwire/v2/MessagePullTest.java   |   2 +
 .../openwire/v2/MessageTestSupport.java         |   1 +
 .../openwire/v2/NetworkBridgeFilterTest.java    |   2 +
 .../openwire/v2/PartialCommandTest.java         |   2 +
 .../activemq/openwire/v2/ProducerIdTest.java    |   2 +
 .../activemq/openwire/v2/ProducerInfoTest.java  |   2 +
 .../activemq/openwire/v2/RemoveInfoTest.java    |   2 +
 .../openwire/v2/RemoveSubscriptionInfoTest.java |   2 +
 .../activemq/openwire/v2/ReplayCommandTest.java |   2 +
 .../activemq/openwire/v2/ResponseTest.java      |   2 +
 .../activemq/openwire/v2/SessionIdTest.java     |   2 +
 .../activemq/openwire/v2/SessionInfoTest.java   |   2 +
 .../activemq/openwire/v2/ShutdownInfoTest.java  |   2 +
 .../openwire/v2/SubscriptionInfoTest.java       |   2 +
 .../openwire/v2/TransactionIdTestSupport.java   |   1 +
 .../openwire/v2/TransactionInfoTest.java        |   2 +
 .../openwire/v2/WireFormatInfoTest.java         |   2 +
 .../openwire/v2/XATransactionIdTest.java        |   2 +
 .../openwire/v3/BaseCommandTestSupport.java     |   1 +
 .../activemq/openwire/v3/BrokerIdTest.java      |   2 +
 .../activemq/openwire/v3/BrokerInfoTest.java    |   2 +
 .../openwire/v3/ConnectionControlTest.java      |   2 +
 .../openwire/v3/ConnectionErrorTest.java        |   2 +
 .../activemq/openwire/v3/ConnectionIdTest.java  |   2 +
 .../openwire/v3/ConnectionInfoTest.java         |   2 +
 .../openwire/v3/ConsumerControlTest.java        |   2 +
 .../activemq/openwire/v3/ConsumerIdTest.java    |   2 +
 .../activemq/openwire/v3/ConsumerInfoTest.java  |   2 +
 .../openwire/v3/ControlCommandTest.java         |   2 +
 .../openwire/v3/DataArrayResponseTest.java      |   2 +
 .../activemq/openwire/v3/DataResponseTest.java  |   2 +
 .../openwire/v3/DestinationInfoTest.java        |   2 +
 .../openwire/v3/DiscoveryEventTest.java         |   2 +
 .../openwire/v3/ExceptionResponseTest.java      |   2 +
 .../activemq/openwire/v3/FlushCommandTest.java  |   2 +
 .../openwire/v3/IntegerResponseTest.java        |   2 +
 .../openwire/v3/JournalQueueAckTest.java        |   2 +
 .../openwire/v3/JournalTopicAckTest.java        |   2 +
 .../activemq/openwire/v3/JournalTraceTest.java  |   2 +
 .../openwire/v3/JournalTransactionTest.java     |   2 +
 .../activemq/openwire/v3/KeepAliveInfoTest.java |   2 +
 .../openwire/v3/LastPartialCommandTest.java     |   2 +
 .../openwire/v3/LocalTransactionIdTest.java     |   2 +
 .../activemq/openwire/v3/MessageAckTest.java    |   2 +
 .../v3/MessageDispatchNotificationTest.java     |   2 +
 .../openwire/v3/MessageDispatchTest.java        |   2 +
 .../activemq/openwire/v3/MessageIdTest.java     |   2 +
 .../activemq/openwire/v3/MessagePullTest.java   |   2 +
 .../openwire/v3/MessageTestSupport.java         |   1 +
 .../openwire/v3/NetworkBridgeFilterTest.java    |   2 +
 .../openwire/v3/PartialCommandTest.java         |   2 +
 .../activemq/openwire/v3/ProducerAckTest.java   |   2 +
 .../activemq/openwire/v3/ProducerIdTest.java    |   2 +
 .../activemq/openwire/v3/ProducerInfoTest.java  |   2 +
 .../activemq/openwire/v3/RemoveInfoTest.java    |   2 +
 .../openwire/v3/RemoveSubscriptionInfoTest.java |   2 +
 .../activemq/openwire/v3/ReplayCommandTest.java |   2 +
 .../activemq/openwire/v3/ResponseTest.java      |   2 +
 .../activemq/openwire/v3/SessionIdTest.java     |   2 +
 .../activemq/openwire/v3/SessionInfoTest.java   |   2 +
 .../activemq/openwire/v3/ShutdownInfoTest.java  |   2 +
 .../openwire/v3/SubscriptionInfoTest.java       |   2 +
 .../openwire/v3/TransactionIdTestSupport.java   |   1 +
 .../openwire/v3/TransactionInfoTest.java        |   2 +
 .../openwire/v3/XATransactionIdTest.java        |   2 +
 .../openwire/v4/BaseCommandTestSupport.java     |   1 +
 .../activemq/openwire/v4/BrokerIdTest.java      |   2 +
 .../activemq/openwire/v4/BrokerInfoTest.java    |   2 +
 .../openwire/v4/ConnectionControlTest.java      |   2 +
 .../openwire/v4/ConnectionErrorTest.java        |   2 +
 .../activemq/openwire/v4/ConnectionIdTest.java  |   2 +
 .../openwire/v4/ConnectionInfoTest.java         |   2 +
 .../openwire/v4/ConsumerControlTest.java        |   2 +
 .../activemq/openwire/v4/ConsumerIdTest.java    |   2 +
 .../activemq/openwire/v4/ConsumerInfoTest.java  |   2 +
 .../openwire/v4/ControlCommandTest.java         |   2 +
 .../openwire/v4/DataArrayResponseTest.java      |   2 +
 .../activemq/openwire/v4/DataResponseTest.java  |   2 +
 .../openwire/v4/DestinationInfoTest.java        |   2 +
 .../openwire/v4/DiscoveryEventTest.java         |   2 +
 .../openwire/v4/ExceptionResponseTest.java      |   2 +
 .../activemq/openwire/v4/FlushCommandTest.java  |   2 +
 .../openwire/v4/IntegerResponseTest.java        |   2 +
 .../openwire/v4/JournalQueueAckTest.java        |   2 +
 .../openwire/v4/JournalTopicAckTest.java        |   2 +
 .../activemq/openwire/v4/JournalTraceTest.java  |   2 +
 .../openwire/v4/JournalTransactionTest.java     |   2 +
 .../activemq/openwire/v4/KeepAliveInfoTest.java |   2 +
 .../openwire/v4/LastPartialCommandTest.java     |   2 +
 .../openwire/v4/LocalTransactionIdTest.java     |   2 +
 .../activemq/openwire/v4/MessageAckTest.java    |   2 +
 .../v4/MessageDispatchNotificationTest.java     |   2 +
 .../openwire/v4/MessageDispatchTest.java        |   2 +
 .../activemq/openwire/v4/MessageIdTest.java     |   2 +
 .../activemq/openwire/v4/MessagePullTest.java   |   2 +
 .../openwire/v4/MessageTestSupport.java         |   1 +
 .../openwire/v4/NetworkBridgeFilterTest.java    |   2 +
 .../openwire/v4/PartialCommandTest.java         |   2 +
 .../activemq/openwire/v4/ProducerAckTest.java   |   2 +
 .../activemq/openwire/v4/ProducerIdTest.java    |   2 +
 .../activemq/openwire/v4/ProducerInfoTest.java  |   2 +
 .../activemq/openwire/v4/RemoveInfoTest.java    |   2 +
 .../openwire/v4/RemoveSubscriptionInfoTest.java |   2 +
 .../activemq/openwire/v4/ReplayCommandTest.java |   2 +
 .../activemq/openwire/v4/ResponseTest.java      |   2 +
 .../activemq/openwire/v4/SessionIdTest.java     |   2 +
 .../activemq/openwire/v4/SessionInfoTest.java   |   2 +
 .../activemq/openwire/v4/ShutdownInfoTest.java  |   2 +
 .../openwire/v4/SubscriptionInfoTest.java       |   2 +
 .../openwire/v4/TransactionIdTestSupport.java   |   1 +
 .../openwire/v4/TransactionInfoTest.java        |   2 +
 .../openwire/v4/XATransactionIdTest.java        |   2 +
 .../openwire/v5/BaseCommandTestSupport.java     |   1 +
 .../activemq/openwire/v5/BrokerIdTest.java      |   2 +
 .../activemq/openwire/v5/BrokerInfoTest.java    |   2 +
 .../openwire/v5/ConnectionControlTest.java      |   2 +
 .../openwire/v5/ConnectionErrorTest.java        |   2 +
 .../activemq/openwire/v5/ConnectionIdTest.java  |   2 +
 .../openwire/v5/ConnectionInfoTest.java         |   2 +
 .../openwire/v5/ConsumerControlTest.java        |   2 +
 .../activemq/openwire/v5/ConsumerIdTest.java    |   2 +
 .../activemq/openwire/v5/ConsumerInfoTest.java  |   2 +
 .../openwire/v5/ControlCommandTest.java         |   2 +
 .../openwire/v5/DataArrayResponseTest.java      |   2 +
 .../activemq/openwire/v5/DataResponseTest.java  |   2 +
 .../openwire/v5/DestinationInfoTest.java        |   2 +
 .../openwire/v5/DiscoveryEventTest.java         |   2 +
 .../openwire/v5/ExceptionResponseTest.java      |   2 +
 .../activemq/openwire/v5/FlushCommandTest.java  |   2 +
 .../openwire/v5/IntegerResponseTest.java        |   2 +
 .../openwire/v5/JournalQueueAckTest.java        |   2 +
 .../openwire/v5/JournalTopicAckTest.java        |   2 +
 .../activemq/openwire/v5/JournalTraceTest.java  |   2 +
 .../openwire/v5/JournalTransactionTest.java     |   2 +
 .../activemq/openwire/v5/KeepAliveInfoTest.java |   2 +
 .../openwire/v5/LastPartialCommandTest.java     |   2 +
 .../openwire/v5/LocalTransactionIdTest.java     |   2 +
 .../activemq/openwire/v5/MessageAckTest.java    |   2 +
 .../v5/MessageDispatchNotificationTest.java     |   2 +
 .../openwire/v5/MessageDispatchTest.java        |   2 +
 .../activemq/openwire/v5/MessageIdTest.java     |   2 +
 .../activemq/openwire/v5/MessagePullTest.java   |   2 +
 .../openwire/v5/MessageTestSupport.java         |   1 +
 .../openwire/v5/NetworkBridgeFilterTest.java    |   2 +
 .../openwire/v5/PartialCommandTest.java         |   2 +
 .../activemq/openwire/v5/ProducerAckTest.java   |   2 +
 .../activemq/openwire/v5/ProducerIdTest.java    |   2 +
 .../activemq/openwire/v5/ProducerInfoTest.java  |   2 +
 .../activemq/openwire/v5/RemoveInfoTest.java    |   2 +
 .../openwire/v5/RemoveSubscriptionInfoTest.java |   2 +
 .../activemq/openwire/v5/ReplayCommandTest.java |   2 +
 .../activemq/openwire/v5/ResponseTest.java      |   2 +
 .../activemq/openwire/v5/SessionIdTest.java     |   2 +
 .../activemq/openwire/v5/SessionInfoTest.java   |   2 +
 .../activemq/openwire/v5/ShutdownInfoTest.java  |   2 +
 .../openwire/v5/SubscriptionInfoTest.java       |   2 +
 .../openwire/v5/TransactionIdTestSupport.java   |   1 +
 .../openwire/v5/TransactionInfoTest.java        |   2 +
 .../openwire/v5/XATransactionIdTest.java        |   2 +
 .../openwire/v6/BaseCommandTestSupport.java     |   1 +
 .../activemq/openwire/v6/BrokerIdTest.java      |   2 +
 .../activemq/openwire/v6/BrokerInfoTest.java    |   2 +
 .../openwire/v6/ConnectionControlTest.java      |   2 +
 .../openwire/v6/ConnectionErrorTest.java        |   2 +
 .../activemq/openwire/v6/ConnectionIdTest.java  |   2 +
 .../openwire/v6/ConnectionInfoTest.java         |   2 +
 .../openwire/v6/ConsumerControlTest.java        |   2 +
 .../activemq/openwire/v6/ConsumerIdTest.java    |   2 +
 .../activemq/openwire/v6/ConsumerInfoTest.java  |   2 +
 .../openwire/v6/ControlCommandTest.java         |   2 +
 .../openwire/v6/DataArrayResponseTest.java      |   2 +
 .../activemq/openwire/v6/DataResponseTest.java  |   2 +
 .../openwire/v6/DestinationInfoTest.java        |   2 +
 .../openwire/v6/DiscoveryEventTest.java         |   2 +
 .../openwire/v6/ExceptionResponseTest.java      |   2 +
 .../activemq/openwire/v6/FlushCommandTest.java  |   2 +
 .../openwire/v6/IntegerResponseTest.java        |   2 +
 .../openwire/v6/JournalQueueAckTest.java        |   2 +
 .../openwire/v6/JournalTopicAckTest.java        |   2 +
 .../activemq/openwire/v6/JournalTraceTest.java  |   2 +
 .../openwire/v6/JournalTransactionTest.java     |   2 +
 .../activemq/openwire/v6/KeepAliveInfoTest.java |   2 +
 .../openwire/v6/LastPartialCommandTest.java     |   2 +
 .../openwire/v6/LocalTransactionIdTest.java     |   2 +
 .../activemq/openwire/v6/MessageAckTest.java    |   2 +
 .../v6/MessageDispatchNotificationTest.java     |   2 +
 .../openwire/v6/MessageDispatchTest.java        |   2 +
 .../activemq/openwire/v6/MessageIdTest.java     |   2 +
 .../activemq/openwire/v6/MessagePullTest.java   |   2 +
 .../openwire/v6/MessageTestSupport.java         |   1 +
 .../openwire/v6/NetworkBridgeFilterTest.java    |   2 +
 .../openwire/v6/PartialCommandTest.java         |   2 +
 .../activemq/openwire/v6/ProducerAckTest.java   |   2 +
 .../activemq/openwire/v6/ProducerIdTest.java    |   2 +
 .../activemq/openwire/v6/ProducerInfoTest.java  |   2 +
 .../activemq/openwire/v6/RemoveInfoTest.java    |   2 +
 .../openwire/v6/RemoveSubscriptionInfoTest.java |   2 +
 .../activemq/openwire/v6/ReplayCommandTest.java |   2 +
 .../activemq/openwire/v6/ResponseTest.java      |   2 +
 .../activemq/openwire/v6/SessionIdTest.java     |   2 +
 .../activemq/openwire/v6/SessionInfoTest.java   |   2 +
 .../activemq/openwire/v6/ShutdownInfoTest.java  |   2 +
 .../openwire/v6/SubscriptionInfoTest.java       |   2 +
 .../openwire/v6/TransactionIdTestSupport.java   |   1 +
 .../openwire/v6/TransactionInfoTest.java        |   2 +
 .../openwire/v6/XATransactionIdTest.java        |   2 +
 .../openwire/v7/BaseCommandTestSupport.java     |   1 +
 .../activemq/openwire/v7/BrokerIdTest.java      |   2 +-
 .../activemq/openwire/v7/BrokerInfoTest.java    |   2 +-
 .../openwire/v7/ConnectionControlTest.java      |   2 +-
 .../openwire/v7/ConnectionErrorTest.java        |   2 +-
 .../activemq/openwire/v7/ConnectionIdTest.java  |   2 +-
 .../openwire/v7/ConnectionInfoTest.java         |   2 +-
 .../openwire/v7/ConsumerControlTest.java        |   2 +-
 .../activemq/openwire/v7/ConsumerIdTest.java    |   2 +-
 .../activemq/openwire/v7/ConsumerInfoTest.java  |   2 +-
 .../openwire/v7/ControlCommandTest.java         |   2 +-
 .../openwire/v7/DataArrayResponseTest.java      |   2 +-
 .../activemq/openwire/v7/DataResponseTest.java  |   2 +-
 .../openwire/v7/DestinationInfoTest.java        |   2 +-
 .../openwire/v7/DiscoveryEventTest.java         |   2 +-
 .../openwire/v7/ExceptionResponseTest.java      |   2 +-
 .../activemq/openwire/v7/FlushCommandTest.java  |   2 +-
 .../openwire/v7/IntegerResponseTest.java        |   2 +-
 .../openwire/v7/JournalQueueAckTest.java        |   2 +-
 .../openwire/v7/JournalTopicAckTest.java        |   2 +-
 .../activemq/openwire/v7/JournalTraceTest.java  |   2 +-
 .../openwire/v7/JournalTransactionTest.java     |   2 +-
 .../activemq/openwire/v7/KeepAliveInfoTest.java |   2 +-
 .../openwire/v7/LastPartialCommandTest.java     |   2 +-
 .../openwire/v7/LocalTransactionIdTest.java     |   2 +-
 .../activemq/openwire/v7/MessageAckTest.java    |   2 +-
 .../v7/MessageDispatchNotificationTest.java     |   2 +-
 .../openwire/v7/MessageDispatchTest.java        |   2 +-
 .../activemq/openwire/v7/MessageIdTest.java     |   2 +-
 .../activemq/openwire/v7/MessagePullTest.java   |   2 +-
 .../openwire/v7/MessageTestSupport.java         |   2 +-
 .../openwire/v7/NetworkBridgeFilterTest.java    |   2 +-
 .../openwire/v7/PartialCommandTest.java         |   2 +-
 .../activemq/openwire/v7/ProducerAckTest.java   |   2 +-
 .../activemq/openwire/v7/ProducerIdTest.java    |   2 +-
 .../activemq/openwire/v7/ProducerInfoTest.java  |   2 +-
 .../activemq/openwire/v7/RemoveInfoTest.java    |   2 +-
 .../openwire/v7/RemoveSubscriptionInfoTest.java |   2 +-
 .../activemq/openwire/v7/ReplayCommandTest.java |   2 +-
 .../activemq/openwire/v7/ResponseTest.java      |   2 +-
 .../activemq/openwire/v7/SessionIdTest.java     |   2 +-
 .../activemq/openwire/v7/SessionInfoTest.java   |   2 +-
 .../activemq/openwire/v7/ShutdownInfoTest.java  |   2 +-
 .../openwire/v7/SubscriptionInfoTest.java       |   2 +-
 .../openwire/v7/TransactionIdTestSupport.java   |   2 +-
 .../openwire/v7/TransactionInfoTest.java        |   2 +-
 .../openwire/v7/XATransactionIdTest.java        |   2 +-
 .../openwire/v8/BaseCommandTestSupport.java     |   1 +
 .../activemq/openwire/v8/BrokerIdTest.java      |   2 +-
 .../activemq/openwire/v8/BrokerInfoTest.java    |   2 +-
 .../openwire/v8/ConnectionControlTest.java      |   2 +-
 .../openwire/v8/ConnectionErrorTest.java        |   2 +-
 .../activemq/openwire/v8/ConnectionIdTest.java  |   2 +-
 .../openwire/v8/ConnectionInfoTest.java         |   2 +-
 .../openwire/v8/ConsumerControlTest.java        |   2 +-
 .../activemq/openwire/v8/ConsumerIdTest.java    |   2 +-
 .../activemq/openwire/v8/ConsumerInfoTest.java  |   2 +-
 .../openwire/v8/ControlCommandTest.java         |   2 +-
 .../openwire/v8/DataArrayResponseTest.java      |   2 +-
 .../activemq/openwire/v8/DataResponseTest.java  |   2 +-
 .../openwire/v8/DestinationInfoTest.java        |   2 +-
 .../openwire/v8/DiscoveryEventTest.java         |   2 +-
 .../openwire/v8/ExceptionResponseTest.java      |   2 +-
 .../activemq/openwire/v8/FlushCommandTest.java  |   2 +-
 .../openwire/v8/IntegerResponseTest.java        |   2 +-
 .../openwire/v8/JournalQueueAckTest.java        |   2 +-
 .../openwire/v8/JournalTopicAckTest.java        |   2 +-
 .../activemq/openwire/v8/JournalTraceTest.java  |   2 +-
 .../openwire/v8/JournalTransactionTest.java     |   2 +-
 .../activemq/openwire/v8/KeepAliveInfoTest.java |   2 +-
 .../openwire/v8/LastPartialCommandTest.java     |   2 +-
 .../openwire/v8/LocalTransactionIdTest.java     |   2 +-
 .../activemq/openwire/v8/MessageAckTest.java    |   2 +-
 .../v8/MessageDispatchNotificationTest.java     |   2 +-
 .../openwire/v8/MessageDispatchTest.java        |   2 +-
 .../activemq/openwire/v8/MessageIdTest.java     |   2 +-
 .../activemq/openwire/v8/MessagePullTest.java   |   2 +-
 .../openwire/v8/MessageTestSupport.java         |   2 +-
 .../openwire/v8/NetworkBridgeFilterTest.java    |   2 +-
 .../openwire/v8/PartialCommandTest.java         |   2 +-
 .../activemq/openwire/v8/ProducerAckTest.java   |   2 +-
 .../activemq/openwire/v8/ProducerIdTest.java    |   2 +-
 .../activemq/openwire/v8/ProducerInfoTest.java  |   2 +-
 .../activemq/openwire/v8/RemoveInfoTest.java    |   2 +-
 .../openwire/v8/RemoveSubscriptionInfoTest.java |   2 +-
 .../activemq/openwire/v8/ReplayCommandTest.java |   2 +-
 .../activemq/openwire/v8/ResponseTest.java      |   2 +-
 .../activemq/openwire/v8/SessionIdTest.java     |   2 +-
 .../activemq/openwire/v8/SessionInfoTest.java   |   2 +-
 .../activemq/openwire/v8/ShutdownInfoTest.java  |   2 +-
 .../openwire/v8/SubscriptionInfoTest.java       |   2 +-
 .../openwire/v8/TransactionIdTestSupport.java   |   2 +-
 .../openwire/v8/TransactionInfoTest.java        |   2 +-
 .../openwire/v8/XATransactionIdTest.java        |   2 +-
 .../openwire/v9/BaseCommandTestSupport.java     |   1 +
 .../activemq/openwire/v9/BrokerIdTest.java      |   2 +-
 .../activemq/openwire/v9/BrokerInfoTest.java    |   2 +-
 .../openwire/v9/ConnectionControlTest.java      |   2 +-
 .../openwire/v9/ConnectionErrorTest.java        |   2 +-
 .../activemq/openwire/v9/ConnectionIdTest.java  |   2 +-
 .../openwire/v9/ConnectionInfoTest.java         |   2 +-
 .../openwire/v9/ConsumerControlTest.java        |   2 +-
 .../activemq/openwire/v9/ConsumerIdTest.java    |   2 +-
 .../activemq/openwire/v9/ConsumerInfoTest.java  |   2 +-
 .../openwire/v9/ControlCommandTest.java         |   2 +-
 .../openwire/v9/DataArrayResponseTest.java      |   2 +-
 .../activemq/openwire/v9/DataResponseTest.java  |   2 +-
 .../openwire/v9/DestinationInfoTest.java        |   2 +-
 .../openwire/v9/DiscoveryEventTest.java         |   2 +-
 .../openwire/v9/ExceptionResponseTest.java      |   2 +-
 .../activemq/openwire/v9/FlushCommandTest.java  |   2 +-
 .../openwire/v9/IntegerResponseTest.java        |   2 +-
 .../openwire/v9/JournalQueueAckTest.java        |   2 +-
 .../openwire/v9/JournalTopicAckTest.java        |   2 +-
 .../activemq/openwire/v9/JournalTraceTest.java  |   2 +-
 .../openwire/v9/JournalTransactionTest.java     |   2 +-
 .../activemq/openwire/v9/KeepAliveInfoTest.java |   2 +-
 .../openwire/v9/LastPartialCommandTest.java     |   2 +-
 .../openwire/v9/LocalTransactionIdTest.java     |   2 +-
 .../activemq/openwire/v9/MessageAckTest.java    |   2 +-
 .../v9/MessageDispatchNotificationTest.java     |   2 +-
 .../openwire/v9/MessageDispatchTest.java        |   2 +-
 .../activemq/openwire/v9/MessageIdTest.java     |   2 +-
 .../activemq/openwire/v9/MessagePullTest.java   |   2 +-
 .../openwire/v9/MessageTestSupport.java         |   2 +-
 .../openwire/v9/NetworkBridgeFilterTest.java    |   2 +-
 .../openwire/v9/PartialCommandTest.java         |   2 +-
 .../activemq/openwire/v9/ProducerAckTest.java   |   2 +-
 .../activemq/openwire/v9/ProducerIdTest.java    |   2 +-
 .../activemq/openwire/v9/ProducerInfoTest.java  |   2 +-
 .../activemq/openwire/v9/RemoveInfoTest.java    |   2 +-
 .../openwire/v9/RemoveSubscriptionInfoTest.java |   2 +-
 .../activemq/openwire/v9/ReplayCommandTest.java |   2 +-
 .../activemq/openwire/v9/ResponseTest.java      |   2 +-
 .../activemq/openwire/v9/SessionIdTest.java     |   2 +-
 .../activemq/openwire/v9/SessionInfoTest.java   |   2 +-
 .../activemq/openwire/v9/ShutdownInfoTest.java  |   2 +-
 .../openwire/v9/SubscriptionInfoTest.java       |   2 +-
 .../openwire/v9/TransactionIdTestSupport.java   |   2 +-
 .../openwire/v9/TransactionInfoTest.java        |   2 +-
 .../openwire/v9/XATransactionIdTest.java        |   2 +-
 .../org/apache/activemq/perf/KahaQueueTest.java |   1 +
 .../activemq/perf/LevelDBStoreQueueTest.java    |   1 +
 .../org/apache/activemq/perf/PerfConsumer.java  |   1 +
 .../org/apache/activemq/perf/PerfProducer.java  |   1 +
 .../perf/SimpleDurableTopicNetworkTest.java     |   3 +
 .../apache/activemq/perf/SimpleNetworkTest.java |   2 +
 .../SimpleNonPersistentQueueNetworkTest.java    |   6 +
 .../perf/SimpleNonPersistentTopicTest.java      |   1 +
 .../org/apache/activemq/perf/SlowConsumer.java  |   1 +
 .../activemq/perf/SlowConsumerTopicTest.java    |   5 +
 .../TemporaryTopicMemoryAllocationTest.java     |   1 +
 ...veTwoConnectionsWithSenderUsingPoolTest.java |   3 +
 .../activemq/proxy/ProxyConnectorTest.java      |   1 +
 .../apache/activemq/proxy/ProxyTestSupport.java |   4 +
 ...stractCachedLDAPAuthorizationModuleTest.java |   1 +
 ...APAuthorizationModuleLegacyOpenLDAPTest.java |   6 +
 ...CachedLDAPAuthorizationModuleLegacyTest.java |   4 +
 ...chedLDAPAuthorizationModuleOpenLDAPTest.java |   1 +
 .../CachedLDAPAuthorizationModuleTest.java      |   1 +
 .../org/apache/activemq/security/DoSTest.java   |   2 +
 .../activemq/security/JaasNetworkTest.java      |   2 +
 .../activemq/security/SecurityTestSupport.java  |   1 +
 ...SimpleAuthenticationPluginSeparatorTest.java |   9 ++
 .../security/SimpleAuthorizationMapTest.java    |   1 +
 .../SimpleSecurityBrokerSystemTest.java         |   3 +
 .../security/StubDoNothingCallbackHandler.java  |   1 +
 .../security/StubDualJaasConfiguration.java     |   2 +
 .../security/StubJaasConfiguration.java         |   2 +
 .../activemq/security/StubSecurityContext.java  |   1 +
 .../activemq/security/XBeanSecurityTest.java    |   1 +
 ...nSecurityWithGuestNoCredentialsOnlyTest.java |   1 +
 .../security/XBeanSecurityWithGuestTest.java    |   1 +
 .../apache/activemq/spring/SpringConsumer.java  |   1 +
 .../apache/activemq/spring/SpringProducer.java  |   1 +
 .../store/AutoStorePerDestinationTest.java      |   1 +
 .../apache/activemq/store/StoreOrderTest.java   |   1 +
 .../store/jdbc/JDBCIOExceptionHandlerTest.java  |   2 +
 .../store/jdbc/JDBCNegativeQueueTest.java       |   2 +
 .../store/jdbc/JDBCNetworkBrokerDetachTest.java |   1 +
 .../store/jdbc/JDBCPersistenceAdapterTest.java  |   1 +
 .../store/jdbc/JDBCStoreBrokerTest.java         |   1 +
 .../activemq/store/jdbc/JDBCTestMemory.java     |   4 +
 .../kahadb/KahaDBPersistenceAdapterTest.java    |   1 +
 .../store/kahadb/KahaDBStoreBrokerTest.java     |   2 +
 .../activemq/store/kahadb/KahaDBStoreTest.java  |   2 +
 .../store/kahadb/TempKahaDBStoreBrokerTest.java |   1 +
 .../kahadb/perf/KahaStoreDurableTopicTest.java  |   1 +
 .../store/kahadb/perf/KahaStoreQueueTest.java   |   1 +
 .../kahadb/perf/TempKahaStoreQueueTest.java     |   1 +
 .../store/leveldb/LevelDBStoreBrokerTest.java   |   2 +
 .../test/JmsSendReceiveTestSupport.java         |   2 +
 .../activemq/test/JmsTopicSendReceiveTest.java  |   2 +
 ...veWithTwoConnectionsAndByteSelectorTest.java |   2 +
 ...WithTwoConnectionsAndEmbeddedBrokerTest.java |   3 +
 ...sTopicSendReceiveWithTwoConnectionsTest.java |   3 +
 .../test/retroactive/DummyMessageQuery.java     |   2 +
 ...sumerTestWithDestinationBasedBufferTest.java |   1 +
 ...TestWithLastImagePolicyWithWildcardTest.java |   4 +
 ...troactiveConsumerTestWithTimePolicyTest.java |   1 +
 .../CloseRollbackRedeliveryQueueTest.java       |   4 +
 .../DelegatingTransactionalMessageListener.java |   1 +
 .../RollbacksWhileConsumingLargeQueueTest.java  |   5 +
 .../activemq/transport/QueueClusterTest.java    |   2 +
 .../transport/SoWriteTimeoutClientTest.java     |   1 +
 .../activemq/transport/SoWriteTimeoutTest.java  |   1 +
 .../transport/StubCompositeTransport.java       |   2 +
 .../activemq/transport/StubTransport.java       |   5 +
 .../activemq/transport/TopicClusterTest.java    |   3 +
 .../transport/TransportBrokerTestSupport.java   |   4 +
 .../discovery/DiscoveryTransportBrokerTest.java |   5 +
 .../ZeroconfDiscoverTransportTest.java          |   1 +
 .../transport/failover/AMQ1925Test.java         |   5 +
 .../transport/failover/BadConnectionTest.java   |   6 +
 .../FailoverConsumerOutstandingCommitTest.java  |   6 +
 .../FailoverConsumerUnconsumedTest.java         |  10 ++
 .../failover/FailoverPrefetchZeroTest.java      |   2 +
 .../transport/failover/FailoverRandomTest.java  |   2 +
 .../failover/FailoverTransactionTest.java       |  19 +++
 .../failover/FailoverTransportTest.java         |  12 ++
 .../transport/failover/ReconnectTest.java       |   7 +
 .../transport/failover/SlowConnectionTest.java  |   3 +
 .../activemq/transport/fanout/FanoutTest.java   |   2 +
 .../fanout/FanoutTransportBrokerTest.java       |   4 +
 .../multicast/MulticastTransportTest.java       |   2 +
 .../nio/NIOJmsDurableTopicSendReceiveTest.java  |   3 +
 .../transport/nio/NIOJmsSendAndReceiveTest.java |   3 +
 .../nio/NIOPersistentSendAndReceiveTest.java    |   2 +
 .../activemq/transport/nio/NIOSSLLoadTest.java  |   1 +
 .../nio/NIOSSLTransportBrokerTest.java          |   2 +
 .../transport/nio/NIOTransportBrokerTest.java   |   1 +
 .../reliable/ReliableTransportTest.java         |   1 +
 .../UnreliableCommandDatagramChannel.java       |   1 +
 .../UnreliableCommandDatagramSocket.java        |   1 +
 .../reliable/UnreliableUdpTransport.java        |   1 +
 .../transport/tcp/InactivityMonitorTest.java    |  17 ++
 .../transport/tcp/ServerSocketTstFactory.java   |   3 +
 .../transport/tcp/SslBrokerServiceTest.java     |   2 +
 .../transport/tcp/SslTransportBrokerTest.java   |   2 +
 .../transport/tcp/SslTransportFactoryTest.java  |   2 +
 .../transport/tcp/SslTransportServerTest.java   |   2 +
 .../transport/tcp/SslTransportTest.java         |   2 +
 .../transport/tcp/StubSSLServerSocket.java      |  14 ++
 .../activemq/transport/tcp/StubSSLSession.java  |  21 +++
 .../activemq/transport/tcp/StubSSLSocket.java   |  18 +++
 .../transport/tcp/StubSSLSocketFactory.java     |   5 +
 .../transport/tcp/StubX509Certificate.java      |  26 ++++
 .../transport/tcp/TcpFaultyTransport.java       |   1 +
 .../tcp/TcpFaultyTransportFactory.java          |   4 +
 .../transport/tcp/TcpFaultyTransportServer.java |   1 +
 .../transport/tcp/TcpTransportBrokerTest.java   |   2 +
 .../tcp/WireformatNegociationTest.java          |  12 ++
 ...eWithTwoConnectionsAndLargeMessagesTest.java |   1 +
 .../UdpSendReceiveWithTwoConnectionsTest.java   |   3 +
 .../activemq/transport/udp/UdpTestSupport.java  |  12 ++
 .../transport/udp/UdpTransportTest.java         |   2 +
 .../udp/UdpTransportUsingServerTest.java        |   3 +
 .../transport/udp/UpdTransportBindTest.java     |   1 +
 .../transport/vm/VMTransportBrokerTest.java     |   1 +
 .../vm/VMTransportEmbeddedBrokerTest.java       |   3 +
 .../usage/CompositeMessageCursorUsageTest.java  |   5 +
 .../apache/activemq/usage/StoreUsageTest.java   |   2 +
 .../AuthorizationFromAdminViewTest.java         |   3 +
 .../usecases/BacklogNetworkCrossTalkTest.java   |   1 +
 .../activemq/usecases/ClientRebalanceTest.java  |   1 +
 .../activemq/usecases/CompositeConsumeTest.java |   2 +
 .../ConcurrentDestinationCreationTest.java      |   1 +
 .../ConcurrentProducerQueueConsumerTest.java    |   2 +
 .../usecases/ConsumeQueuePrefetchTest.java      |   1 +
 .../usecases/ConsumeTopicPrefetchTest.java      |   2 +
 .../CreateTemporaryQueueBeforeStartTest.java    |   3 +
 ...DurableConsumerCloseAndReconnectTcpTest.java |   8 +
 .../DurableConsumerCloseAndReconnectTest.java   |   1 +
 .../DurableSubDelayedUnsubscribeTest.java       |   1 +
 .../usecases/DurableSubInBrokerNetworkTest.java |   2 +
 .../usecases/DurableSubProcessTest.java         |   2 +
 .../DurableSubsOfflineSelectorIndexUseTest.java |   5 +
 ...ableSubscriberWithNetworkDisconnectTest.java |   3 +
 ...DurableSubscriberWithNetworkRestartTest.java |   3 +
 .../DurableSubscriptionActivationTest.java      |   4 +
 .../DurableSubscriptionReactivationTest.java    |   3 +
 .../DurableSubscriptionRemoveOfflineTest.java   |   3 +
 .../usecases/DurableUnsubscribeTest.java        |   4 +
 .../usecases/ExceptionListenerTest.java         |   1 +
 .../usecases/JDBCDurableSubscriptionTest.java   |   1 +
 .../JournalDurableSubscriptionTest.java         |   1 +
 .../usecases/KahaDBDurableSubscriptionTest.java |   1 +
 .../LevelDBDurableSubscriptionTest.java         |   1 +
 .../ManagedDurableSubscriptionTest.java         |   1 +
 .../usecases/MessageGroupCloseTest.java         |   3 +
 .../usecases/MessageGroupNewConsumerTest.java   |   3 +
 .../activemq/usecases/MessageReroutingTest.java |   1 +
 .../usecases/MultiBrokersMultiClientsTest.java  |   2 +
 .../MultiBrokersMultiClientsUsingTcpTest.java   |   1 +
 .../MulticastDiscoveryOnFaultyNetworkTest.java  |   1 +
 .../usecases/NetworkAsyncStartTest.java         |   1 +
 .../usecases/NetworkOfTwentyBrokersTest.java    |   4 +
 .../usecases/NoDuplicateOnTopicNetworkTest.java |   6 +
 .../ObjectMessageNotSerializableTest.java       |   8 +
 .../usecases/ProducerConsumerTestSupport.java   |   2 +
 ...ublishOnDurableTopicConsumedMessageTest.java |   1 +
 ...OnQueueConsumedMessageInTransactionTest.java |   3 +
 .../PublishOnQueueConsumedMessageTest.java      |   1 +
 ...ueueConsumedMessageUsingActivemqXMLTest.java |   3 +
 ...lishOnTemporaryQueueConsumedMessageTest.java |   1 +
 .../PublishOnTopicConsumedMessageTest.java      |   2 +
 ...opicConsumerMessageUsingActivemqXMLTest.java |   3 +
 .../QueueConsumerCloseAndReconnectTest.java     |   1 +
 .../activemq/usecases/QueueDuplicatesTest.java  |   4 +
 .../QueueMemoryFullMultiBrokersTest.java        |   1 +
 .../activemq/usecases/QueueRedeliverTest.java   |   1 +
 .../activemq/usecases/QueueRepeaterTest.java    |   2 +
 .../usecases/ReliableReconnectTest.java         |   4 +
 ...AndBrokerDoesNotLeaveThreadsRunningTest.java |   2 +
 .../usecases/ThreeBrokerQueueNetworkTest.java   |   4 +
 ...reeBrokerVirtualTopicNetworkLevelDBTest.java |   1 +
 .../ThreeBrokerVirtualTopicNetworkTest.java     |   1 +
 .../usecases/TopicProducerFlowControlTest.java  |   5 +
 .../activemq/usecases/TopicRedeliverTest.java   |   2 +
 .../TopicSubscriptionSlowConsumerTest.java      |   2 +
 .../usecases/TransactionRollbackOrderTest.java  |   2 +
 .../usecases/TransientQueueRedeliverTest.java   |   1 +
 ...essageNotSentToRemoteWhenNoConsumerTest.java |   1 +
 .../usecases/TwoBrokerMulticastQueueTest.java   |   2 +
 ...dcardDynamicallyIncludedDestinationTest.java |   1 +
 ...ldcardStaticallyIncludedDestinationTest.java |   1 +
 .../TwoBrokerNetworkLoadBalanceTest.java        |   2 +
 .../usecases/TwoBrokerQueueSendReceiveTest.java |   1 +
 ...icSendReceiveLotsOfMessagesUsingTcpTest.java |   1 +
 ...icSendReceiveUsingJavaConfigurationTest.java |   3 +
 .../TwoBrokerTopicSendReceiveUsingTcpTest.java  |   4 +
 ...rVirtualDestDinamicallyIncludedDestTest.java |   1 +
 .../TwoBrokerVirtualTopicForwardingTest.java    |   1 +
 ...castDiscoveryBrokerTopicSendReceiveTest.java |   3 +
 .../TwoSecureBrokerRequestReplyTest.java        |   1 +
 .../activemq/usecases/UnlimitedEnqueueTest.java |   1 +
 .../VerifyNetworkConsumersDisconnectTest.java   |   2 +
 .../apache/activemq/util/ProducerThread.java    |   1 +
 .../activemq/util/ReflectionSupportTest.java    |   1 +
 .../JDBCPersistenceAdapterXBeanConfigTest.java  |   2 +
 .../xbean/JDBCPersistenceXBeanConfigTest.java   |   2 +
 ...stsWithEmbeddedBrokerAndPersistenceTest.java |   1 +
 .../MultipleTestsWithSpringFactoryBeanTest.java |   2 +
 ...ipleTestsWithSpringXBeanFactoryBeanTest.java |   2 +
 .../MultipleTestsWithXBeanFactoryBeanTest.java  |   1 +
 .../org/apache/activemq/xbean/XBeanXmlTest.java |   1 +
 .../byteman/ActiveMQMessageHandlerTest.java     |   4 +
 .../byteman/ConcurrentDeliveryCancelTest.java   |   2 +
 .../byteman/InterruptedMessageHandlerTest.java  |   4 +
 .../tests/extras/byteman/PagingLeakTest.java    |   1 +
 .../byteman/ScaleDownGroupedFailoverTest.java   |   1 +
 .../byteman/ScaleDownGroupedFailureTest.java    |   1 +
 .../tests/extras/byteman/TimeoutXATest.java     |   2 +
 .../tests/extras/jms/bridge/BridgeTestBase.java |   9 ++
 .../jms/bridge/ClusteredBridgeTestBase.java     |   2 +
 .../jms/bridge/JMSBridgeReconnectionTest.java   |   1 +
 .../tests/extras/jms/bridge/JMSBridgeTest.java  |   1 +
 ...MDBMultipleHandlersServerDisconnectTest.java |   8 +
 .../extras/jms/xa/JMSXDeliveryCountTest.java    |  11 ++
 .../artemis/tests/extras/jms/xa/XATest.java     |  10 ++
 .../hornetq/HornetQProtocolManagerTest.java     |   2 +
 .../protocols/hornetq/HornetQProtocolTest.java  |   2 +
 .../integration/SimpleNotificationService.java  |   5 +
 .../integration/client/AcknowledgeTest.java     |   3 +
 .../integration/client/ActiveMQCrashTest.java   |   2 +
 .../client/AutoCreateJmsQueueTest.java          |   1 +
 .../integration/client/AutogroupIdTest.java     |   1 +
 .../integration/client/CommitRollbackTest.java  |   2 +
 .../ConcurrentCreateDeleteProduceTest.java      |   2 +
 .../integration/client/ConsumerCloseTest.java   |   5 +
 .../integration/client/ConsumerStuckTest.java   |   3 +
 .../tests/integration/client/ConsumerTest.java  |   6 +
 .../client/ConsumerWindowSizeTest.java          |   3 +
 .../client/DeadLetterAddressTest.java           |   1 +
 .../integration/client/DeliveryOrderTest.java   |   1 +
 .../integration/client/FailureDeadlockTest.java |   1 +
 .../integration/client/HangConsumerTest.java    |   1 +
 .../client/InterruptedLargeMessageTest.java     |   2 +
 .../integration/client/LargeMessageTest.java    |   1 +
 .../client/MessageConcurrencyTest.java          |   2 +
 .../client/MessageConsumerRollbackTest.java     |   2 +
 .../client/MessageDurabilityTest.java           |   2 +
 .../MessageGroupingConnectionFactoryTest.java   |   1 +
 .../integration/client/MessageGroupingTest.java |   1 +
 .../integration/client/MessageHandlerTest.java  |   4 +
 .../integration/client/MessageRateTest.java     |   1 +
 .../client/MultipleThreadFilterOneTest.java     |   2 +
 .../tests/integration/client/NIOvsOIOTest.java  |   1 +
 .../tests/integration/client/PagingTest.java    |  12 ++
 .../integration/client/ProducerCloseTest.java   |   1 +
 .../client/ProducerFlowControlTest.java         |   2 +
 .../tests/integration/client/ProducerTest.java  |   2 +
 .../client/ReceiveImmediateTest.java            |   1 +
 .../tests/integration/client/ReceiveTest.java   |   1 +
 .../client/RedeliveryConsumerTest.java          |   5 +
 .../tests/integration/client/RequestorTest.java |   4 +
 .../client/ServerLocatorConnectTest.java        |   1 +
 .../integration/client/SessionCloseTest.java    |  17 ++
 .../SessionSendAcknowledgementHandlerTest.java  |   1 +
 .../client/SessionStopStartTest.java            |   4 +
 .../tests/integration/client/SessionTest.java   |   1 +
 .../integration/client/TemporaryQueueTest.java  |   5 +
 .../integration/client/TransientQueueTest.java  |   1 +
 .../clientcrash/DummyInterceptor.java           |   1 +
 .../clientcrash/DummyInterceptorB.java          |   1 +
 .../integration/cluster/NodeManagerTest.java    |   1 +
 .../integration/cluster/bridge/BridgeTest.java  |   2 +
 .../cluster/bridge/SimpleTransformer.java       |   1 +
 .../cluster/distribution/ClusterTestBase.java   |   1 +
 .../distribution/ClusteredGroupingTest.java     |   9 ++
 .../LargeMessageRedistributionTest.java         |   1 +
 .../NettyFileStorageSymmetricClusterTest.java   |   1 +
 ...leStorageSymmetricClusterWithBackupTest.java |   1 +
 ...torageSymmetricClusterWithDiscoveryTest.java |   1 +
 .../SymmetricClusterWithDiscoveryTest.java      |   1 +
 .../failover/AsynchronousFailoverTest.java      |   2 +
 .../cluster/failover/DelayInterceptor.java      |   1 +
 .../cluster/failover/DelayInterceptor2.java     |   1 +
 .../cluster/failover/DelayInterceptor3.java     |   1 +
 .../cluster/failover/FailBackManualTest.java    |   1 +
 .../failover/FailoverOnFlowControlTest.java     |   1 +
 .../cluster/failover/FailoverTest.java          |   3 +
 .../failover/LiveToLiveFailoverTest.java        |   7 +
 .../MultiThreadRandomReattachTestBase.java      |   1 +
 .../cluster/reattach/OrderReattachTest.java     |   1 +
 .../cluster/reattach/RandomReattachTest.java    |   1 +
 .../cluster/reattach/ReattachTest.java          |   2 +
 .../cluster/util/BackupSyncDelay.java           |   1 +
 .../cluster/util/MultiServerTestBase.java       |   1 +
 .../cluster/util/SameProcessActiveMQServer.java |   9 ++
 .../cluster/util/TestableServer.java            |   1 +
 .../discovery/DiscoveryBaseTest.java            |   3 +
 .../discovery/DiscoveryStayAliveTest.java       |   2 +
 .../integration/interceptors/Incoming.java      |   1 +
 .../interceptors/InterceptorTest.java           |  12 ++
 .../integration/interceptors/Outgoing.java      |   1 +
 .../ManualReconnectionToSingleServerTest.java   |   2 +
 .../integration/jms/client/GroupIDTest.java     |   1 +
 .../jms/client/NewQueueRequestorTest.java       |   1 +
 .../jms/client/RemoteConnectionStressTest.java  |   1 +
 .../jms/client/TopicCleanupTest.java            |   1 +
 .../jms/cluster/BindingsClusterTest.java        |   1 +
 .../jms/cluster/JMSFailoverListenerTest.java    |   1 +
 .../jms/cluster/JMSFailoverTest.java            |   2 +
 .../jms/cluster/JMSReconnectTest.java           |   1 +
 .../jms/cluster/LargeMessageOverBridgeTest.java |   1 +
 .../jms/cluster/MultipleThreadsOpeningTest.java |   1 +
 .../CloseConnectionFactoryOnGCest.java          |   1 +
 .../jms/connection/CloseConnectionOnGCTest.java |   3 +
 .../jms/connection/ExceptionListenerTest.java   |   1 +
 .../integration/jms/consumer/ConsumerTest.java  |   3 +
 .../management/JMSQueueControlUsingJMSTest.java |  42 +++++
 .../management/JMSServerControl2Test.java       |   6 +
 .../server/management/JMSServerControlTest.java |  15 ++
 .../JMSServerControlUsingJMSTest.java           |  36 +++++
 .../jms/server/management/JMSUtil.java          |   1 +
 .../journal/NIOJournalCompactTest.java          |   6 +
 .../journal/ValidateTransactionHealthTest.java  |  10 ++
 .../largemessage/LargeMessageTestBase.java      |   2 +
 .../AcceptorControlUsingCoreTest.java           |   6 +
 .../ActiveMQServerControlUsingCoreTest.java     |  93 +++++++++++
 .../BroadcastGroupControlUsingCoreTest.java     |  10 ++
 .../ClusterConnectionControlUsingCoreTest.java  |  15 ++
 .../management/DivertControlUsingCoreTest.java  |   7 +
 .../management/QueueControlTest.java            |   1 +
 .../management/QueueControlUsingCoreTest.java   |  49 ++++++
 .../integration/mqtt/imported/MQTTTest.java     |   1 +
 .../mqtt/imported/MQTTTestSupport.java          |   3 +
 .../integration/openwire/BasicSecurityTest.java |   1 +
 .../amq/JMSDurableTopicRedeliverTest.java       |   1 +
 .../openwire/amq/JmsAutoAckListenerTest.java    |   1 +
 .../amq/JmsConnectionStartStopTest.java         |   2 +
 .../amq/JmsConsumerResetActiveListenerTest.java |   2 +
 .../amq/JmsCreateConsumerInOnMessageTest.java   |   1 +
 .../JmsDurableQueueWildcardSendReceiveTest.java |   1 +
 .../amq/JmsDurableTopicSendReceiveTest.java     |   1 +
 .../amq/JmsDurableTopicTransactionTest.java     |   1 +
 .../JmsDurableTopicWildcardSendReceiveTest.java |   1 +
 .../openwire/amq/JmsSendReceiveTestSupport.java |   1 +
 .../openwire/amq/JmsTopicRequestReplyTest.java  |   2 +
 .../amq/JmsTopicWildcardSendReceiveTest.java    |   2 +
 .../amq/MessageListenerRedeliveryTest.java      |   1 +
 .../amq/ProducerFlowControlSendFailTest.java    |   1 +
 .../openwire/amq/ProducerFlowControlTest.java   |   2 +
 .../amq/ReconnectWithSameClientIDTest.java      |   1 +
 .../PagingWithFailoverAndCountersTest.java      |   2 +
 .../ra/ActiveMQMessageHandlerTest.java          |   1 +
 .../ra/ActiveMQRAClusteredTestBase.java         |   1 +
 .../integration/ra/ActiveMQRATestBase.java      |   6 +
 .../integration/ra/ResourceAdapterTest.java     |   3 +
 .../tests/integration/remoting/PingTest.java    |   5 +
 .../integration/remoting/ReconnectTest.java     |   4 +
 .../replication/ReplicationTest.java            |  49 ++++++
 .../integration/security/SecurityTest.java      |   6 +
 .../server/AddressFullLoggingTest.java          |   1 +
 .../integration/server/ExpiryRunnerTest.java    |   1 +
 .../server/GracefulShutdownTest.java            |   2 +
 .../server/SuppliedThreadPoolTest.java          |   1 +
 .../integration/spring/ExampleListener.java     |   1 +
 .../spring/SpringIntegrationTest.java           |   1 +
 .../ssl/CoreClientOverTwoWaySSLTest.java        |   1 +
 .../tests/integration/stomp/StompTest.java      |   1 +
 .../stomp/util/AbstractClientStompFrame.java    |   1 +
 .../util/AbstractStompClientConnection.java     |  11 ++
 .../stomp/util/ClientStompFrameV11.java         |   3 +
 .../stomp/util/ClientStompFrameV12.java         |   3 +
 .../stomp/util/StompClientConnectionV10.java    |   2 +
 .../stomp/util/StompClientConnectionV11.java    |   2 +
 .../stomp/util/StompClientConnectionV12.java    |   1 +
 .../stomp/util/StompFrameFactoryV10.java        |   1 +
 .../integration/stomp/v11/StompV11Test.java     |   2 +
 .../integration/stomp/v12/StompV12Test.java     |   2 +
 .../NettyConnectorWithHTTPUpgradeTest.java      |   1 +
 .../tests/integration/xa/BasicXaTest.java       |   1 +
 .../tests/integration/xa/XaTimeoutTest.java     |   1 +
 .../tests/util/NonSerializableFactory.java      |   1 +
 .../artemis/jms/tests/AcknowledgementTest.java  |   1 +
 .../jms/tests/AutoAckMesageListenerTest.java    |   1 +
 .../activemq/artemis/jms/tests/BrowserTest.java |   1 +
 .../artemis/jms/tests/ConnectionClosedTest.java |   1 +
 .../jms/tests/ConnectionFactoryTest.java        |   2 +
 .../artemis/jms/tests/ConnectionTest.java       |   1 +
 .../artemis/jms/tests/DeliveryOrderTest.java    |   1 +
 .../activemq/artemis/jms/tests/JMSTest.java     |   2 +
 .../artemis/jms/tests/MessageConsumerTest.java  |  17 ++
 .../artemis/jms/tests/MessageProducerTest.java  |   2 +
 .../artemis/jms/tests/MiscellaneousTest.java    |   2 +
 .../activemq/artemis/jms/tests/SessionTest.java |   1 +
 .../jms/tests/TemporaryDestinationTest.java     |   1 +
 .../activemq/artemis/jms/tests/TopicTest.java   |   1 +
 .../jms/tests/TransactedSessionTest.java        |   1 +
 .../tests/message/JMSExpirationHeaderTest.java  |   4 +
 .../jms/tests/message/MessageHeaderTest.java    |  62 ++++++++
 .../jms/tests/message/MessageTestBase.java      |   1 +
 .../tests/message/SimpleJMSBytesMessage.java    |  27 ++++
 .../jms/tests/message/SimpleJMSMapMessage.java  |  25 +++
 .../jms/tests/message/SimpleJMSMessage.java     |  45 ++++++
 .../tests/message/SimpleJMSObjectMessage.java   |   2 +
 .../tests/message/SimpleJMSStreamMessage.java   |  24 +++
 .../jms/tests/message/SimpleJMSTextMessage.java |   2 +
 .../jms/tests/selector/SelectorTest.java        |   2 +
 .../jms/tests/tools/container/InVMContext.java  |  34 ++++
 .../container/InVMInitialContextFactory.java    |   1 +
 .../InVMInitialContextFactoryBuilder.java       |   1 +
 .../tests/tools/container/InVMNameParser.java   |   1 +
 .../tests/tools/container/LocalTestServer.java  |  30 ++++
 .../tools/container/NonSerializableFactory.java |   1 +
 .../activemq/artemis/jms/AbstractAdmin.java     |  16 ++
 .../activemq/artemis/jms/ActiveMQAdmin.java     |  16 ++
 .../activemq/artemis/jms/GenericAdmin.java      |  16 ++
 .../jms/conform/connection/ConnectionTest.java  |   1 +
 .../sends/MeasureCommitPerfTest.java            |   1 +
 .../artemis/tests/soak/client/Receiver.java     |   2 +
 .../artemis/tests/soak/client/Sender.java       |   2 +
 .../stress/journal/AddAndRemoveStressTest.java  |   5 +
 .../AllPossibilitiesCompactStressTest.java      |   1 +
 ...ibilitiesCompactWithAddDeleteStressTest.java |   1 +
 .../JournalCleanupCompactStressTest.java        |   7 +
 .../stress/journal/MixupCompactorTestBase.java  |   1 +
 .../stress/paging/PageCursorStressTest.java     |   4 +
 .../tests/stress/remote/PingStressTest.java     |   1 +
 .../jms/bridge/impl/JMSBridgeImplTest.java      |  14 ++
 .../timing/util/TokenBucketLimiterImplTest.java |   1 +
 .../tests/unit/core/asyncio/AIOTestBase.java    |   2 +
 .../client/impl/LargeMessageBufferTest.java     |  24 +++
 .../core/config/impl/ConnectorsServiceTest.java |   1 +
 .../journal/impl/AlignedJournalImplTest.java    |   6 +
 .../core/journal/impl/JournalImplTestBase.java  |   1 +
 .../core/journal/impl/JournalImplTestUnit.java  |   1 +
 .../unit/core/journal/impl/ReclaimerTest.java   |  14 ++
 .../unit/core/journal/impl/TimedBufferTest.java |  14 ++
 .../impl/fakes/FakeSequentialFileFactory.java   |  35 +++++
 .../core/journal/impl/fakes/SimpleEncoding.java |   3 +
 .../impl/OperationContextUnitTest.java          |   6 +
 .../core/postoffice/impl/BindingsImplTest.java  |  34 ++++
 .../unit/core/postoffice/impl/FakeQueue.java    |  20 +++
 .../impl/WildcardAddressManagerUnitTest.java    |   1 +
 .../impl/netty/NettyAcceptorFactoryTest.java    |   5 +
 .../remoting/impl/netty/NettyAcceptorTest.java  |   5 +
 .../impl/netty/NettyConnectionTest.java         |   4 +
 .../remoting/impl/netty/NettyConnectorTest.java |  30 ++++
 .../server/impl/fake/FakeAcceptorFactory.java   |   1 +
 .../unit/core/server/impl/QueueImplTest.java    |   3 +
 .../core/server/impl/fakes/FakeConsumer.java    |   4 +
 .../unit/core/server/impl/fakes/FakeFilter.java |   2 +
 .../core/server/impl/fakes/FakePostOffice.java  |   5 +
 .../server/impl/fakes/FakeQueueFactory.java     |   2 +
 .../jms/client/ActiveMQStreamMessageTest.java   |  29 ++++
 .../artemis/tests/unit/ra/BootstrapContext.java |   9 ++
 .../tests/unit/util/FakePagingManager.java      |  13 ++
 .../artemis/tests/unit/util/InVMContext.java    |  34 ++++
 .../artemis/tests/unit/util/InVMNameParser.java |   1 +
 .../tests/unit/util/InVMNamingContext.java      |  34 ++++
 .../artemis/tests/unit/util/MemorySizeTest.java |   2 +
 .../tests/unit/util/NonSerializableFactory.java |   1 +
 .../ObjectInputStreamWithClassLoaderTest.java   |   1 +
 .../tests/unit/util/SoftValueMapTest.java       |   1 +
 .../artemis/tests/util/SpawnedVMSupport.java    |   1 +
 1541 files changed, 7631 insertions(+), 138 deletions(-)
----------------------------------------------------------------------



Mime
View raw message