[prev in list] [next in list] [prev in thread] [next in thread]
List: activemq-commits
Subject: [activemq] branch main updated (8d322df244 -> fc13d61714)
From: mattrpav () apache ! org
Date: 2023-08-30 14:29:40
Message-ID: 169340578049.956170.7474796324504331708 () gitbox2-he-fi ! apache ! org
[Download RAW message or body]
This is an automated email from the ASF dual-hosted git repository.
mattrpav pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/activemq.git
from 8d322df244 [#9292] Update stompjms to 1.27 and new groupId (#1039)
new 699a0b6e7f [AMQ-9239] jakarta.jms - pom.xml, Jenkinsfile and dependency \
changes
new 770032d483 [AMQ-9239] jakarta.jms - activemq-joram-jms-tests conversion
new f022aeac58 [AMQ-9239] jakarta.jms - activemq-client changes
new 39feb6b5c4 [AMQ-9239] jakarta.jms - activemq-client-jakarta relocation and \
removal new e2121de655 [AMQ-9239] jakarta.jms - activemq-amqp changes
new fa7d1347e9 [AMQ-9239] jakarta.jms - activemq-broker changes
new 867254a41c [AMQ-9239] jakarta.jms - activemq-cf changes
new b1de919bf4 [AMQ-9239] jakarta.jms - activemq-console changes
new f1c7b7350f [AMQ-9239] jakarta.jms - activemq-http changes
new ef0b6dd0f2 Fix timeout errors on Jetty shutdown
new 30114aa86d [AMQ-9239] jakarta.jms - activemq-jms-pool, activemq-pool changes
new 976db65c58 [AMQ-9239] jakarta.jms - activemq-kahadb-store changes
new a2f83d4dce [AMQ-9239] jakarta.jms - activemq-karaf-itest, activemq-osgi \
changes
new d83d2f5e18 [AMQ-9239] jakarta.jms - activemq-log4j-appender changes
new 64cbba0417 [AMQ-9239] jakarta.jms - activemq-mqtt changes
new 4faad74272 [AMQ-9239] jakarta.jms - activemq-runtime-config, activemq-shiro \
changes
new 5473ea58e5 [AMQ-9239] jakarta.jms - activemq-ra, activemq-rar changes
new af07efe27d [AMQ-9239] jakarta.jms - activemq-spring changes
new 30127d3a66 [AMQ-9239] jakarta.jms - activemq-stomp changes
new febcd0b485 [AMQ-9239] jakarta.jms - activemq-tooling chnages
new 65267a9a15 [AMQ-9239] jakarta.jms - activemq-unit-tests changes
new 90fbd9098b [AMQ-9239] jakarta.jms - activemq-web-console, activemq-web-demo, \
activemq-web changes new e10d457868 [AMQ-9239] jakarta.jms - assembly changes
new 5243a4451c [AMQ-9239] jakarta.jms - activemq-unit-tests changes
new 0cb5b9bb72 Fix several hanging Http transport tests
new fc13d61714 Merge pull request #996 from mattrpav/AMQ-9239
The 11474 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
Jenkinsfile | 14 +-
activemq-all/pom.xml | 4 +-
activemq-amqp/pom.xml | 7 +-
.../message/AMQPNativeOutboundTransformer.java | 4 +-
.../amqp/message/AMQPRawInboundTransformer.java | 2 +-
.../transport/amqp/message/AmqpMessageSupport.java | 2 +-
.../amqp/message/AutoOutboundTransformer.java | 2 +-
.../transport/amqp/message/InboundTransformer.java | 6 +-
.../amqp/message/JMSMappingInboundTransformer.java | 4 +-
.../message/JMSMappingOutboundTransformer.java | 8 +-
.../transport/amqp/protocol/AmqpConnection.java | 2 +-
.../transport/amqp/protocol/AmqpReceiver.java | 4 +-
.../transport/amqp/protocol/AmqpSession.java | 2 +-
.../activemq/transport/amqp/AMQ4563Test.java | 22 +-
.../activemq/transport/amqp/AmqpAdvisoryTest.java | 14 +-
.../activemq/transport/amqp/AmqpAndMqttTest.java | 14 +-
.../transport/amqp/AmqpAndStompInteropTest.java | 27 +-
.../activemq/transport/amqp/AmqpTestSupport.java | 19 +-
.../transport/amqp/AmqpTransformerTest.java | 18 +-
.../apache/activemq/transport/amqp/IDERunner.java | 2 +-
.../activemq/transport/amqp/JMSClientContext.java | 16 +-
.../JMSClientProducerFlowSendFailIfNoSpace.java | 16 +-
.../amqp/JMSClientRequestResponseTest.java | 22 +-
.../transport/amqp/JMSClientSimpleAuthTest.java | 18 +-
.../activemq/transport/amqp/JMSClientTest.java | 40 +--
.../transport/amqp/JMSClientTestSupport.java | 4 +-
.../transport/amqp/JMSClientTransactionTest.java | 26 +-
.../transport/amqp/JMSConcurrentConsumersTest.java | 16 +-
.../amqp/JMSDurableSubNoLocalChangedTest.java | 16 +-
.../transport/amqp/JMSInteroperabilityTest.java | 20 +-
.../amqp/JMSLargeMessageSendRecvTest.java | 18 +-
.../JMSMaxConnectionsSSLHandshakeFailsTest.java | 2 +-
.../transport/amqp/JMSMessageGroupsTest.java | 14 +-
.../transport/amqp/JMSParallelConnectTest.java | 4 +-
.../transport/amqp/JMSQueueBrowserTest.java | 14 +-
.../amqp/JmsTransactedMessageOrderTest.java | 16 +-
.../transport/amqp/client/AmqpReceiver.java | 2 +-
.../activemq/transport/amqp/client/AmqpSender.java | 2 +-
.../transport/amqp/client/AmqpSession.java | 6 +-
.../transport/amqp/client/AmqpSupport.java | 12 +-
.../amqp/client/AmqpTransactionCoordinator.java | 6 +-
.../amqp/client/sasl/SaslAuthenticator.java | 2 +-
.../amqp/interop/AmqpDescribedTypePayloadTest.java | 14 +-
.../amqp/interop/AmqpScheduledMessageTest.java | 10 +-
.../amqp/interop/AmqpSendReceiveTest.java | 10 +-
...enWireToAmqpConcurrentStoreAndDispatchTest.java | 10 +-
.../message/JMSMappingInboundTransformerTest.java | 58 ++--
.../message/JMSMappingOutboundTransformerTest.java | 2 +-
.../amqp/profile/JmsSendReceiveStressTest.java | 12 +-
.../amqp/profile/QueueBrowserStressTest.java | 10 +-
activemq-broker/pom.xml | 6 +-
.../org/apache/activemq/broker/BrokerService.java | 4 +-
.../apache/activemq/broker/TransactionBroker.java | 2 +-
.../activemq/broker/jmx/DestinationView.java | 8 +-
.../activemq/broker/jmx/DestinationViewMBean.java | 2 +-
.../activemq/broker/jmx/ManagedQueueRegion.java | 2 +-
.../activemq/broker/jmx/ManagedRegionBroker.java | 4 +-
.../broker/jmx/ManagedTempQueueRegion.java | 2 +-
.../broker/jmx/ManagedTempTopicRegion.java | 2 +-
.../activemq/broker/jmx/ManagedTopicRegion.java | 2 +-
.../activemq/broker/jmx/OpenTypeSupport.java | 4 +-
.../org/apache/activemq/broker/jmx/QueueView.java | 2 +-
.../activemq/broker/jmx/SubscriptionView.java | 2 +-
.../activemq/broker/jmx/SubscriptionViewMBean.java | 2 +-
.../activemq/broker/region/AbstractRegion.java | 4 +-
.../broker/region/AbstractSubscription.java | 4 +-
.../activemq/broker/region/BaseDestination.java | 2 +-
.../broker/region/DurableTopicSubscription.java | 4 +-
.../broker/region/MessageReferenceFilter.java | 2 +-
.../broker/region/PrefetchSubscription.java | 2 +-
.../org/apache/activemq/broker/region/Queue.java | 6 +-
.../broker/region/QueueBrowserSubscription.java | 2 +-
.../apache/activemq/broker/region/QueueRegion.java | 2 +-
.../activemq/broker/region/QueueSubscription.java | 2 +-
.../activemq/broker/region/RegionBroker.java | 4 +-
.../activemq/broker/region/Subscription.java | 2 +-
.../activemq/broker/region/TempQueueRegion.java | 2 +-
.../activemq/broker/region/TempTopicRegion.java | 2 +-
.../org/apache/activemq/broker/region/Topic.java | 6 +-
.../apache/activemq/broker/region/TopicRegion.java | 4 +-
.../activemq/broker/region/TopicSubscription.java | 2 +-
.../region/cursors/PrioritizedPendingList.java | 2 +-
.../broker/region/policy/MessageQuery.java | 2 +-
.../QueryBasedSubscriptionRecoveryPolicy.java | 6 +-
.../broker/region/virtual/FilteredDestination.java | 4 +-
.../region/virtual/VirtualTopicInterceptor.java | 2 +-
.../activemq/broker/scheduler/SchedulerBroker.java | 2 +-
.../scheduler/memory/InMemoryJobScheduler.java | 2 +-
.../activemq/broker/util/LoggingBrokerPlugin.java | 2 +-
.../apache/activemq/filter/JAXPXPathEvaluator.java | 6 +-
.../activemq/network/jms/DestinationBridge.java | 14 +-
.../apache/activemq/network/jms/JmsConnector.java | 4 +-
.../activemq/network/jms/JmsMesageConvertor.java | 8 +-
.../apache/activemq/network/jms/QueueBridge.java | 20 +-
.../network/jms/SimpleJmsMessageConvertor.java | 8 +-
.../network/jms/SimpleJmsQueueConnector.java | 18 +-
.../network/jms/SimpleJmsTopicConnector.java | 18 +-
.../apache/activemq/network/jms/TopicBridge.java | 20 +-
.../apache/activemq/plugin/StatisticsBroker.java | 4 +-
.../activemq/security/AuthorizationBroker.java | 4 +-
.../apache/activemq/store/TopicMessageStore.java | 2 +-
.../apache/activemq/store/TopicReferenceStore.java | 2 +-
.../apache/activemq/transaction/Transaction.java | 2 +-
.../apache/activemq/JmsQueueTransactionTest.java | 16 +-
.../apache/activemq/JmsTransactionTestSupport.java | 22 +-
.../apache/activemq/broker/LinkStealingTest.java | 4 +-
.../activemq/broker/OpenwireConnectionTest.java | 2 +-
.../broker/interceptor/MessageInterceptorTest.java | 38 +--
.../broker/view/BrokerDestinationViewTest.java | 12 +-
.../java/org/apache/activemq/bugs/AMQ7085Test.java | 10 +-
.../apache/activemq/test/JmsResourceProvider.java | 36 +-
.../java/org/apache/activemq/test/TestSupport.java | 12 +-
.../osgi/cf/ConnectionFactoryProvider.java | 2 +-
activemq-client-jakarta/pom.xml | 196 +----------
.../org/apache/activemq/jakarta/JakartaTest.java | 86 -----
activemq-client/src/main/grammar/SelectorParser.jj | 2 +-
.../org/apache/activemq/ActiveMQConnection.java | 80 ++---
.../activemq/ActiveMQConnectionConsumer.java | 22 +-
.../apache/activemq/ActiveMQConnectionFactory.java | 20 +-
.../activemq/ActiveMQConnectionMetaData.java | 2 +-
.../java/org/apache/activemq/ActiveMQConsumer.java | 12 +-
.../java/org/apache/activemq/ActiveMQContext.java | 44 +--
.../activemq/ActiveMQMessageAuditNoSync.java | 4 +-
.../apache/activemq/ActiveMQMessageConsumer.java | 26 +-
.../apache/activemq/ActiveMQMessageProducer.java | 22 +-
.../activemq/ActiveMQMessageProducerSupport.java | 88 ++---
.../activemq/ActiveMQMessageTransformation.java | 18 +-
.../java/org/apache/activemq/ActiveMQProducer.java | 24 +-
.../org/apache/activemq/ActiveMQQueueBrowser.java | 14 +-
.../org/apache/activemq/ActiveMQQueueReceiver.java | 16 +-
.../org/apache/activemq/ActiveMQQueueSender.java | 18 +-
.../org/apache/activemq/ActiveMQQueueSession.java | 44 +--
.../java/org/apache/activemq/ActiveMQSession.java | 90 ++---
.../apache/activemq/ActiveMQSessionExecutor.java | 4 +-
.../activemq/ActiveMQSslConnectionFactory.java | 2 +-
.../apache/activemq/ActiveMQTopicPublisher.java | 20 +-
.../org/apache/activemq/ActiveMQTopicSession.java | 42 +--
.../apache/activemq/ActiveMQTopicSubscriber.java | 18 +-
.../org/apache/activemq/ActiveMQXAConnection.java | 30 +-
.../activemq/ActiveMQXAConnectionFactory.java | 16 +-
.../org/apache/activemq/ActiveMQXASession.java | 22 +-
.../activemq/ActiveMQXASslConnectionFactory.java | 16 +-
.../java/org/apache/activemq/AdvisoryConsumer.java | 2 +-
.../apache/activemq/AlreadyClosedException.java | 2 +-
.../java/org/apache/activemq/AsyncCallback.java | 2 +-
.../main/java/org/apache/activemq/BlobMessage.java | 2 +-
.../activemq/ClientInternalExceptionListener.java | 4 +-
.../main/java/org/apache/activemq/Closeable.java | 2 +-
.../apache/activemq/ConfigurationException.java | 2 +-
.../apache/activemq/ConnectionClosedException.java | 2 +-
.../apache/activemq/ConnectionFailedException.java | 2 +-
.../org/apache/activemq/CustomDestination.java | 16 +-
.../activemq/DestinationDoesNotExistException.java | 2 +-
.../org/apache/activemq/EnhancedConnection.java | 6 +-
.../src/main/java/org/apache/activemq/Message.java | 2 +-
.../apache/activemq/MessageAvailableConsumer.java | 2 +-
.../apache/activemq/MessageAvailableListener.java | 2 +-
.../apache/activemq/MessageDispatchChannel.java | 2 +-
.../org/apache/activemq/MessageTransformer.java | 10 +-
.../apache/activemq/MessageTransformerSupport.java | 4 +-
.../org/apache/activemq/NotStartedException.java | 2 +-
.../SimplePriorityMessageDispatchChannel.java | 2 +-
.../org/apache/activemq/TransactionContext.java | 20 +-
.../apache/activemq/advisory/AdvisorySupport.java | 4 +-
.../apache/activemq/advisory/ConsumerEvent.java | 2 +-
.../activemq/advisory/ConsumerEventSource.java | 12 +-
.../activemq/advisory/DestinationSource.java | 12 +-
.../apache/activemq/advisory/ProducerEvent.java | 2 +-
.../activemq/advisory/ProducerEventSource.java | 14 +-
.../apache/activemq/blob/BlobDownloadStrategy.java | 2 +-
.../org/apache/activemq/blob/BlobDownloader.java | 2 +-
.../apache/activemq/blob/BlobUploadStrategy.java | 2 +-
.../org/apache/activemq/blob/BlobUploader.java | 2 +-
.../activemq/blob/DefaultBlobDownloadStrategy.java | 2 +-
.../activemq/blob/DefaultBlobUploadStrategy.java | 2 +-
.../org/apache/activemq/blob/DefaultStrategy.java | 2 +-
.../activemq/blob/FileSystemBlobStrategy.java | 2 +-
.../activemq/broker/scheduler/CronParser.java | 2 +-
.../activemq/command/ActiveMQBlobMessage.java | 2 +-
.../activemq/command/ActiveMQBytesMessage.java | 24 +-
.../activemq/command/ActiveMQDestination.java | 12 +-
.../activemq/command/ActiveMQMapMessage.java | 20 +-
.../apache/activemq/command/ActiveMQMessage.java | 10 +-
.../activemq/command/ActiveMQObjectMessage.java | 22 +-
.../org/apache/activemq/command/ActiveMQQueue.java | 4 +-
.../activemq/command/ActiveMQStreamMessage.java | 24 +-
.../activemq/command/ActiveMQTempDestination.java | 2 +-
.../apache/activemq/command/ActiveMQTempQueue.java | 4 +-
.../apache/activemq/command/ActiveMQTempTopic.java | 4 +-
.../activemq/command/ActiveMQTextMessage.java | 6 +-
.../org/apache/activemq/command/ActiveMQTopic.java | 4 +-
.../DefaultUnresolvedDestinationTransformer.java | 8 +-
.../java/org/apache/activemq/command/Message.java | 2 +-
.../activemq/command/NetworkBridgeFilter.java | 2 +-
.../command/UnresolvedDestinationTransformer.java | 4 +-
.../activemq/filter/ArithmeticExpression.java | 2 +-
.../apache/activemq/filter/BooleanExpression.java | 2 +-
.../activemq/filter/BooleanFunctionCallExpr.java | 2 +-
.../activemq/filter/ComparisonExpression.java | 2 +-
.../apache/activemq/filter/ConstantExpression.java | 2 +-
.../apache/activemq/filter/DestinationFilter.java | 2 +-
.../apache/activemq/filter/DestinationPath.java | 2 +-
.../org/apache/activemq/filter/Expression.java | 2 +-
.../activemq/filter/FunctionCallExpression.java | 2 +-
.../apache/activemq/filter/LogicExpression.java | 2 +-
.../activemq/filter/MultiExpressionEvaluator.java | 2 +-
.../apache/activemq/filter/NoLocalExpression.java | 2 +-
.../apache/activemq/filter/PropertyExpression.java | 2 +-
.../apache/activemq/filter/UnaryExpression.java | 2 +-
.../apache/activemq/filter/XPathExpression.java | 2 +-
.../apache/activemq/filter/XQueryExpression.java | 2 +-
.../activemq/filter/function/FilterFunction.java | 2 +-
.../activemq/filter/function/inListFunction.java | 2 +-
.../activemq/filter/function/makeListFunction.java | 2 +-
.../filter/function/regexMatchFunction.java | 2 +-
.../activemq/filter/function/replaceFunction.java | 2 +-
.../activemq/filter/function/splitFunction.java | 2 +-
.../jndi/ActiveMQInitialContextFactory.java | 6 +-
.../activemq/management/JMSConsumerStatsImpl.java | 2 +-
.../activemq/management/JMSEndpointStatsImpl.java | 8 +-
.../activemq/management/JMSProducerStatsImpl.java | 2 +-
.../activemq/state/ConnectionStateTracker.java | 2 +-
.../org/apache/activemq/util/ConsumerThread.java | 2 +-
.../apache/activemq/util/JMSExceptionSupport.java | 50 +--
.../org/apache/activemq/util/ProducerThread.java | 2 +-
.../activemq/ActiveMQSslConnectionFactoryTest.java | 4 +-
.../apache/activemq/blob/DownloadStrategyTest.java | 2 +-
.../activemq/broker/scheduler/CronParserTest.java | 2 +-
.../activemq/command/ScheduledValuesTest.java | 2 +-
.../openwire/v1/BaseDataStreamMarshallerTest.java | 2 +-
.../openwire/v10/BaseDataStreamMarshallerTest.java | 2 +-
.../apache/activemq/console/CommandContext.java | 2 +-
.../console/command/AbstractAmqCommand.java | 6 +-
.../activemq/console/command/AmqBrowseCommand.java | 4 +-
.../activemq/console/command/ConsumerCommand.java | 4 +-
.../activemq/console/command/ProducerCommand.java | 4 +-
.../console/filter/AmqMessagesQueryFilter.java | 12 +-
.../console/filter/MapTransformFilter.java | 4 +-
.../formatter/CommandShellOutputFormatter.java | 2 +-
.../console/formatter/OutputFormatter.java | 2 +-
.../activemq/console/util/AmqMessagesUtil.java | 4 +-
.../apache/activemq/console/PurgeCommandTest.java | 14 +-
.../apache/activemq/console/QueryCommandTest.java | 2 +-
.../java/org/apache/activemq/simple/Consumer.java | 14 +-
.../java/org/apache/activemq/simple/Producer.java | 14 +-
activemq-http/pom.xml | 8 +-
.../transport/SecureSocketConnectorFactory.java | 30 +-
.../activemq/transport/SocketConnectorFactory.java | 3 +-
.../transport/WebTransportServerSupport.java | 3 +-
.../discovery/http/DiscoveryRegistryServlet.java | 8 +-
.../transport/http/HttpEmbeddedTunnelServlet.java | 2 +-
.../activemq/transport/http/HttpTunnelServlet.java | 30 +-
.../https/Krb5AndCertsSslSocketConnector.java | 4 +-
.../transport/util/HttpTransportUtils.java | 2 +-
.../activemq/transport/ws/WSTransportProxy.java | 6 +-
.../activemq/transport/ws/WSTransportServer.java | 7 +-
.../ws/{jetty9 => jetty11}/MQTTSocket.java | 6 +-
.../ws/{jetty9 => jetty11}/StompSocket.java | 5 +-
.../ws/{jetty9 => jetty11}/WSServlet.java | 28 +-
.../TwoBrokerTopicSendReceiveUsingHttpTest.java | 2 +-
.../java/org/apache/activemq/bugs/AMQ2764Test.java | 16 +-
.../transport/http/HttpClientReconnectTest.java | 12 +-
.../transport/http/HttpJMSMessageTest.java | 10 +-
.../http/HttpJMSMessagesWithCompressionTest.java | 26 +-
.../HttpJmsSendAndReceiveWithCompressionTest.java | 6 +-
.../transport/http/HttpMaxFrameSizeTest.java | 23 +-
.../http/HttpPersistentSendAndReceiveTest.java | 2 +-
.../transport/http/HttpPullConsumerTest.java | 13 +-
.../http/HttpSendCompressedMessagesTest.java | 81 ++---
.../transport/http/HttpTraceTestSupport.java | 11 +-
.../http/HttpTransportConnectTimeoutTest.java | 47 +--
.../transport/util/HttpTransportUtilsTest.java | 2 +-
.../transport/ws/MQTTWSSubProtocolTest.java | 10 +-
.../activemq/transport/ws/MQTTWSTransportTest.java | 10 +-
.../transport/ws/MQTTWSTransportWillTest.java | 10 +-
.../apache/activemq/transport/ws/SocketTest.java | 14 +-
.../transport/ws/StompWSConnectionTimeoutTest.java | 6 +-
.../transport/ws/StompWSSubProtocolTest.java | 13 +-
.../transport/ws/StompWSTransportTest.java | 11 +-
.../activemq/transport/ws/WSTransportTest.java | 11 +-
.../transport/ws/WSTransportTestSupport.java | 2 +-
.../transport/wss/WSSTransportHttpTraceTest.java | 4 +-
.../wss/WSSTransportNeedClientAuthTest.java | 53 ++-
.../activemq/transport/wss/WSSTransportTest.java | 4 +-
.../resources/activemq-https-need-client-auth.xml | 2 +-
.../resources/activemq-https-want-client-auth.xml | 2 +-
.../src/test/resources/activemq-https.xml | 2 +-
activemq-http/src/test/resources/jetty.xml | 2 +-
.../activemq/bugs/amq2764/reconnect-broker1.xml | 2 +-
.../activemq/bugs/amq2764/reconnect-broker2.xml | 2 +-
activemq-http/src/test/resources/spring-http.xml | 2 +-
activemq-http/src/webapp/WEB-INF/web.xml | 9 +-
activemq-jms-pool/pom.xml | 15 +-
.../apache/activemq/jms/pool/ConnectionPool.java | 14 +-
.../activemq/jms/pool/GenericResourceManager.java | 14 +-
.../activemq/jms/pool/JcaConnectionPool.java | 8 +-
.../jms/pool/JcaPooledConnectionFactory.java | 2 +-
.../apache/activemq/jms/pool/PooledConnection.java | 40 +--
.../activemq/jms/pool/PooledConnectionFactory.java | 20 +-
.../activemq/jms/pool/PooledMessageConsumer.java | 8 +-
.../apache/activemq/jms/pool/PooledProducer.java | 16 +-
.../activemq/jms/pool/PooledQueueSender.java | 10 +-
.../apache/activemq/jms/pool/PooledSession.java | 50 +--
.../jms/pool/PooledSessionEventListener.java | 4 +-
.../activemq/jms/pool/PooledTopicPublisher.java | 10 +-
.../apache/activemq/jms/pool/SessionHolder.java | 14 +-
.../apache/activemq/jms/pool/XaConnectionPool.java | 18 +-
.../jms/pool/XaPooledConnectionFactory.java | 10 +-
.../pool/ConnectionExpiryEvictsFromPoolTest.java | 6 +-
.../activemq/jms/pool/ConnectionPoolTest.java | 4 +-
.../activemq/jms/pool/JmsPoolTestSupport.java | 2 +-
.../PooledConnectionFactoryMaximumActiveTest.java | 6 +-
.../jms/pool/PooledConnectionFactoryTest.java | 10 +-
...ectionFactoryWithTemporaryDestinationsTest.java | 10 +-
.../jms/pool/PooledConnectionFailoverTest.java | 12 +-
.../PooledConnectionSecurityExceptionTest.java | 14 +-
.../pool/PooledConnectionSessionCleanupTest.java | 10 +-
.../pool/PooledConnectionTempDestCleanupTest.java | 10 +-
.../jms/pool/PooledConnectionTempQueueTest.java | 20 +-
.../activemq/jms/pool/PooledConnectionTest.java | 10 +-
.../PooledSessionExhaustionBlockTimeoutTest.java | 16 +-
.../jms/pool/PooledSessionExhaustionTest.java | 16 +-
.../pool/PooledSessionNoPublisherCachingTest.java | 10 +-
.../activemq/jms/pool/PooledSessionTest.java | 14 +-
.../jms/pool/PooledTopicPublisherTest.java | 14 +-
.../activemq/jms/pool/XAConnectionPoolTest.java | 46 +--
.../apache/activemq/jms/pool/bugs/AMQ4441Test.java | 2 +-
activemq-kahadb-store/pom.xml | 10 +-
.../activemq/store/kahadb/MessageDatabase.java | 8 +-
.../store/kahadb/scheduler/JobSchedulerImpl.java | 2 +-
.../apache/activemq/store/kahadb/AMQ5626Test.java | 10 +-
.../store/kahadb/ErrorOnFutureSendTest.java | 12 +-
.../activemq/store/kahadb/JournalArchiveTest.java | 10 +-
.../JournalCorruptionEofIndexRecoveryTest.java | 16 +-
.../kahadb/JournalCorruptionExceptionTest.java | 10 +-
.../kahadb/JournalCorruptionIndexRecoveryTest.java | 12 +-
.../store/kahadb/JournalFdRecoveryTest.java | 14 +-
.../kahadb/JournalMetaDataCheckpointTest.java | 10 +-
.../kahadb/KahaDBStoreOpenWireVersionTest.java | 18 +-
.../disk/journal/DataFileAccessorPoolTest.java | 4 +-
.../store/kahadb/scheduler/AMQ7086Test.java | 2 +-
.../karaf/itest/ActiveMQAMQPBrokerFeatureTest.java | 2 +-
.../karaf/itest/ActiveMQClientFactoryTest.java | 2 +-
.../org/apache/activemq/karaf/itest/JMSTester.java | 14 +-
.../org/apache/activemq/util/JmsLogAppender.java | 4 +-
.../activemq/util/JmsLogAppenderSupport.java | 12 +-
.../apache/activemq/util/JndiJmsLogAppender.java | 6 +-
activemq-mqtt/pom.xml | 10 +-
.../transport/mqtt/MQTTProtocolConverter.java | 6 +-
.../activemq/transport/mqtt/MQTTSubscription.java | 2 +-
.../transport/mqtt/MQTTTransportFilter.java | 2 +-
.../activemq/transport/mqtt/MQTTAuthTest.java | 2 +-
.../mqtt/MQTTCompositeQueueRetainedTest.java | 8 +-
.../apache/activemq/transport/mqtt/MQTTTest.java | 22 +-
.../activemq/transport/mqtt/MQTTTestSupport.java | 2 +-
.../mqtt/MQTTVirtualTopicSubscriptionsTest.java | 8 +-
.../activemq/transport/mqtt/PahoMQTTTest.java | 8 +-
.../transport/mqtt/PahoVirtualTopicMQTTTest.java | 4 +-
.../mqtt/util/ResourceLoadingSslContext.java | 2 +-
activemq-osgi/pom.xml | 2 +-
activemq-pool/pom.xml | 10 +-
.../activemq/pool/JcaPooledConnectionFactory.java | 2 +-
.../org/apache/activemq/pool/PooledConnection.java | 2 +-
.../activemq/pool/PooledConnectionFactory.java | 2 +-
.../activemq/pool/XaPooledConnectionFactory.java | 10 +-
.../apache/activemq/pool/ConfigFromPropsTest.java | 2 +-
.../pool/ConnectionFailureEvictsFromPoolTest.java | 10 +-
.../apache/activemq/pool/PooledConsumerTest.java | 16 +-
.../apache/activemq/pool/XAConnectionPoolTest.java | 38 +--
activemq-ra/pom.xml | 4 +-
.../apache/activemq/ra/ActiveMQActivationSpec.java | 12 +-
.../activemq/ra/ActiveMQConnectionFactory.java | 26 +-
.../activemq/ra/ActiveMQConnectionRequestInfo.java | 2 +-
.../activemq/ra/ActiveMQConnectionSupport.java | 2 +-
.../activemq/ra/ActiveMQEndpointActivationKey.java | 2 +-
.../apache/activemq/ra/ActiveMQEndpointWorker.java | 30 +-
.../activemq/ra/ActiveMQManagedConnection.java | 20 +-
.../ra/ActiveMQManagedConnectionFactory.java | 16 +-
.../activemq/ra/ActiveMQResourceAdapter.java | 14 +-
.../apache/activemq/ra/InboundConnectionProxy.java | 32 +-
.../activemq/ra/InboundConnectionProxyFactory.java | 16 +-
.../org/apache/activemq/ra/InboundContext.java | 8 +-
.../activemq/ra/InboundMessageProducerProxy.java | 26 +-
.../apache/activemq/ra/InboundSessionProxy.java | 46 +--
.../apache/activemq/ra/LocalAndXATransaction.java | 6 +-
.../apache/activemq/ra/ManagedConnectionProxy.java | 38 +--
.../apache/activemq/ra/ManagedSessionProxy.java | 52 +--
.../activemq/ra/ManagedTransactionContext.java | 2 +-
.../apache/activemq/ra/MessageActivationSpec.java | 4 +-
.../apache/activemq/ra/MessageEndpointProxy.java | 8 +-
.../apache/activemq/ra/MessageResourceAdapter.java | 6 +-
.../org/apache/activemq/ra/ServerSessionImpl.java | 26 +-
.../apache/activemq/ra/ServerSessionPoolImpl.java | 12 +-
.../activemq/ra/SimpleConnectionManager.java | 14 +-
.../activemq/ra/ActiveMQActivationSpecTest.java | 8 +-
.../activemq/ra/ActiveMQConnectionFactoryTest.java | 6 +-
.../ra/ConnectionEventListenerAdapter.java | 4 +-
.../activemq/ra/ConnectionManagerAdapter.java | 14 +-
.../activemq/ra/FailoverManagedClusterTest.java | 67 +++-
.../activemq/ra/FailoverManagedConnectionTest.java | 2 +-
.../activemq/ra/JmsXAQueueTransactionTest.java | 20 +-
.../ra/JmsXARollback2CxTransactionTest.java | 14 +-
.../test/java/org/apache/activemq/ra/MDBTest.java | 216 ++++++++++--
.../activemq/ra/ManagedConnectionFactoryTest.java | 22 +-
.../apache/activemq/ra/ManagedConnectionTest.java | 22 +-
.../activemq/ra/MessageEndpointProxyTest.java | 10 +-
.../ra/SSLMAnagedConnectionFactoryTest.java | 8 +-
.../test/java/org/apache/activemq/ra/SSLTest.java | 105 +++++-
.../apache/activemq/ra/ServerSessionImplTest.java | 42 +--
.../activemq/ra/UnsubscribeResubscribeTest.java | 16 +-
activemq-rar/pom.xml | 8 +-
.../plugin/DefaultConfigurationProcessor.java | 2 +-
.../apache/activemq/AbstractAuthorizationTest.java | 4 +-
.../apache/activemq/AbstractVirtualDestTest.java | 8 +-
.../org/apache/activemq/AuthenticationTest.java | 4 +-
.../java/org/apache/activemq/PolicyEntryTest.java | 2 +-
.../activemq/java/JavaAuthenticationTest.java | 4 +-
.../apache/activemq/java/JavaPolicyEntryTest.java | 2 +-
.../org/apache/activemq/shiro/ShiroPluginTest.java | 16 +-
activemq-spring/pom.xml | 60 +++-
.../activemq/pool/PooledConnectionFactoryBean.java | 8 +-
.../activemq/security/XBeanAuthorizationEntry.java | 2 +-
.../activemq/security/XBeanAuthorizationMap.java | 2 +-
.../activemq/spring/ActiveMQConnectionFactory.java | 2 +-
.../spring/ActiveMQXAConnectionFactory.java | 2 +-
.../apache/activemq/spring/SpringSslContext.java | 2 +-
.../apache/activemq/xbean/XBeanBrokerService.java | 4 +-
.../src/main/resources/META-INF/spring.schemas | 2 +
.../java/org/apache/activemq/spring/Listener.java | 6 +-
.../org/apache/activemq/spring/ListenerTest.java | 4 +-
.../activemq/spring/ParallelXATransactionTest.java | 18 +-
.../geronimo/ConnectionFactoryFactoryBean.java | 86 +++++
.../geronimo/ConnectionManagerFactoryBean.java | 365 +++++++++++++++++++++
.../geronimo/ConnectionTrackerFactoryBean.java | 58 ++++
.../GeronimoPlatformTransactionManager.java | 171 ++++++++++
.../spring/geronimo/HowlLogFactoryBean.java | 219 +++++++++++++
.../geronimo/TransactionManagerFactoryBean.java | 132 ++++++++
.../apache/activemq/usecases/AMQDeadlockTest3.java | 21 +-
.../usecases/AMQDeadlockTestW4Brokers.java | 14 +-
.../apache/activemq/usecases/AMQFailoverIssue.java | 14 +-
.../src/test/java/org/apache/bugs/AMQ1730Test.java | 18 +-
.../src/test/java/org/apache/bugs/AMQ2754Test.java | 10 +-
.../test/java/org/apache/bugs/LoadBalanceTest.java | 10 +-
.../src/test/resources/spring/spring.xml | 6 +-
activemq-spring/src/test/resources/spring/xa.xml | 17 +-
.../activemq/transport/stomp/FrameTranslator.java | 6 +-
.../transport/stomp/JmsFrameTranslator.java | 2 +-
.../transport/stomp/LegacyFrameTranslator.java | 4 +-
.../transport/stomp/ProtocolConverter.java | 2 +-
.../stomp/StompQueueBrowserSubscription.java | 2 +-
.../transport/stomp/StompSubscription.java | 2 +-
.../transport/stomp/StompTransportFilter.java | 2 +-
.../activemq/transport/stomp/Stomp11Test.java | 10 +-
.../activemq/transport/stomp/Stomp12Test.java | 2 +-
.../transport/stomp/StompAdvisoryTest.java | 16 +-
.../stomp/StompCompositeDestinationTest.java | 12 +-
.../stomp/StompNIOSSLLargeMessageTest.java | 4 +-
.../transport/stomp/StompPrefetchTest.java | 2 +-
.../stomp/StompSubscriptionRemoveTest.java | 8 +-
.../apache/activemq/transport/stomp/StompTest.java | 20 +-
.../activemq/transport/stomp/StompTestSupport.java | 2 +-
.../stomp/StompTimeStampingBrokerPluginTest.java | 10 +-
.../transport/stomp/auto/StompAutoSslAuthTest.java | 2 +-
.../stomp/util/ResourceLoadingSslContext.java | 2 +-
.../java/org/objectweb/jtests/jms/admin/Admin.java | 23 +-
.../objectweb/jtests/jms/admin/AdminFactory.java | 23 +-
.../jms/conform/connection/ConnectionTest.java | 53 +--
.../conform/connection/TopicConnectionTest.java | 45 +--
.../jms/conform/message/MessageBodyTest.java | 33 +-
.../jms/conform/message/MessageDefaultTest.java | 37 ++-
.../jms/conform/message/MessageTypeTest.java | 39 ++-
.../conform/message/headers/MessageHeaderTest.java | 37 ++-
.../message/properties/JMSXPropertyTest.java | 33 +-
.../properties/MessagePropertyConversionTest.java | 105 +++---
.../message/properties/MessagePropertyTest.java | 41 +--
.../jtests/jms/conform/queue/QueueBrowserTest.java | 35 +-
.../jms/conform/queue/TemporaryQueueTest.java | 37 ++-
.../jms/conform/selector/SelectorSyntaxTest.java | 29 +-
.../jtests/jms/conform/selector/SelectorTest.java | 29 +-
.../jms/conform/session/QueueSessionTest.java | 61 ++--
.../jtests/jms/conform/session/SessionTest.java | 75 +++--
.../jms/conform/session/TopicSessionTest.java | 63 ++--
.../jms/conform/session/UnifiedSessionTest.java | 103 +++---
.../jms/conform/topic/TemporaryTopicTest.java | 35 +-
.../jtests/jms/framework/JMSTestCase.java | 29 +-
.../jtests/jms/framework/PTPTestCase.java | 37 ++-
.../jtests/jms/framework/PubSubTestCase.java | 37 ++-
.../objectweb/jtests/jms/framework/TestConfig.java | 23 +-
.../jtests/jms/framework/UnifiedTestCase.java | 51 +--
.../junit/AbstractActiveMQClientResource.java | 18 +-
.../junit/AbstractActiveMQConsumerResource.java | 14 +-
.../junit/AbstractActiveMQProducerResource.java | 14 +-
.../junit/ActiveMQDynamicQueueSenderResource.java | 14 +-
.../ActiveMQDynamicTopicPublisherResource.java | 14 +-
.../junit/ActiveMQQueueSenderResource.java | 2 +-
.../ActiveMQTopicDurableSubscriberResource.java | 4 +-
.../junit/ActiveMQTopicPublisherResource.java | 2 +-
.../activemq/junit/EmbeddedActiveMQBroker.java | 20 +-
.../java/org/apache/activemq/tool/JMSMemtest.java | 16 +-
.../java/org/apache/activemq/tool/MemConsumer.java | 18 +-
.../org/apache/activemq/tool/MemMessageIdList.java | 6 +-
.../java/org/apache/activemq/tool/MemProducer.java | 16 +-
.../apache/activemq/tool/AbstractJmsClient.java | 2 +-
.../activemq/tool/AbstractJmsClientSystem.java | 6 +-
.../activemq/tool/AbstractJmsMeasurableClient.java | 2 +-
.../apache/activemq/tool/JmsConsumerClient.java | 14 +-
.../apache/activemq/tool/JmsConsumerSystem.java | 2 +-
.../apache/activemq/tool/JmsProducerClient.java | 12 +-
.../apache/activemq/tool/JmsProducerSystem.java | 2 +-
.../apache/activemq/tool/spi/ActiveMQPojoSPI.java | 2 +-
.../tool/spi/ClassLoaderSPIConnectionFactory.java | 2 +-
.../tool/spi/ReflectionSPIConnectionFactory.java | 2 +-
.../activemq/tool/spi/SPIConnectionFactory.java | 2 +-
.../activemq/tool/AbstractJmsClientTest.java | 6 +-
.../activemq/tool/JmsProducerClientTest.java | 4 +-
activemq-unit-tests/pom.xml | 9 +-
.../activemq/ActiveMQConnectionFactoryTest.java | 6 +-
.../activemq/ActiveMQSslConnectionFactoryTest.java | 8 +-
.../activemq/ActiveMQXAConnectionFactoryTest.java | 28 +-
.../ActiveMQXAConnectionTxInterruptTest.java | 12 +-
.../apache/activemq/BrokerDurableRejectedTest.java | 10 +-
.../org/apache/activemq/ClientTestSupport.java | 2 +-
.../org/apache/activemq/ConnectionCleanupTest.java | 4 +-
...ConnectionCloseMultipleTimesConcurrentTest.java | 6 +-
.../activemq/ConnectionCloseMultipleTimesTest.java | 6 +-
.../activemq/ConsumerReceiveWithTimeoutTest.java | 16 +-
...eConsumerButDontStartConnectionWarningTest.java | 2 +-
.../EmbeddedBrokerAndConnectionTestSupport.java | 2 +-
.../apache/activemq/EmbeddedBrokerTestSupport.java | 6 +-
.../ExclusiveConsumerStartupDestinationTest.java | 14 +-
.../org/apache/activemq/ExclusiveConsumerTest.java | 14 +-
.../activemq/ExpiredAckAsyncConsumerTest.java | 24 +-
.../java/org/apache/activemq/ExpiryHogTest.java | 6 +-
.../java/org/apache/activemq/JMSConsumerTest.java | 22 +-
.../activemq/JMSDurableTopicRedeliverTest.java | 6 +-
.../apache/activemq/JMSExclusiveConsumerTest.java | 10 +-
.../org/apache/activemq/JMSIndividualAckTest.java | 16 +-
.../java/org/apache/activemq/JMSMessageTest.java | 26 +-
.../java/org/apache/activemq/JMSUsecaseTest.java | 16 +-
.../org/apache/activemq/JMSXAConsumerTest.java | 4 +-
.../apache/activemq/JmsAutoAckListenerTest.java | 16 +-
.../java/org/apache/activemq/JmsAutoAckTest.java | 16 +-
.../java/org/apache/activemq/JmsBenchmark.java | 20 +-
.../apache/activemq/JmsClientAckListenerTest.java | 18 +-
.../java/org/apache/activemq/JmsClientAckTest.java | 14 +-
.../activemq/JmsConnectionStartStopTest.java | 16 +-
.../JmsConsumerResetActiveListenerTest.java | 20 +-
.../activemq/JmsCreateConsumerInOnMessageTest.java | 14 +-
.../JmsDurableQueueWildcardSendReceiveTest.java | 2 +-
.../activemq/JmsDurableTopicSendReceiveTest.java | 16 +-
.../activemq/JmsDurableTopicTransactionTest.java | 2 +-
.../JmsDurableTopicWildcardSendReceiveTest.java | 2 +-
.../activemq/JmsMessageConsumerClosedTest.java | 14 +-
.../apache/activemq/JmsMessageConsumerTest.java | 14 +-
.../activemq/JmsMessageProcuderClosedTest.java | 12 +-
.../activemq/JmsMultipleBrokersTestSupport.java | 24 +-
.../activemq/JmsMultipleClientsTestSupport.java | 22 +-
.../activemq/JmsQueueBrowserExpirationTest.java | 16 +-
.../org/apache/activemq/JmsQueueBrowserTest.java | 12 +-
.../activemq/JmsQueueCompositeSendReceiveTest.java | 10 +-
.../org/apache/activemq/JmsQueueSelectorTest.java | 4 +-
.../JmsQueueTopicCompositeSendReceiveTest.java | 8 +-
.../activemq/JmsQueueWildcardSendReceiveTest.java | 16 +-
.../org/apache/activemq/JmsRedeliveredTest.java | 22 +-
.../apache/activemq/JmsRollbackRedeliveryTest.java | 16 +-
.../apache/activemq/JmsSendReceiveTestSupport.java | 20 +-
.../JmsSendReceiveWithMessageExpirationTest.java | 18 +-
.../activemq/JmsSendWithAsyncCallbackTest.java | 16 +-
.../org/apache/activemq/JmsSessionRecoverTest.java | 20 +-
.../apache/activemq/JmsTempDestinationTest.java | 24 +-
.../java/org/apache/activemq/JmsTestSupport.java | 14 +-
.../activemq/JmsTopicCompositeSendReceiveTest.java | 8 +-
.../org/apache/activemq/JmsTopicRedeliverTest.java | 18 +-
.../apache/activemq/JmsTopicRequestReplyTest.java | 22 +-
.../org/apache/activemq/JmsTopicSelectorTest.java | 20 +-
.../JmsTopicSendReceiveSubscriberTest.java | 8 +-
.../apache/activemq/JmsTopicSendReceiveTest.java | 12 +-
.../JmsTopicSendReceiveWithTwoConnectionsTest.java | 12 +-
.../activemq/JmsTopicSendSameMessageTest.java | 2 +-
.../activemq/JmsTopicWildcardSendReceiveTest.java | 16 +-
.../apache/activemq/LargeMessageTestSupport.java | 22 +-
.../java/org/apache/activemq/LoadTestBurnIn.java | 20 +-
.../org/apache/activemq/MessageEvictionTest.java | 18 +-
.../activemq/MessageListenerRedeliveryTest.java | 22 +-
.../apache/activemq/MessageTransformationTest.java | 18 +-
.../activemq/OnePrefetchAsyncConsumerTest.java | 24 +-
.../java/org/apache/activemq/OptimizedAckTest.java | 20 +-
.../activemq/PerDestinationStoreLimitTest.java | 14 +-
.../activemq/ProducerFlowControlSendFailTest.java | 16 +-
.../apache/activemq/ProducerFlowControlTest.java | 16 +-
.../apache/activemq/QueueConsumerPriorityTest.java | 14 +-
.../activemq/ReconnectWithSameClientIDTest.java | 10 +-
.../org/apache/activemq/RedeliveryPolicyTest.java | 18 +-
.../org/apache/activemq/RemoveDestinationTest.java | 16 +-
.../org/apache/activemq/SpringTestSupport.java | 2 +-
.../test/java/org/apache/activemq/TestSupport.java | 10 +-
.../java/org/apache/activemq/TimeStampTest.java | 14 +-
.../TopicSubscriptionCountBeforeFullTest.java | 14 +-
.../apache/activemq/TransactionContextTest.java | 2 +-
.../java/org/apache/activemq/XAConsumerTest.java | 22 +-
.../apache/activemq/ZeroPrefetchConsumerTest.java | 18 +-
.../advisory/AdvisoryTempDestinationTests.java | 22 +-
.../apache/activemq/advisory/AdvisoryTests.java | 24 +-
.../activemq/advisory/ConsumerListenerTest.java | 14 +-
.../activemq/advisory/DestinationListenerTest.java | 6 +-
.../activemq/advisory/ProducerListenerTest.java | 10 +-
.../activemq/advisory/TempDestDeleteTest.java | 16 +-
.../apache/activemq/advisory/TempDestLoadTest.java | 12 +-
.../activemq/advisory/TempQueueMemoryTest.java | 18 +-
.../apache/activemq/blob/FilesystemBlobTest.java | 10 +-
.../org/apache/activemq/broker/AMQ4351Test.java | 4 +-
.../activemq/broker/BrokerRedeliveryTest.java | 8 +-
.../apache/activemq/broker/BrokerServiceTest.java | 3 +
.../org/apache/activemq/broker/BrokerTest.java | 2 +-
.../apache/activemq/broker/BrokerTestSupport.java | 4 +-
.../activemq/broker/DoubleSubscriptionTest.java | 4 +-
.../broker/DurablePersistentFalseRestartTest.java | 18 +-
.../test/java/org/apache/activemq/broker/Main.java | 4 +-
.../activemq/broker/MessageExpirationTest.java | 2 +-
.../activemq/broker/NioQueueSubscriptionTest.java | 6 +-
.../activemq/broker/QueueMbeanRestartTest.java | 4 +-
.../broker/ReconnectWithJMXEnabledTest.java | 14 +-
.../apache/activemq/broker/RecoveryBrokerTest.java | 2 +-
.../activemq/broker/RedeliveryRecoveryTest.java | 18 +-
.../activemq/broker/RedeliveryRestartTest.java | 18 +-
.../broker/RedeliveryRestartWithExceptionTest.java | 18 +-
.../org/apache/activemq/broker/SpringTest.java | 2 +-
.../org/apache/activemq/broker/StubBroker.java | 2 +-
.../activemq/broker/XARecoveryBrokerTest.java | 2 +-
.../broker/advisory/AdvisoryDuringStartTest.java | 6 +-
.../activemq/broker/advisory/AdvisoryJmxTest.java | 10 +-
.../broker/advisory/AdvisoryNetworkBridgeTest.java | 6 +-
.../ft/DbRestartJDBCQueueMasterSlaveTest.java | 14 +-
.../activemq/broker/ft/DbRestartJDBCQueueTest.java | 14 +-
.../broker/ft/QueueMasterSlaveTestSupport.java | 8 +-
.../activemq/broker/jmx/ConcurrentMoveTest.java | 10 +-
.../activemq/broker/jmx/HealthViewMBeanTest.java | 12 +-
.../broker/jmx/JMXRemoveDurableSubscriberTest.java | 2 +-
.../jmx/JMXRemoveOfflineDurableSubscriberTest.java | 2 +-
.../broker/jmx/JmxConsumerRemovalTest.java | 14 +-
.../broker/jmx/JmxOpPageInOnMemoryLimitTest.java | 2 +-
.../activemq/broker/jmx/Log4JConfigTest.java | 2 +-
.../broker/jmx/MBeanOperationTimeoutTest.java | 10 +-
.../org/apache/activemq/broker/jmx/MBeanTest.java | 24 +-
.../activemq/broker/jmx/PurgeLargeMessageTest.java | 14 +-
.../org/apache/activemq/broker/jmx/PurgeTest.java | 12 +-
.../broker/jmx/SelectiveMBeanRegistrationTest.java | 8 +-
.../security/MessageAuthenticationTest.java | 16 +-
.../broker/policy/AbortSlowAckConsumer0Test.java | 8 +-
.../broker/policy/AbortSlowAckConsumer1Test.java | 2 +-
.../broker/policy/AbortSlowAckConsumer2Test.java | 2 +-
.../broker/policy/AbortSlowConsumer0Test.java | 12 +-
.../broker/policy/AbortSlowConsumer1Test.java | 6 +-
.../broker/policy/AbortSlowConsumer2Test.java | 4 +-
.../broker/policy/AbortSlowConsumerBase.java | 4 +-
.../policy/ClientIdFilterDispatchPolicyTest.java | 2 +-
.../broker/policy/DeadLetterExpiryTest.java | 8 +-
.../activemq/broker/policy/DeadLetterTest.java | 6 +-
.../broker/policy/DeadLetterTestSupport.java | 24 +-
.../policy/DiscardingDeadLetterPolicyTest.java | 2 +-
.../broker/policy/IndividualDeadLetterTest.java | 12 +-
.../policy/IndividualDeadLetterViaXmlTest.java | 2 +-
.../broker/policy/MaxDestinationsPolicyTest.java | 26 +-
.../policy/MessageListenerDeadLetterTest.java | 10 +-
.../broker/policy/NoConsumerDeadLetterTest.java | 16 +-
.../policy/PerDurableConsumerDeadLetterTest.java | 2 +-
.../policy/RoundRobinDispatchPolicyTest.java | 8 +-
.../activemq/broker/policy/SecureDLQTest.java | 2 +-
.../policy/SendDuplicateFromStoreToDLQTest.java | 14 +-
.../broker/policy/SimpleDispatchPolicyTest.java | 2 +-
.../policy/StrictOrderDispatchPolicyTest.java | 2 +-
.../broker/region/DestinationGCStressTest.java | 10 +-
.../activemq/broker/region/DestinationGCTest.java | 12 +-
.../region/QueueDuplicatesFromStoreTest.java | 2 +-
.../activemq/broker/region/QueuePurgeTest.java | 18 +-
.../region/QueueResendDuringShutdownTest.java | 16 +-
.../region/SubscriptionAddRemoveQueueTest.java | 2 +-
.../UniquePropertyMessageEvictionStrategyTest.java | 8 +-
.../cursors/AbstractPendingMessageCursorTest.java | 14 +-
.../region/cursors/AbstractStoreCursorNpeTest.java | 14 +-
.../broker/region/cursors/CursorDurableTest.java | 14 +-
.../region/cursors/CursorQueueStoreTest.java | 12 +-
.../broker/region/cursors/CursorSupport.java | 20 +-
.../cursors/KahaDBPendingMessageCursorTest.java | 16 +-
.../cursors/MemoryPendingMessageCursorTest.java | 4 +-
.../broker/region/cursors/NegativeQueueTest.java | 22 +-
.../region/cursors/PrioritizedPendingListTest.java | 2 +-
.../region/cursors/StoreBasedCursorTest.java | 14 +-
.../broker/region/group/MessageGroupTest.java | 12 +-
.../broker/scheduler/JmsCronSchedulerTest.java | 16 +-
.../broker/scheduler/JmsSchedulerTest.java | 16 +-
.../scheduler/JobSchedulerBrokerShutdownTest.java | 6 +-
.../scheduler/JobSchedulerJmxManagementTests.java | 8 +-
.../scheduler/JobSchedulerManagementTest.java | 16 +-
...chedulerRedliveryPluginDLQStoreCleanupTest.java | 20 +-
.../broker/scheduler/JobSchedulerTestSupport.java | 6 +-
.../broker/scheduler/JobSchedulerTxTest.java | 14 +-
.../scheduler/KahaDBSchedulerIndexRebuildTest.java | 10 +-
.../KahaDBSchedulerMissingJournalLogsTest.java | 10 +-
.../scheduler/LostScheduledMessagesTest.java | 14 +-
.../scheduler/ReduceMemoryFootprintTest.java | 12 +-
.../broker/scheduler/SchedulerDBVersionTest.java | 16 +-
.../broker/scheduler/SchedulerRepeatTest.java | 12 +-
.../apache/activemq/broker/store/LoadTester.java | 12 +-
.../activemq/broker/util/PluginBrokerTest.java | 4 +-
.../broker/util/TimeStampingBrokerPluginTest.java | 14 +-
.../broker/util/TraceBrokerPathPluginTest.java | 12 +-
.../activemq/broker/virtual/AMQ7088Test.java | 8 +-
...CompositeDestinationSendWhenNotMatchedTest.java | 14 +-
.../broker/virtual/CompositeQueueTest.java | 16 +-
.../virtual/CompositeTopicMemoryUsageTest.java | 8 +-
.../broker/virtual/CompositeTopicTest.java | 2 +-
.../virtual/CustomVirtualTopicInterceptorTest.java | 10 +-
...ualTopicInterceptorWithLeadingWildcardTest.java | 10 +-
.../DestinationInterceptorDurableSubTest.java | 8 +-
.../MessageDestinationVirtualTopicTest.java | 4 +-
.../MirroredQueueCorrectMemoryUsageTest.java | 10 +-
.../activemq/broker/virtual/MirroredQueueTest.java | 12 +-
.../MirroredQueueUsingVirtualTopicQueueTest.java | 2 +-
.../MultipleCompositeToPhysicalQueueTest.java | 18 +-
.../broker/virtual/SimpleMessageListener.java | 8 +-
.../broker/virtual/VirtualDestPerfTest.java | 8 +-
.../VirtualTopicConcurrentSendDeleteTest.java | 8 +-
.../broker/virtual/VirtualTopicDLQTest.java | 18 +-
.../VirtualTopicDestinationMapAccessTest.java | 8 +-
.../VirtualTopicDisconnectSelectorTest.java | 18 +-
.../broker/virtual/VirtualTopicFanoutPerfTest.java | 8 +-
.../VirtualTopicFlowControlDiscardTest.java | 8 +-
.../broker/virtual/VirtualTopicPubSubTest.java | 12 +-
.../broker/virtual/VirtualTopicSelectorTest.java | 10 +-
.../broker/virtual/VirtualTopicWildcardTest.java | 14 +-
.../virtual/VirtualTopicsAndDurableSubsTest.java | 8 +-
.../java/org/apache/activemq/bugs/AMQ1282.java | 10 +-
.../java/org/apache/activemq/bugs/AMQ1687Test.java | 10 +-
.../java/org/apache/activemq/bugs/AMQ1853Test.java | 18 +-
.../java/org/apache/activemq/bugs/AMQ1893Test.java | 22 +-
.../java/org/apache/activemq/bugs/AMQ1917Test.java | 18 +-
.../java/org/apache/activemq/bugs/AMQ1936Test.java | 20 +-
.../java/org/apache/activemq/bugs/AMQ2021Test.java | 18 +-
.../java/org/apache/activemq/bugs/AMQ2084Test.java | 30 +-
.../java/org/apache/activemq/bugs/AMQ2103Test.java | 10 +-
.../java/org/apache/activemq/bugs/AMQ2149Test.java | 16 +-
.../java/org/apache/activemq/bugs/AMQ2171Test.java | 4 +-
.../java/org/apache/activemq/bugs/AMQ2174Test.java | 12 +-
.../java/org/apache/activemq/bugs/AMQ2200Test.java | 10 +-
.../java/org/apache/activemq/bugs/AMQ2213Test.java | 20 +-
.../java/org/apache/activemq/bugs/AMQ2314Test.java | 14 +-
.../java/org/apache/activemq/bugs/AMQ2356Test.java | 16 +-
.../java/org/apache/activemq/bugs/AMQ2364Test.java | 14 +-
.../java/org/apache/activemq/bugs/AMQ2383Test.java | 14 +-
.../java/org/apache/activemq/bugs/AMQ2401Test.java | 16 +-
.../java/org/apache/activemq/bugs/AMQ2413Test.java | 20 +-
.../java/org/apache/activemq/bugs/AMQ2439Test.java | 10 +-
.../java/org/apache/activemq/bugs/AMQ2489Test.java | 22 +-
.../java/org/apache/activemq/bugs/AMQ2512Test.java | 22 +-
.../java/org/apache/activemq/bugs/AMQ2513Test.java | 8 +-
.../java/org/apache/activemq/bugs/AMQ2528Test.java | 8 +-
.../java/org/apache/activemq/bugs/AMQ2571Test.java | 14 +-
.../java/org/apache/activemq/bugs/AMQ2580Test.java | 18 +-
.../activemq/bugs/AMQ2584ConcurrentDlqTest.java | 14 +-
.../java/org/apache/activemq/bugs/AMQ2584Test.java | 12 +-
.../java/org/apache/activemq/bugs/AMQ2585Test.java | 10 +-
.../java/org/apache/activemq/bugs/AMQ2616Test.java | 10 +-
.../java/org/apache/activemq/bugs/AMQ2645Test.java | 20 +-
.../java/org/apache/activemq/bugs/AMQ2736Test.java | 6 +-
.../java/org/apache/activemq/bugs/AMQ2751Test.java | 16 +-
.../java/org/apache/activemq/bugs/AMQ2801Test.java | 18 +-
.../java/org/apache/activemq/bugs/AMQ2832Test.java | 18 +-
.../java/org/apache/activemq/bugs/AMQ2870Test.java | 12 +-
.../java/org/apache/activemq/bugs/AMQ2902Test.java | 6 +-
.../java/org/apache/activemq/bugs/AMQ2982Test.java | 18 +-
.../java/org/apache/activemq/bugs/AMQ2983Test.java | 16 +-
.../java/org/apache/activemq/bugs/AMQ3120Test.java | 2 +-
.../java/org/apache/activemq/bugs/AMQ3140Test.java | 16 +-
.../java/org/apache/activemq/bugs/AMQ3141Test.java | 14 +-
.../java/org/apache/activemq/bugs/AMQ3145Test.java | 18 +-
.../java/org/apache/activemq/bugs/AMQ3157Test.java | 8 +-
.../java/org/apache/activemq/bugs/AMQ3166Test.java | 14 +-
.../java/org/apache/activemq/bugs/AMQ3167Test.java | 16 +-
.../java/org/apache/activemq/bugs/AMQ3274Test.java | 18 +-
.../java/org/apache/activemq/bugs/AMQ3324Test.java | 16 +-
.../java/org/apache/activemq/bugs/AMQ3352Test.java | 6 +-
.../java/org/apache/activemq/bugs/AMQ3405Test.java | 24 +-
.../java/org/apache/activemq/bugs/AMQ3436Test.java | 12 +-
.../java/org/apache/activemq/bugs/AMQ3445Test.java | 10 +-
.../java/org/apache/activemq/bugs/AMQ3454Test.java | 8 +-
.../java/org/apache/activemq/bugs/AMQ3465Test.java | 20 +-
.../java/org/apache/activemq/bugs/AMQ3529Test.java | 12 +-
.../org/apache/activemq/bugs/AMQ3529v2Test.java | 10 +-
.../java/org/apache/activemq/bugs/AMQ3537Test.java | 2 +-
.../java/org/apache/activemq/bugs/AMQ3567Test.java | 18 +-
.../java/org/apache/activemq/bugs/AMQ3674Test.java | 10 +-
.../java/org/apache/activemq/bugs/AMQ3675Test.java | 10 +-
.../java/org/apache/activemq/bugs/AMQ3678Test.java | 14 +-
.../java/org/apache/activemq/bugs/AMQ3732Test.java | 12 +-
.../java/org/apache/activemq/bugs/AMQ3779Test.java | 8 +-
.../java/org/apache/activemq/bugs/AMQ3879Test.java | 12 +-
.../java/org/apache/activemq/bugs/AMQ3903Test.java | 20 +-
.../java/org/apache/activemq/bugs/AMQ3932Test.java | 10 +-
.../java/org/apache/activemq/bugs/AMQ3934Test.java | 12 +-
.../java/org/apache/activemq/bugs/AMQ3961Test.java | 22 +-
.../java/org/apache/activemq/bugs/AMQ3992Test.java | 10 +-
.../java/org/apache/activemq/bugs/AMQ4062Test.java | 20 +-
.../java/org/apache/activemq/bugs/AMQ4083Test.java | 16 +-
.../java/org/apache/activemq/bugs/AMQ4092Test.java | 20 +-
.../java/org/apache/activemq/bugs/AMQ4116Test.java | 12 +-
.../java/org/apache/activemq/bugs/AMQ4147Test.java | 4 +-
.../java/org/apache/activemq/bugs/AMQ4157Test.java | 14 +-
.../java/org/apache/activemq/bugs/AMQ4212Test.java | 16 +-
.../java/org/apache/activemq/bugs/AMQ4213Test.java | 6 +-
.../java/org/apache/activemq/bugs/AMQ4221Test.java | 16 +-
.../java/org/apache/activemq/bugs/AMQ4222Test.java | 18 +-
.../java/org/apache/activemq/bugs/AMQ4323Test.java | 8 +-
.../java/org/apache/activemq/bugs/AMQ4356Test.java | 12 +-
.../java/org/apache/activemq/bugs/AMQ4361Test.java | 10 +-
.../java/org/apache/activemq/bugs/AMQ4368Test.java | 14 +-
.../java/org/apache/activemq/bugs/AMQ4407Test.java | 8 +-
.../java/org/apache/activemq/bugs/AMQ4413Test.java | 18 +-
.../java/org/apache/activemq/bugs/AMQ4469Test.java | 4 +-
.../java/org/apache/activemq/bugs/AMQ4472Test.java | 16 +-
.../java/org/apache/activemq/bugs/AMQ4475Test.java | 14 +-
.../apache/activemq/bugs/AMQ4485LowLimitTest.java | 18 +-
...kOfXBrokersWithNDestsFanoutTransactionTest.java | 14 +-
.../java/org/apache/activemq/bugs/AMQ4485Test.java | 10 +-
.../java/org/apache/activemq/bugs/AMQ4487Test.java | 12 +-
.../java/org/apache/activemq/bugs/AMQ4504Test.java | 10 +-
.../java/org/apache/activemq/bugs/AMQ4513Test.java | 8 +-
.../java/org/apache/activemq/bugs/AMQ4517Test.java | 16 +-
.../java/org/apache/activemq/bugs/AMQ4518Test.java | 16 +-
.../java/org/apache/activemq/bugs/AMQ4530Test.java | 12 +-
.../java/org/apache/activemq/bugs/AMQ4554Test.java | 12 +-
.../java/org/apache/activemq/bugs/AMQ4582Test.java | 4 +-
.../java/org/apache/activemq/bugs/AMQ4595Test.java | 14 +-
.../java/org/apache/activemq/bugs/AMQ4607Test.java | 4 +-
.../java/org/apache/activemq/bugs/AMQ4636Test.java | 20 +-
.../java/org/apache/activemq/bugs/AMQ4656Test.java | 12 +-
.../java/org/apache/activemq/bugs/AMQ4671Test.java | 6 +-
.../java/org/apache/activemq/bugs/AMQ4814Test.java | 8 +-
.../java/org/apache/activemq/bugs/AMQ4853Test.java | 14 +-
.../java/org/apache/activemq/bugs/AMQ4887Test.java | 16 +-
.../java/org/apache/activemq/bugs/AMQ4893Test.java | 2 +-
.../java/org/apache/activemq/bugs/AMQ4899Test.java | 20 +-
.../java/org/apache/activemq/bugs/AMQ4930Test.java | 10 +-
.../java/org/apache/activemq/bugs/AMQ4950Test.java | 6 +-
.../java/org/apache/activemq/bugs/AMQ4952Test.java | 12 +-
.../java/org/apache/activemq/bugs/AMQ5035Test.java | 10 +-
.../java/org/apache/activemq/bugs/AMQ5136Test.java | 14 +-
.../java/org/apache/activemq/bugs/AMQ5212Test.java | 8 +-
.../activemq/bugs/AMQ5266SingleDestTest.java | 14 +-
.../activemq/bugs/AMQ5266StarvedConsumerTest.java | 14 +-
.../java/org/apache/activemq/bugs/AMQ5266Test.java | 14 +-
.../java/org/apache/activemq/bugs/AMQ5274Test.java | 12 +-
.../java/org/apache/activemq/bugs/AMQ5381Test.java | 12 +-
.../java/org/apache/activemq/bugs/AMQ5421Test.java | 16 +-
.../java/org/apache/activemq/bugs/AMQ5426Test.java | 22 +-
.../java/org/apache/activemq/bugs/AMQ5450Test.java | 8 +-
.../java/org/apache/activemq/bugs/AMQ5486Test.java | 4 +-
.../java/org/apache/activemq/bugs/AMQ5567Test.java | 4 +-
.../java/org/apache/activemq/bugs/AMQ5712Test.java | 18 +-
.../java/org/apache/activemq/bugs/AMQ5814Test.java | 12 +-
.../java/org/apache/activemq/bugs/AMQ5822Test.java | 10 +-
.../java/org/apache/activemq/bugs/AMQ5844Test.java | 16 +-
.../activemq/bugs/AMQ5863CompositePublishTest.java | 6 +-
.../java/org/apache/activemq/bugs/AMQ5893Test.java | 16 +-
.../java/org/apache/activemq/bugs/AMQ5914Test.java | 12 +-
.../java/org/apache/activemq/bugs/AMQ5921Test.java | 12 +-
.../java/org/apache/activemq/bugs/AMQ6000Test.java | 10 +-
.../java/org/apache/activemq/bugs/AMQ6059Test.java | 18 +-
.../java/org/apache/activemq/bugs/AMQ6094Test.java | 12 +-
.../java/org/apache/activemq/bugs/AMQ6117Test.java | 14 +-
.../java/org/apache/activemq/bugs/AMQ6122Test.java | 10 +-
.../java/org/apache/activemq/bugs/AMQ6125Test.java | 12 +-
.../java/org/apache/activemq/bugs/AMQ6131Test.java | 14 +-
.../bugs/AMQ6133PersistJMSRedeliveryTest.java | 20 +-
.../java/org/apache/activemq/bugs/AMQ6194Test.java | 10 +-
.../java/org/apache/activemq/bugs/AMQ6240Test.java | 8 +-
.../java/org/apache/activemq/bugs/AMQ6244Test.java | 12 +-
.../java/org/apache/activemq/bugs/AMQ6254Test.java | 12 +-
.../java/org/apache/activemq/bugs/AMQ6264Test.java | 14 +-
.../java/org/apache/activemq/bugs/AMQ6293Test.java | 12 +-
.../java/org/apache/activemq/bugs/AMQ6387Test.java | 20 +-
.../java/org/apache/activemq/bugs/AMQ6432Test.java | 14 +-
.../java/org/apache/activemq/bugs/AMQ6459Test.java | 14 +-
.../java/org/apache/activemq/bugs/AMQ6463Test.java | 10 +-
.../java/org/apache/activemq/bugs/AMQ6522Test.java | 12 +-
.../java/org/apache/activemq/bugs/AMQ6579Test.java | 12 +-
.../java/org/apache/activemq/bugs/AMQ6815Test.java | 12 +-
.../java/org/apache/activemq/bugs/AMQ7002Test.java | 2 +-
.../java/org/apache/activemq/bugs/AMQ7067Test.java | 2 +-
.../java/org/apache/activemq/bugs/AMQ7077Test.java | 2 +-
.../java/org/apache/activemq/bugs/AMQ7118Test.java | 2 +-
.../java/org/apache/activemq/bugs/AMQ7185Test.java | 2 +-
.../java/org/apache/activemq/bugs/AMQ7270Test.java | 2 +-
.../bugs/ActiveMQSlowConsumerManualTest.java | 18 +-
.../activemq/bugs/ConnectionPerMessageTest.java | 14 +-
.../org/apache/activemq/bugs/CraigsBugTest.java | 8 +-
.../bugs/CursorMemoryHighWaterMarkTest.java | 12 +-
.../org/apache/activemq/bugs/DoubleExpireTest.java | 10 +-
.../activemq/bugs/DuplicateFromStoreTest.java | 22 +-
.../apache/activemq/bugs/DurableConsumerTest.java | 34 +-
.../activemq/bugs/JMSDurableTopicNoLocalTest.java | 16 +-
.../activemq/bugs/JMSQueueBrowserPriorityTest.java | 16 +-
.../bugs/JmsDurableTopicSlowReceiveTest.java | 18 +-
.../org/apache/activemq/bugs/JmsTimeoutTest.java | 14 +-
.../activemq/bugs/MKahaDBTxRecoveryTest.java | 6 +-
.../activemq/bugs/MKahaDBTxVirtualTopicTest.java | 18 +-
.../activemq/bugs/MemoryUsageBlockResumeTest.java | 14 +-
.../activemq/bugs/MemoryUsageBrokerTest.java | 2 +-
.../activemq/bugs/MemoryUsageCleanupTest.java | 12 +-
.../activemq/bugs/MessageExpirationReaperTest.java | 2 +-
.../activemq/bugs/MessageExpiryClientSideTest.java | 18 +-
.../bugs/MessageExpiryTimeDifferenceTest.java | 14 +-
.../org/apache/activemq/bugs/MessageSender.java | 8 +-
.../apache/activemq/bugs/MissingDataFileTest.java | 14 +-
.../OptimizeAcknowledgeWithExpiredMsgsTest.java | 22 +-
.../apache/activemq/bugs/OutOfOrderTestCase.java | 18 +-
.../org/apache/activemq/bugs/PfcTimeoutTest.java | 10 +-
.../activemq/bugs/QueueWorkerPrefetchTest.java | 20 +-
.../bugs/RawRollbackSharedConsumerTests.java | 16 +-
.../org/apache/activemq/bugs/RawRollbackTests.java | 16 +-
.../activemq/bugs/RedeliveryPluginHeaderTest.java | 16 +-
.../org/apache/activemq/bugs/SlowConsumerTest.java | 12 +-
.../activemq/bugs/TempQueueDeleteOnCloseTest.java | 10 +-
.../bugs/TempStorageBlockedBrokerTest.java | 16 +-
.../activemq/bugs/TempStorageConfigBrokerTest.java | 16 +-
.../activemq/bugs/TempStoreDataCleanupTest.java | 12 +-
.../TransactedStoreUsageSuspendResumeTest.java | 18 +-
.../bugs/TransactionNotStartedErrorTest.java | 16 +-
.../activemq/bugs/TrapMessageInJDBCStoreTest.java | 16 +-
.../activemq/bugs/VMTransportClosureTest.java | 4 +-
.../activemq/bugs/VerifySteadyEnqueueRate.java | 2 +-
.../activemq/bugs/amq1095/ActiveMQTestCase.java | 12 +-
.../activemq/bugs/amq1095/MessageSelectorTest.java | 12 +-
.../activemq/bugs/embedded/EmbeddedActiveMQ.java | 12 +-
.../activemq/command/ActiveMQBytesMessageTest.java | 8 +-
.../ActiveMQConcurrentDecompressionTest.java | 14 +-
.../activemq/command/ActiveMQDestinationTest.java | 10 +-
.../activemq/command/ActiveMQMapMessageTest.java | 8 +-
.../activemq/command/ActiveMQMessageTest.java | 10 +-
.../command/ActiveMQObjectMessageTest.java | 6 +-
.../command/ActiveMQStreamMessageTest.java | 10 +-
.../activemq/command/ActiveMQTextMessageTest.java | 6 +-
.../activemq/command/MessageCompressionTest.java | 10 +-
.../activemq/config/BrokerPropertiesTest.java | 2 +-
.../org/apache/activemq/config/ConfigTest.java | 10 +-
.../config/ConfigUsingDestinationOptions.java | 8 +-
.../activemq/console/command/PurgeCommandTest.java | 20 +-
.../apache/activemq/demo/DefaultQueueSender.java | 14 +-
.../org/apache/activemq/demo/SimpleConsumer.java | 16 +-
.../org/apache/activemq/demo/SimpleProducer.java | 14 +-
.../apache/activemq/demo/SimpleQueueReceiver.java | 18 +-
.../apache/activemq/demo/SimpleQueueSender.java | 16 +-
.../activemq/jms2/ActiveMQJMS2AckModesTest.java | 12 +-
.../activemq/jms2/ActiveMQJMS2ConnectionTest.java | 4 +-
.../activemq/jms2/ActiveMQJMS2ContextTest.java | 32 +-
.../jms2/ActiveMQJMS2MessageListenerTest.java | 16 +-
.../activemq/jms2/ActiveMQJMS2MessageTest.java | 16 +-
.../jms2/ActiveMQJMS2MessageTypesTest.java | 34 +-
.../activemq/jms2/ActiveMQJMS2ProducerTest.java | 16 +-
.../apache/activemq/jms2/ActiveMQJMS2TestBase.java | 6 +-
.../activemq/jms2/ActiveMQJMS2TestSupport.java | 32 +-
.../java/org/apache/activemq/jms2/MessageData.java | 8 +-
.../java/org/apache/activemq/jmx/DLQRetryTest.java | 14 +-
.../apache/activemq/jmx/OpenTypeSupportTest.java | 12 +-
.../apache/activemq/jmx/TotalMessageCountTest.java | 16 +-
.../org/apache/activemq/jndi/JNDITestSupport.java | 6 +-
.../activemq/jndi/XAConnectionFactoryTest.java | 2 +-
.../activemq/jndi/XASslConnectionFactoryTest.java | 2 +-
.../apache/activemq/joramtests/ActiveMQAdmin.java | 2 +-
.../java/org/apache/activemq/load/LoadClient.java | 18 +-
.../org/apache/activemq/load/LoadController.java | 6 +-
.../java/org/apache/activemq/load/LoadTest.java | 12 +-
.../apache/activemq/network/BaseNetworkTest.java | 4 +-
.../BrokerNetworkWithStuckMessagesTest.java | 12 +-
.../CheckDuplicateMessagesOnDuplexTest.java | 14 +-
.../CompositeConsumerNetworkBridgeTest.java | 8 +-
.../network/CompressionOverNetworkTest.java | 18 +-
.../activemq/network/CustomBridgeFactoryTest.java | 13 +-
.../network/DemandForwardingBridgeTest.java | 2 +-
.../apache/activemq/network/DrainBridgeTest.java | 10 +-
.../activemq/network/DuplexNetworkMBeanTest.java | 8 +-
.../apache/activemq/network/DuplexNetworkTest.java | 4 +-
.../activemq/network/DuplexStartNpeTest.java | 10 +-
.../DurableFiveBrokerNetworkBridgeTest.java | 6 +-
.../network/DurableSyncNetworkBridgeTest.java | 8 +-
.../network/DynamicNetworkTestSupport.java | 8 +-
...callyIncludedDestinationsDuplexNetworkTest.java | 4 +-
.../network/FailoverStaticNetworkTest.java | 12 +-
.../network/ForceDurableNetworkBridgeTest.java | 6 +-
.../activemq/network/ForwardingBridgeTest.java | 2 +-
.../network/MQTTNetworkOfBrokersFailoverTest.java | 14 +-
.../activemq/network/NetworkBrokerDetachTest.java | 12 +-
.../activemq/network/NetworkConnectionsTest.java | 2 +-
.../network/NetworkDurableRecreationTest.java | 8 +-
.../activemq/network/NetworkFailoverTest.java | 22 +-
.../apache/activemq/network/NetworkLoadTest.java | 18 +-
.../activemq/network/NetworkReconnectTest.java | 14 +-
.../network/NetworkRemoteUserPasswordTest.java | 14 +-
.../network/NetworkRemovesSubscriptionsTest.java | 12 +-
.../activemq/network/NetworkRestartTest.java | 2 +-
.../apache/activemq/network/SimpleNetworkTest.java | 20 +-
.../network/UserIDBrokerPopulateFalseTest.java | 2 +-
.../network/UserIDBrokerPopulateMixedTest.java | 2 +-
.../apache/activemq/network/UserIDBrokerTest.java | 14 +-
.../network/VirtualConsumerDemandTest.java | 10 +-
.../jms/QueueBridgeStandaloneReconnectTest.java | 16 +-
.../activemq/network/jms/QueueBridgeTest.java | 24 +-
.../jms/QueueOutboundBridgeReconnectTest.java | 16 +-
.../network/jms/TopicBridgeSpringTest.java | 24 +-
.../jms/TopicBridgeStandaloneReconnectTest.java | 16 +-
.../jms/TopicOutboundBridgeReconnectTest.java | 16 +-
.../apache/activemq/perf/ConnectionChurnTest.java | 6 +-
.../activemq/perf/InactiveDurableTopicTest.java | 26 +-
.../apache/activemq/perf/InactiveQueueTest.java | 18 +-
.../apache/activemq/perf/MemoryAllocationTest.java | 18 +-
.../apache/activemq/perf/NetworkedSyncTest.java | 26 +-
.../activemq/perf/NumberOfDestinationsTest.java | 14 +-
.../org/apache/activemq/perf/PerfConsumer.java | 18 +-
.../org/apache/activemq/perf/PerfProducer.java | 14 +-
.../perf/SimpleDurableTopicNetworkTest.java | 8 +-
.../apache/activemq/perf/SimpleNetworkTest.java | 6 +-
.../perf/SimpleNonPersistentQueueNetworkTest.java | 10 +-
.../perf/SimpleNonPersistentQueueTest.java | 8 +-
.../perf/SimpleNonPersistentTopicTest.java | 8 +-
.../org/apache/activemq/perf/SimpleQueueTest.java | 8 +-
.../org/apache/activemq/perf/SimpleTopicTest.java | 10 +-
.../org/apache/activemq/perf/SlowConsumer.java | 8 +-
.../activemq/perf/SlowConsumerTopicTest.java | 8 +-
.../perf/SlowDurableConsumerTopicTest.java | 6 +-
.../perf/TemporaryTopicMemoryAllocationTest.java | 6 +-
.../plugin/BrokerStatisticsPluginTest.java | 16 +-
...ceiveTwoConnectionsWithSenderUsingPoolTest.java | 2 +-
.../org/apache/activemq/proxy/AMQ4889Test.java | 8 +-
.../apache/activemq/proxy/ProxyConnectorTest.java | 2 +-
.../apache/activemq/proxy/ProxyFailoverTest.java | 4 +-
.../java/org/apache/activemq/security/CRLTest.java | 2 +-
.../security/CachedLDAPSecurityLegacyTest.java | 2 +-
.../java/org/apache/activemq/security/DoSTest.java | 4 +-
.../security/JaasAuthenticationBrokerTest.java | 2 +-
.../apache/activemq/security/JaasNetworkTest.java | 10 +-
.../activemq/security/LDAPAuthenticationTest.java | 16 +-
.../apache/activemq/security/LDAPSecurityTest.java | 16 +-
.../apache/activemq/security/SecurityJMXTest.java | 8 +-
.../activemq/security/SecurityTestSupport.java | 12 +-
.../security/SimpleAnonymousPluginTest.java | 4 +-
.../SimpleAuthenticationPluginNoUsersTest.java | 4 +-
.../security/SimpleAuthenticationPluginTest.java | 14 +-
.../security/SimpleSecurityBrokerSystemTest.java | 4 +-
...BeanSecurityWithGuestNoCredentialsOnlyTest.java | 12 +-
.../security/XBeanSecurityWithGuestTest.java | 12 +-
.../activemq/selector/SelectorParserTest.java | 2 +-
.../org/apache/activemq/selector/SelectorTest.java | 6 +-
.../selector/UnknownHandlingSelectorTest.java | 4 +-
.../org/apache/activemq/spring/ConsumerBean.java | 4 +-
.../org/apache/activemq/spring/SpringConsumer.java | 16 +-
.../org/apache/activemq/spring/SpringProducer.java | 10 +-
.../apache/activemq/spring/SpringTestSupport.java | 4 +-
.../AbstractInflightMessageSizeTest.java | 28 +-
...DurableSubscriptionInflightMessageSizeTest.java | 6 +-
.../QueueSubscriptionInflightMessageSizeTest.java | 6 +-
.../TopicSubscriptionInflightMessageSizeTest.java | 6 +-
.../store/AbstractMessageStoreSizeStatTest.java | 4 +-
.../store/AbstractStoreStatTestSupport.java | 28 +-
.../store/AbstractVmConcurrentDispatchTest.java | 26 +-
.../apache/activemq/store/MessagePriorityTest.java | 20 +-
.../org/apache/activemq/store/StoreOrderTest.java | 12 +-
.../activemq/store/StorePerDestinationTest.java | 10 +-
.../store/jdbc/JDBCCleanupLimitedPoolTest.java | 4 +-
.../store/jdbc/JDBCCommitExceptionTest.java | 16 +-
.../activemq/store/jdbc/JDBCConcurrentDLQTest.java | 10 +-
.../jdbc/JDBCIOExceptionHandlerMockeryTest.java | 2 +
.../store/jdbc/JDBCIOExceptionHandlerTest.java | 2 +-
.../store/jdbc/JDBCMessagePriorityTest.java | 16 +-
.../JDBCPersistenceAdapterExpiredMessageTest.java | 8 +-
.../store/jdbc/JDBCStoreAutoCommitTest.java | 8 +-
.../store/jdbc/JDBCTablePrefixAssignedTest.java | 6 +-
.../apache/activemq/store/jdbc/JDBCTestMemory.java | 10 +-
.../store/jdbc/JDBCXACommitExceptionTest.java | 16 +-
.../jdbc/JmsTransactionCommitFailureTest.java | 2 +-
.../store/jdbc/LeaseDatabaseLockerTest.java | 2 +
.../activemq/store/jdbc/XACompletionTest.java | 32 +-
.../kahadb/AbstractMultiKahaDBDeletionTest.java | 2 +-
.../kahadb/KahaDBDurableMessageRecoveryTest.java | 10 +-
.../store/kahadb/KahaDBFastEnqueueTest.java | 14 +-
.../store/kahadb/KahaDBIndexLocationTest.java | 10 +-
.../kahadb/KahaDBStoreRecoveryExpiryTest.java | 12 +-
.../apache/activemq/store/kahadb/KahaDBTest.java | 10 +-
.../activemq/store/kahadb/KahaDBVersionTest.java | 16 +-
.../store/kahadb/MKahaDBIndexLocationTest.java | 8 +-
.../store/kahadb/MKahaDBStoreLimitTest.java | 12 +-
.../store/kahadb/MultiKahaDBQueueDeletionTest.java | 6 +-
.../store/kahadb/MultiKahaDBTopicDeletionTest.java | 8 +-
.../activemq/store/kahadb/NoSpaceIOTest.java | 12 +-
.../store/kahadb/SubscriptionRecoveryTest.java | 16 +-
.../store/kahadb/perf/KahaBulkLoadingTest.java | 12 +-
.../memory/MemoryMessageStoreSizeStatTest.java | 2 +-
.../activemq/test/JmsSendReceiveTestSupport.java | 20 +-
.../activemq/test/JmsTopicSendReceiveTest.java | 12 +-
...SendReceiveWithEmbeddedBrokerAndUserIDTest.java | 4 +-
...ceiveWithTwoConnectionsAndByteSelectorTest.java | 6 +-
.../JmsTopicSendReceiveWithTwoConnectionsTest.java | 10 +-
.../test/TemporaryDestinationToFromNameTest.java | 6 +-
.../test/message/NestedMapAndListPropertyTest.java | 4 +-
.../test/message/NestedMapMessageTest.java | 6 +-
.../test/retroactive/DummyMessageQuery.java | 2 +-
.../RetroactiveConsumerBrokerRestartedTest.java | 6 +-
...merTestWithLastImagePolicyWithWildcardTest.java | 8 +-
...ctiveConsumerTestWithSimpleMessageListTest.java | 14 +-
.../RetroactiveConsumerWithMessageQueryTest.java | 12 +-
.../rollback/CloseRollbackRedeliveryQueueTest.java | 14 +-
.../DelegatingTransactionalMessageListener.java | 14 +-
.../RollbacksWhileConsumingLargeQueueTest.java | 16 +-
.../transport/MaxFrameSizeEnabledTest.java | 16 +-
.../RestrictedThreadPoolInactivityTimeoutTest.java | 2 +-
.../transport/SoWriteTimeoutClientTest.java | 6 +-
.../activemq/transport/SoWriteTimeoutTest.java | 10 +-
.../activemq/transport/TopicClusterTest.java | 20 +-
.../transport/auto/AutoTransportConfigureTest.java | 10 +-
.../auto/AutoTransportConnectionsTest.java | 4 +-
.../discovery/DiscoveryTransportBrokerTest.java | 2 +-
.../discovery/DiscoveryTransportNoBrokerTest.java | 4 +-
.../transport/discovery/DiscoveryUriTest.java | 2 +-
.../activemq/transport/failover/AMQ1925Test.java | 20 +-
.../failover/ConnectionHangOnStartupTest.java | 2 +-
.../transport/failover/FailoverBackupLeakTest.java | 8 +-
.../transport/failover/FailoverClusterTest.java | 8 +-
.../failover/FailoverClusterTestSupport.java | 10 +-
.../FailoverConsumerOutstandingCommitTest.java | 20 +-
.../failover/FailoverConsumerUnconsumedTest.java | 16 +-
.../transport/failover/FailoverDuplicateTest.java | 18 +-
.../FailoverDurableSubTransactionTest.java | 6 +-
.../failover/FailoverPrefetchZeroTest.java | 14 +-
...rReadInactivityBlockWriteTimeoutClientTest.java | 8 +-
.../failover/FailoverStateTrackingTest.java | 6 +-
.../transport/failover/FailoverTimeoutTest.java | 12 +-
.../failover/FailoverTransactionTest.java | 22 +-
.../failover/FailoverTransportBrokerTest.java | 2 +-
.../transport/failover/FailoverTxSlowAckTest.java | 20 +-
.../transport/failover/FailoverUpdateURIsTest.java | 12 +-
.../failover/FailoverXATransactionTest.java | 14 +-
.../failover/InitalReconnectDelayTest.java | 12 +-
.../activemq/transport/failover/ReconnectTest.java | 10 +-
.../transport/failover/SlowConnectionTest.java | 2 +-
.../activemq/transport/fanout/FanoutTest.java | 10 +-
.../fanout/FanoutTransportBrokerTest.java | 2 +-
.../transport/nio/NIOAsyncSendWithPFCTest.java | 2 +-
.../transport/nio/NIOMaxFrameSizeCleanupTest.java | 8 +-
.../nio/NIOPersistentSendAndReceiveTest.java | 2 +-
.../activemq/transport/nio/NIOSSLBasicTest.java | 14 +-
.../transport/nio/NIOSSLConcurrencyTest.java | 18 +-
.../activemq/transport/nio/NIOSSLLoadTest.java | 6 +-
.../transport/nio/NIOSSLWindowSizeTest.java | 12 +-
.../activemq/transport/peer/PeerTransportTest.java | 16 +-
.../transport/tcp/SslContextBrokerServiceTest.java | 2 +-
.../tcp/SslContextNBrokerServiceTest.java | 2 +-
.../transport/tcp/TcpTransportBindTest.java | 6 +-
...TransportConnectorInvalidSocketOptionsTest.java | 2 +-
.../activemq/transport/tcp/TransportUriTest.java | 4 +-
.../activemq/transport/udp/UdpTestSupport.java | 2 +-
.../transport/udp/UpdTransportBindTest.java | 4 +-
.../transport/vm/VMTransportBrokerNameTest.java | 2 +-
.../vm/VMTransportEmbeddedBrokerTest.java | 2 +-
.../transport/vm/VMTransportWaitForTest.java | 2 +-
.../transport/vm/VmTransportNetworkBrokerTest.java | 4 +-
.../usage/CompositeMessageCursorUsageTest.java | 8 +-
.../activemq/usage/JobSchedulerStoreUsageTest.java | 8 +-
.../org/apache/activemq/usage/StoreUsageTest.java | 6 +-
.../org/apache/activemq/usecases/AMQ2927Test.java | 2 +-
.../org/apache/activemq/usecases/AMQ6366Test.java | 2 +-
.../org/apache/activemq/usecases/AMQ6446Test.java | 2 +-
.../org/apache/activemq/usecases/AMQ6477Test.java | 10 +-
.../activemq/usecases/AMQStackOverFlowTest.java | 8 +-
...ctorWildcardIncludedDestinationTestSupport.java | 2 +-
.../ActiveDurableSubscriptionBrowseExpireTest.java | 8 +-
.../usecases/AdvisoryTopicCleanUpTest.java | 2 +-
.../usecases/AdvisoryTopicDeletionTest.java | 12 +-
.../activemq/usecases/AdvisoryViaNetworkTest.java | 2 +-
.../usecases/BacklogNetworkCrossTalkTest.java | 2 +-
.../BatchedMessagePriorityConsumerTest.java | 8 +-
.../BrokerQueueNetworkWithDisconnectTest.java | 6 +-
.../apache/activemq/usecases/BrowseDLQTest.java | 2 +-
.../activemq/usecases/BrowseOverNetworkTest.java | 6 +-
.../activemq/usecases/ChangeSentMessageTest.java | 12 +-
.../usecases/ChangeSessionDeliveryModeTest.java | 16 +-
.../activemq/usecases/ClientRebalanceTest.java | 12 +-
.../activemq/usecases/CompositeConsumeTest.java | 4 +-
.../activemq/usecases/CompositePublishTest.java | 14 +-
.../ConcurrentDestinationCreationTest.java | 10 +-
.../ConcurrentProducerDurableConsumerTest.java | 26 +-
.../ConcurrentProducerQueueConsumerTest.java | 22 +-
.../usecases/ConsumeQueuePrefetchTest.java | 4 +-
.../usecases/ConsumeTopicPrefetchTest.java | 8 +-
.../ConsumeUncompressedCompressedMessageTest.java | 12 +-
.../usecases/CreateLotsOfTemporaryQueuesTest.java | 4 +-
.../CreateTemporaryQueueBeforeStartTest.java | 12 +-
.../usecases/DiscriminatingConsumerLoadTest.java | 14 +-
.../usecases/DispatchMultipleConsumersTest.java | 14 +-
.../activemq/usecases/DuplexAdvisoryRaceTest.java | 16 +-
.../DurableConsumerCloseAndReconnectTcpTest.java | 4 +-
.../DurableConsumerCloseAndReconnectTest.java | 20 +-
.../activemq/usecases/DurableRedeliveryTest.java | 18 +-
.../activemq/usecases/DurableSubCacheTest.java | 12 +-
.../usecases/DurableSubDelayedUnsubscribeTest.java | 14 +-
.../usecases/DurableSubInBrokerNetworkTest.java | 10 +-
...essConcurrentCommitActivateNoDuplicateTest.java | 12 +-
.../DurableSubProcessMultiRestartTest.java | 14 +-
.../activemq/usecases/DurableSubProcessTest.java | 2 +-
.../usecases/DurableSubProcessWithRestartTest.java | 14 +-
.../usecases/DurableSubSelectorDelayTest.java | 14 +-
.../DurableSubSelectorDelayWithRestartTest.java | 14 +-
...flineSelectorConcurrentConsumeIndexUseTest.java | 12 +-
.../DurableSubsOfflineSelectorIndexUseTest.java | 12 +-
.../DurableSubscriberNonPersistentMessageTest.java | 22 +-
...DurableSubscriberWithNetworkDisconnectTest.java | 18 +-
.../DurableSubscriberWithNetworkRestartTest.java | 12 +-
.../DurableSubscriptionActivationTest.java | 4 +-
.../usecases/DurableSubscriptionHangTestCase.java | 18 +-
.../usecases/DurableSubscriptionOffline1Test.java | 10 +-
.../usecases/DurableSubscriptionOffline2Test.java | 10 +-
.../usecases/DurableSubscriptionOffline3Test.java | 12 +-
.../usecases/DurableSubscriptionOffline4Test.java | 10 +-
...DurableSubscriptionOfflineBrowseRemoveTest.java | 8 +-
.../usecases/DurableSubscriptionOfflineTest.java | 14 +-
.../DurableSubscriptionOfflineTestBase.java | 10 +-
.../DurableSubscriptionReactivationTest.java | 12 +-
.../DurableSubscriptionRemoveOfflineTest.java | 8 +-
.../usecases/DurableSubscriptionSelectorTest.java | 12 +-
.../usecases/DurableSubscriptionTestSupport.java | 58 ++--
.../DurableSubscriptionUnsubscribeTest.java | 2 +-
.../usecases/DurableSubscriptionUpdatesTest.java | 16 +-
.../DurableSubscriptionWithNoLocalTest.java | 20 +-
.../activemq/usecases/DurableUnsubscribeTest.java | 6 +-
.../activemq/usecases/EmptyTransactionTest.java | 12 +-
.../activemq/usecases/ExceptionListenerTest.java | 10 +-
.../activemq/usecases/ExpiredMessagesTest.java | 2 +-
.../ExpiredMessagesWithNoConsumerTest.java | 18 +-
.../usecases/JDBCDurableSubscriptionTest.java | 12 +-
.../JMXRemoveQueueThenSendIgnoredTest.java | 20 +-
.../activemq/usecases/JdbcDurableSubDupTest.java | 20 +-
.../usecases/LargeQueueSparseDeleteTest.java | 8 +-
.../apache/activemq/usecases/MemoryLimitTest.java | 12 +-
.../activemq/usecases/MessageGroupCloseTest.java | 4 +-
.../activemq/usecases/MessageGroupDelayedTest.java | 12 +-
.../usecases/MessageGroupLateArrivalsTest.java | 12 +-
.../usecases/MessageGroupNewConsumerTest.java | 16 +-
.../MessageGroupReconnectDistributionTest.java | 16 +-
.../activemq/usecases/MessageReroutingTest.java | 4 +-
.../usecases/MultiBrokersMultiClientsTest.java | 4 +-
.../MulticastDiscoveryOnFaultyNetworkTest.java | 6 +-
.../NetworkBridgeProducerFlowControlTest.java | 6 +-
.../NewConsumerCreatesDestinationTest.java | 4 +-
.../usecases/NoDuplicateOnTopicNetworkTest.java | 18 +-
.../NonBlockingConsumerRedeliveryTest.java | 18 +-
.../usecases/ObjectMessageNotSerializableTest.java | 8 +-
.../activemq/usecases/ObjectSerializationTest.java | 14 +-
.../OfflineDurableSubscriberTimeoutTest.java | 6 +-
.../usecases/PriorityRedeliveryOrderTest.java | 12 +-
.../usecases/ProducerConsumerTestSupport.java | 10 +-
...ishOnQueueConsumedMessageInTransactionTest.java | 18 +-
...PublishOnTemporaryQueueConsumedMessageTest.java | 2 +-
.../PublishOnTopicConsumedMessageTest.java | 8 +-
.../activemq/usecases/QueueBrowsingLimitTest.java | 10 +-
.../activemq/usecases/QueueBrowsingTest.java | 14 +-
.../activemq/usecases/QueueDuplicatesTest.java | 20 +-
.../usecases/QueueMemoryFullMultiBrokersTest.java | 2 +-
.../QueueOrderSingleTransactedConsumerTest.java | 12 +-
.../activemq/usecases/QueueRepeaterTest.java | 18 +-
.../QueueZeroPrefetchLazyDispatchPriorityTest.java | 16 +-
.../activemq/usecases/ReliableReconnectTest.java | 20 +-
.../RequestReplyNoAdvisoryNetworkTest.java | 8 +-
...equestReplyTempDestRemovalAdvisoryRaceTest.java | 20 +-
...RequestReplyToTopicViaThreeNetworkHopsTest.java | 18 +-
...ctorAwareVTThatDropsMessagesWhenNoConsumer.java | 18 +-
...eBrokerVirtualDestinationsWithWildcardTest.java | 2 +-
.../activemq/usecases/StartAndStopBrokerTest.java | 2 +-
...entAndBrokerDoesNotLeaveThreadsRunningTest.java | 12 +-
.../activemq/usecases/StaticNetworkTest.java | 2 +-
.../SubscribeClosePublishThenConsumeTest.java | 16 +-
.../usecases/TempTopicProducerFlowControlTest.java | 4 +-
...BrokerConnectionDuplexExcludedDestinations.java | 18 +-
.../org/apache/activemq/usecases/TestSupport.java | 10 +-
.../usecases/ThreeBrokerQueueNetworkTest.java | 4 +-
...rokerTempDestDemandSubscriptionCleanupTest.java | 18 +-
.../usecases/ThreeBrokerTempQueueNetworkTest.java | 6 +-
.../usecases/ThreeBrokerTopicNetworkTest.java | 6 +-
.../ThreeBrokerVirtualTopicNetworkTest.java | 4 +-
.../usecases/TopicBridgeSelectorConduitOnOff.java | 2 +-
.../usecases/TopicDurableConnectStatsTest.java | 18 +-
.../TopicProducerDurableSubFlowControlTest.java | 12 +-
.../usecases/TopicProducerFlowControlTest.java | 12 +-
.../usecases/TopicProducerToSubFileCursorTest.java | 12 +-
.../activemq/usecases/TopicRedeliverTest.java | 22 +-
.../activemq/usecases/TopicReplicationTest.java | 4 +-
.../TopicSubscriptionSlowConsumerTest.java | 10 +-
.../TopicSubscriptionZeroPrefetchTest.java | 14 +-
.../usecases/TransactionRollbackOrderTest.java | 18 +-
.../apache/activemq/usecases/TransactionTest.java | 18 +-
.../usecases/TransientQueueRedeliverTest.java | 2 +-
.../TwoBrokerDurableForwardStaticRestartTest.java | 8 +-
...erMessageNotSentToRemoteWhenNoConsumerTest.java | 4 +-
.../usecases/TwoBrokerMulticastQueueTest.java | 16 +-
.../usecases/TwoBrokerNetworkLoadBalanceTest.java | 4 +-
.../TwoBrokerQueueClientsReconnectTest.java | 10 +-
.../usecases/TwoBrokerTempQueueAdvisoryTest.java | 16 +-
.../usecases/TwoBrokerTopicSendReceiveTest.java | 4 +-
...TopicSendReceiveUsingJavaConfigurationTest.java | 2 +-
.../TwoBrokerTopicSendReceiveUsingTcpTest.java | 2 +-
...okerVirtualDestDinamicallyIncludedDestTest.java | 4 +-
.../TwoBrokerVirtualTopicForwardingTest.java | 2 +-
...kerVirtualTopicSelectorAwareForwardingTest.java | 6 +-
...lticastDiscoveryBrokerTopicSendReceiveTest.java | 2 +-
.../usecases/TwoSecureBrokerRequestReplyTest.java | 14 +-
.../activemq/usecases/UnlimitedEnqueueTest.java | 16 +-
.../usecases/UsageBlockedDispatchTest.java | 2 +-
.../VerifyNetworkConsumersDisconnectTest.java | 4 +-
...VirtualTopicNetworkClusterReactivationTest.java | 2 +-
.../org/apache/activemq/util/MessageIdList.java | 6 +-
.../activemq/xbean/ConnectorXBeanConfigTest.java | 2 +-
.../xbean/MultipleTestsWithEmbeddedBrokerTest.java | 2 +-
.../MultipleTestsWithSpringFactoryBeanTest.java | 4 +-
...ultipleTestsWithSpringXBeanFactoryBeanTest.java | 2 +-
.../network/localBroker-custom-factory.xml | 2 +-
activemq-web-console/pom.xml | 71 ++--
.../org/apache/activemq/web/WebConsoleStarter.java | 12 +-
.../activemq/web/config/OsgiConfiguration.java | 2 +-
.../activemq/web/controller/CopyMessage.java | 4 +-
.../activemq/web/controller/CreateDestination.java | 4 +-
.../activemq/web/controller/CreateSubscriber.java | 4 +-
.../activemq/web/controller/DeleteDestination.java | 4 +-
.../apache/activemq/web/controller/DeleteJob.java | 4 +-
.../activemq/web/controller/DeleteMessage.java | 4 +-
.../activemq/web/controller/DeleteSubscriber.java | 4 +-
.../activemq/web/controller/MoveMessage.java | 4 +-
.../activemq/web/controller/PauseDestination.java | 4 +-
.../activemq/web/controller/PurgeDestination.java | 4 +-
.../activemq/web/controller/ResumeDestination.java | 4 +-
.../activemq/web/controller/RetryMessage.java | 4 +-
.../activemq/web/controller/SendMessage.java | 8 +-
.../web/filter/ApplicationContextFilter.java | 18 +-
.../handler/BindingBeanNameUrlHandlerMapping.java | 2 +-
.../src/main/webapp/WEB-INF/jspf/headertags.jspf | 4 +-
.../webapp/WEB-INF/tags/jms/forEachMessage.tag | 4 +-
.../main/webapp/WEB-INF/tags/jms/persistent.tag | 4 +-
.../src/main/webapp/WEB-INF/web.xml | 11 +-
activemq-web-demo/pom.xml | 21 +-
activemq-web-demo/src/main/webapp/META-INF/NOTICE | 2 +-
activemq-web-demo/src/main/webapp/WEB-INF/web.xml | 9 +-
.../java/org/apache/activemq/web/AjaxTest.java | 4 +-
.../org/apache/activemq/web/JettyTestSupport.java | 6 +-
.../java/org/apache/activemq/web/RestTest.java | 7 +-
activemq-web/pom.xml | 10 +-
.../java/org/apache/activemq/web/AjaxListener.java | 6 +-
.../java/org/apache/activemq/web/AjaxServlet.java | 6 +-
.../org/apache/activemq/web/AjaxWebClient.java | 4 +-
.../java/org/apache/activemq/web/AuditFilter.java | 4 +-
.../org/apache/activemq/web/DestinationFacade.java | 2 +-
.../activemq/web/MessageListenerServlet.java | 24 +-
.../java/org/apache/activemq/web/MessageQuery.java | 16 +-
.../org/apache/activemq/web/MessageServlet.java | 15 +-
.../apache/activemq/web/MessageServletSupport.java | 14 +-
.../web/NoDestinationSuppliedException.java | 2 +-
.../activemq/web/NoSuchViewStyleException.java | 2 +-
.../activemq/web/PortfolioPublishServlet.java | 14 +-
.../org/apache/activemq/web/QueueBrowseQuery.java | 8 +-
.../apache/activemq/web/QueueBrowseServlet.java | 18 +-
.../apache/activemq/web/QueueConsumerQuery.java | 2 +-
.../apache/activemq/web/QueueProducerQuery.java | 2 +-
.../org/apache/activemq/web/SessionFilter.java | 16 +-
.../org/apache/activemq/web/SessionListener.java | 4 +-
.../java/org/apache/activemq/web/SessionPool.java | 8 +-
.../activemq/web/SpringBrokerContextListener.java | 6 +-
.../apache/activemq/web/TopicProducerQuery.java | 2 +-
.../apache/activemq/web/TopicSubscriberQuery.java | 2 +-
.../activemq/web/UndeliveredAjaxMessage.java | 4 +-
.../java/org/apache/activemq/web/WebClient.java | 32 +-
.../activemq/web/async/AsyncServletRequest.java | 12 +-
.../activemq/web/config/AbstractConfiguration.java | 2 +-
.../activemq/web/config/JNDIConfiguration.java | 2 +-
.../apache/activemq/web/config/JspConfigurer.java | 12 +-
.../web/config/SystemPropertiesConfiguration.java | 2 +-
.../web/config/WebConsoleConfiguration.java | 2 +-
.../apache/activemq/web/view/MessageRenderer.java | 12 +-
.../activemq/web/view/RssMessageRenderer.java | 14 +-
.../activemq/web/view/SimpleMessageRenderer.java | 12 +-
.../activemq/web/view/XmlMessageRenderer.java | 10 +-
assembly/pom.xml | 45 ++-
assembly/src/main/descriptors/common-bin.xml | 31 +-
assembly/src/release/conf/jetty.xml | 3 +
assembly/src/release/examples/amqp/java/pom.xml | 8 +-
.../amqp/java/src/main/java/example/Listener.java | 2 +-
.../amqp/java/src/main/java/example/Publisher.java | 2 +-
.../src/release/examples/conf/activemq-demo.xml | 2 +-
assembly/src/release/examples/conf/jetty-demo.xml | 5 +-
assembly/src/release/examples/mqtt/java/pom.xml | 6 +-
.../main/java/example/composite/dest/Consumer.java | 2 +-
.../main/java/example/composite/dest/Producer.java | 2 +-
.../main/java/example/topic/durable/Publisher.java | 2 +-
.../java/example/topic/durable/Subscriber.java | 2 +-
.../java/example/queue/exclusive/Consumer.java | 2 +-
.../java/example/queue/exclusive/Producer.java | 2 +-
.../src/main/java/example/browser/Browser.java | 2 +-
.../src/main/java/example/browser/Producer.java | 2 +-
.../main/java/example/queue/selector/Consumer.java | 2 +-
.../main/java/example/queue/selector/Producer.java | 2 +-
.../src/main/java/example/queue/Consumer.java | 2 +-
.../src/main/java/example/queue/Producer.java | 2 +-
.../src/main/java/example/tempdest/Consumer.java | 2 +-
.../example/tempdest/ProducerRequestReply.java | 2 +-
.../src/main/java/example/topic/Publisher.java | 2 +-
.../src/main/java/example/topic/Subscriber.java | 2 +-
.../src/main/java/example/transaction/Client.java | 2 +-
.../src/main/java/example/wildcard/Client.java | 2 +-
.../examples/openwire/advanced-scenarios/pom.xml | 25 +-
.../src/release/examples/openwire/java/pom.xml | 8 +-
.../java/src/main/java/example/Listener.java | 2 +-
.../java/src/main/java/example/Publisher.java | 2 +-
assembly/src/release/examples/stomp/java/pom.xml | 6 +-
.../stomp/java/src/main/java/example/Listener.java | 8 +-
.../java/src/main/java/example/Publisher.java | 8 +-
assembly/src/release/webapps/api/WEB-INF/web.xml | 17 +-
.../activemq/benchmark/BenchmarkSupport.java | 8 +-
.../org/apache/activemq/benchmark/Consumer.java | 16 +-
.../org/apache/activemq/benchmark/Producer.java | 12 +-
.../activemq/config/BrokerXmlConfigStartTest.java | 6 +-
pom.xml | 94 +++---
1425 files changed, 9514 insertions(+), 8091 deletions(-)
delete mode 100644 activemq-client-jakarta/src/test/java/org/apache/activemq/jakarta/JakartaTest.java
rename activemq-http/src/main/java/org/apache/activemq/transport/ws/{jetty9 => \
jetty11}/MQTTSocket.java (95%) rename \
activemq-http/src/main/java/org/apache/activemq/transport/ws/{jetty9 => \
jetty11}/StompSocket.java (93%) rename \
activemq-http/src/main/java/org/apache/activemq/transport/ws/{jetty9 => \
jetty11}/WSServlet.java (89%) create mode 100644 \
activemq-spring/src/test/java/org/apache/activemq/spring/geronimo/ConnectionFactoryFactoryBean.java
create mode 100644 \
activemq-spring/src/test/java/org/apache/activemq/spring/geronimo/ConnectionManagerFactoryBean.java
create mode 100644 \
activemq-spring/src/test/java/org/apache/activemq/spring/geronimo/ConnectionTrackerFactoryBean.java
create mode 100644 \
activemq-spring/src/test/java/org/apache/activemq/spring/geronimo/GeronimoPlatformTransactionManager.java
create mode 100644 \
activemq-spring/src/test/java/org/apache/activemq/spring/geronimo/HowlLogFactoryBean.java
create mode 100644 \
activemq-spring/src/test/java/org/apache/activemq/spring/geronimo/TransactionManagerFactoryBean.java
[prev in list] [next in list] [prev in thread] [next in thread]
Configure |
About |
News |
Add a list |
Sponsored by KoreLogic