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 <clebertsuco...@apache.org> Authored: Mon Dec 7 13:38:35 2015 -0500 Committer: Clebert Suconic <clebertsuco...@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(-) ----------------------------------------------------------------------
