You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2015/12/07 19:39:54 UTC
[42/42] activemq-artemis git commit: This closes #255
This closes #255
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/deb84857
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/deb84857
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/deb84857
Branch: refs/heads/master
Commit: deb84857a692630508b30849e4be7c79c02831c3
Parents: fd38ddd 25ae472
Author: Clebert Suconic <cl...@apache.org>
Authored: Mon Dec 7 13:38:35 2015 -0500
Committer: Clebert Suconic <cl...@apache.org>
Committed: Mon Dec 7 13:38:35 2015 -0500
----------------------------------------------------------------------
.../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(-)
----------------------------------------------------------------------