This is an automated email from the git hooks/post-receive script.
ebourg-guest pushed a commit to branch master
in repository activemq.
commit 739582df522926211442b4a2ec906bf476d5f972
Merge: 71837b1 3033de9
Author: Emmanuel Bourg <ebo...@apache.org>
Date: Tue Dec 12 00:46:33 2017 +0100
Update upstream source from tag 'upstream/5.15.2'
Update to upstream version '5.15.2'
with Debian dir 28e37a2c898a8cbbe4b78970f7ec94c627a10d15
activemq-all/pom.xml | 2 +-
activemq-amqp/pom.xml | 8 +-
.../activemq/transport/amqp/AmqpWSTransport.java | 5 +
.../activemq/transport/amqp/AmqpWireFormat.java | 3 +-
.../transport/amqp/AmqpWireFormatFactory.java | 2 +-
.../amqp/protocol/AmqpAbstractReceiver.java | 7 +
.../transport/amqp/protocol/AmqpConnection.java | 29 +-
.../transport/amqp/protocol/AmqpSender.java | 13 +-
.../amqp/protocol/AmqpTransferTagGenerator.java | 66 ++-
.../transport/amqp/AmqpAndStompInteropTest.java | 226 +++++++++
.../activemq/transport/amqp/AmqpTestSupport.java | 4 -
.../apache/activemq/transport/amqp/IDERunner.java | 4 +-
.../activemq/transport/amqp/JMSClientContext.java | 35 +-
.../transport/amqp/JMSClientTestSupport.java | 67 +--
.../amqp/JMSLargeMessageSendRecvTest.java | 26 +-
.../transport/amqp/client/AmqpConnection.java | 30 +-
.../transport/amqp/client/AmqpMessage.java | 4 +-
.../transport/amqp/client/AmqpReceiver.java | 56 ++-
.../activemq/transport/amqp/client/AmqpSender.java | 51 +-
.../transport/amqp/client/AmqpSession.java | 84 +++-
.../amqp/client/AmqpTransferTagGenerator.java | 66 ++-
.../amqp/client/transport/NettyTcpTransport.java | 45 +-
.../amqp/client/transport/NettyTransport.java | 4 +
.../client/transport/NettyTransportOptions.java | 19 +
.../amqp/client/transport/NettyWSTransport.java | 10 +-
.../transport/PartialPooledByteBufAllocator.java | 5 +
.../amqp/client/util/UnmodifiableConnection.java | 202 --------
.../amqp/client/util/UnmodifiableDelivery.java | 168 -------
.../amqp/client/util/UnmodifiableLink.java | 306 ------------
.../amqp/client/util/UnmodifiableProxy.java | 167 +++++++
.../amqp/client/util/UnmodifiableReceiver.java | 65 ---
.../amqp/client/util/UnmodifiableSender.java | 51 --
.../amqp/client/util/UnmodifiableSession.java | 197 --------
.../amqp/client/util/UnmodifiableTransport.java | 274 -----------
.../interop/AmqpBrokerReuqestedHearbeatsTest.java | 4 +-
.../interop/AmqpClientRequestsHeartbeatsTest.java | 4 +-
.../amqp/interop/AmqpConnectionsTest.java | 75 +++
.../amqp/interop/AmqpMaxFrameSizeTest.java | 9 +-
.../transport/amqp/interop/AmqpReceiverTest.java | 75 +++
.../transport/amqp/interop/AmqpSenderTest.java | 84 ++++
.../transport/amqp/interop/AmqpSessionTest.java | 35 ++
.../amqp/message/MessageTransformationTest.java | 33 +-
.../protocol/AmqpTransferTagGeneratorTest.java | 186 ++++++++
activemq-amqp/src/test/resources/log4j.properties | 0
activemq-blueprint/pom.xml | 2 +-
activemq-broker/pom.xml | 11 +-
.../apache/activemq/advisory/AdvisoryBroker.java | 74 ++-
.../java/org/apache/activemq/broker/Broker.java | 4 +-
.../apache/activemq/broker/BrokerBroadcaster.java | 0
.../org/apache/activemq/broker/BrokerFactory.java | 0
.../org/apache/activemq/broker/BrokerFilter.java | 149 +++---
.../org/apache/activemq/broker/BrokerRegistry.java | 0
.../org/apache/activemq/broker/BrokerService.java | 92 ++--
.../broker/CompositeDestinationBroker.java | 0
.../org/apache/activemq/broker/Connection.java | 0
.../apache/activemq/broker/ConnectionContext.java | 0
.../java/org/apache/activemq/broker/Connector.java | 0
.../activemq/broker/ConsumerBrokerExchange.java | 0
.../org/apache/activemq/broker/EmptyBroker.java | 55 +--
.../org/apache/activemq/broker/ErrorBroker.java | 18 +-
.../MapTransportConnectionStateRegister.java | 0
.../activemq/broker/MutableBrokerFilter.java | 374 +--------------
.../activemq/broker/ProducerBrokerExchange.java | 3 +-
.../activemq/broker/PublishedAddressPolicy.java | 25 +-
.../SingleTransportConnectionStateRegister.java | 0
.../apache/activemq/broker/TransactionBroker.java | 0
.../activemq/broker/TransportConnection.java | 17 +-
.../activemq/broker/TransportConnectionState.java | 0
.../broker/TransportConnectionStateRegister.java | 0
.../apache/activemq/broker/TransportConnector.java | 0
.../activemq/broker/TransportStatusDetector.java | 0
.../apache/activemq/broker/jmx/AnnotatedMBean.java | 39 +-
.../org/apache/activemq/broker/jmx/BrokerView.java | 31 +-
.../activemq/broker/jmx/BrokerViewMBean.java | 18 +
.../apache/activemq/broker/jmx/ConnectionView.java | 0
.../activemq/broker/jmx/ConnectionViewMBean.java | 0
.../apache/activemq/broker/jmx/ConnectorView.java | 0
.../activemq/broker/jmx/ConnectorViewMBean.java | 0
.../activemq/broker/jmx/DestinationView.java | 5 +
.../activemq/broker/jmx/DestinationViewMBean.java | 40 +-
.../broker/jmx/DestinationsViewFilter.java | 247 ++++++++++
.../broker/jmx/DurableSubscriptionView.java | 0
.../broker/jmx/DurableSubscriptionViewMBean.java | 0
.../jmx/InactiveDurableSubscriptionView.java | 0
.../activemq/broker/jmx/ManagedQueueRegion.java | 0
.../activemq/broker/jmx/ManagedRegionBroker.java | 9 +
.../broker/jmx/ManagedTempQueueRegion.java | 0
.../broker/jmx/ManagedTempTopicRegion.java | 0
.../activemq/broker/jmx/ManagedTopicRegion.java | 0
.../broker/jmx/ManagedTransportConnector.java | 0
.../activemq/broker/jmx/ManagementContext.java | 11 +-
.../org/apache/activemq/broker/jmx/QueueView.java | 12 +-
.../activemq/broker/jmx/SubscriptionView.java | 0
.../activemq/broker/jmx/SubscriptionViewMBean.java | 0
.../org/apache/activemq/broker/jmx/TopicView.java | 0
.../apache/activemq/broker/jmx/TopicViewMBean.java | 0
.../activemq/broker/region/AbstractRegion.java | 0
.../broker/region/AbstractSubscription.java | 42 ++
.../activemq/broker/region/BaseDestination.java | 25 +-
.../apache/activemq/broker/region/Destination.java | 0
.../broker/region/DestinationStatistics.java | 0
.../broker/region/DurableTopicSubscription.java | 0
.../broker/region/PrefetchSubscription.java | 79 +---
.../org/apache/activemq/broker/region/Queue.java | 56 ++-
.../broker/region/QueueBrowserSubscription.java | 0
.../apache/activemq/broker/region/QueueRegion.java | 0
.../activemq/broker/region/QueueSubscription.java | 0
.../org/apache/activemq/broker/region/Region.java | 2 +-
.../activemq/broker/region/RegionBroker.java | 11 +-
.../activemq/broker/region/Subscription.java | 0
.../apache/activemq/broker/region/TempQueue.java | 0
.../activemq/broker/region/TempQueueRegion.java | 0
.../apache/activemq/broker/region/TempTopic.java | 0
.../activemq/broker/region/TempTopicRegion.java | 0
.../org/apache/activemq/broker/region/Topic.java | 3 +-
.../apache/activemq/broker/region/TopicRegion.java | 0
.../activemq/broker/region/TopicSubscription.java | 50 +-
.../cursors/AbstractPendingMessageCursor.java | 13 +-
.../broker/region/cursors/AbstractStoreCursor.java | 100 ++--
.../region/cursors/FilePendingMessageCursor.java | 0
.../region/cursors/PendingMessageCursor.java | 0
.../broker/region/cursors/QueueStorePrefetch.java | 7 +
.../cursors/StoreDurableSubscriberCursor.java | 0
.../broker/region/cursors/StoreQueueCursor.java | 0
.../broker/region/cursors/TopicStorePrefetch.java | 9 +
.../region/cursors/VMPendingMessageCursor.java | 0
.../region/policy/AbstractDeadLetterStrategy.java | 17 +
.../broker/region/policy/DispatchPolicy.java | 0
...ndingDurableSubscriberMessageStoragePolicy.java | 0
.../FilePendingQueueMessageStoragePolicy.java | 0
...ndingDurableSubscriberMessageStoragePolicy.java | 0
.../policy/PendingQueueMessageStoragePolicy.java | 0
.../activemq/broker/region/policy/PolicyEntry.java | 1 +
.../region/policy/PriorityDispatchPolicy.java | 0
.../region/policy/RoundRobinDispatchPolicy.java | 0
.../broker/region/policy/SimpleDispatchPolicy.java | 0
...ndingDurableSubscriberMessageStoragePolicy.java | 0
.../StorePendingQueueMessageStoragePolicy.java | 0
.../region/policy/StrictOrderDispatchPolicy.java | 0
...ndingDurableSubscriberMessageStoragePolicy.java | 0
.../policy/VMPendingQueueMessageStoragePolicy.java | 0
.../region/virtual/CompositeDestinationFilter.java | 1 +
.../broker/region/virtual/MappedQueueFilter.java | 55 +--
.../activemq/broker/scheduler/SchedulerBroker.java | 121 +++++
.../activemq/broker/util/JMXAuditLogEntry.java | 9 +-
.../activemq/broker/util/LoggingBrokerPlugin.java | 3 +-
.../activemq/filter/XalanXPathEvaluator.java | 0
.../java/org/apache/activemq/memory/Cache.java | 0
.../org/apache/activemq/memory/CacheEntry.java | 0
.../org/apache/activemq/memory/CacheEntryList.java | 0
.../memory/CacheEvictionUsageListener.java | 0
.../org/apache/activemq/memory/CacheEvictor.java | 0
.../org/apache/activemq/memory/CacheFilter.java | 0
.../java/org/apache/activemq/memory/LRUMap.java | 0
.../java/org/apache/activemq/memory/MapCache.java | 0
.../activemq/memory/UsageManagerCacheFilter.java | 0
.../activemq/network/DemandForwardingBridge.java | 0
.../network/DemandForwardingBridgeSupport.java | 69 ++-
.../apache/activemq/network/ForwardingBridge.java | 0
.../activemq/network/NetworkBridgeFactory.java | 14 +-
.../apache/activemq/network/NetworkConnector.java | 2 +-
.../activemq/network/jms/DestinationBridge.java | 0
.../activemq/network/jms/InboundQueueBridge.java | 0
.../activemq/network/jms/InboundTopicBridge.java | 0
.../apache/activemq/network/jms/JmsConnector.java | 0
.../activemq/network/jms/JmsMesageConvertor.java | 0
.../activemq/network/jms/OutboundQueueBridge.java | 0
.../activemq/network/jms/OutboundTopicBridge.java | 0
.../apache/activemq/network/jms/QueueBridge.java | 0
.../network/jms/SimpleJmsMessageConvertor.java | 0
.../network/jms/SimpleJmsQueueConnector.java | 0
.../network/jms/SimpleJmsTopicConnector.java | 0
.../apache/activemq/network/jms/TopicBridge.java | 0
.../security/JaasAuthenticationBroker.java | 18 +-
.../activemq/security/LDAPAuthorizationMap.java | 0
.../activemq/store/MessageRecoveryListener.java | 0
.../org/apache/activemq/store/MessageStore.java | 0
.../apache/activemq/store/PersistenceAdapter.java | 2 +
.../activemq/store/PersistenceAdapterFactory.java | 0
.../apache/activemq/store/ProxyMessageStore.java | 0
.../activemq/store/ProxyTopicMessageStore.java | 0
.../apache/activemq/store/TopicMessageStore.java | 0
.../store/TransactionRecoveryListener.java | 0
.../apache/activemq/store/TransactionStore.java | 0
.../activemq/store/memory/MemoryMessageStore.java | 0
.../store/memory/MemoryPersistenceAdapter.java | 3 +
.../store/memory/MemoryTopicMessageStore.java | 0
.../activemq/store/memory/MemoryTopicSub.java | 0
.../store/memory/MemoryTransactionStore.java | 0
.../activemq/transaction/LocalTransaction.java | 23 +-
.../apache/activemq/transaction/Transaction.java | 11 +-
.../apache/activemq/transaction/XATransaction.java | 0
.../apache/activemq/transport/TransportLogger.java | 0
.../activemq/transport/TransportLoggerFactory.java | 17 +-
.../transport/auto/AutoTcpTransportServer.java | 2 +-
.../auto/nio/AutoNIOSSLTransportServer.java | 10 +-
.../transport/logwriters/CustomLogWriter.java | 7 +-
.../transport/logwriters/DefaultLogWriter.java | 18 +-
.../transport/peer/PeerTransportFactory.java | 0
.../transport/protocol/MqttProtocolVerifier.java | 32 +-
.../apache/activemq/transport/vm/VMTransport.java | 10 +-
.../activemq/transport/vm/VMTransportFactory.java | 0
.../activemq/transport/vm/VMTransportServer.java | 0
.../apache/activemq/usage/PercentLimitUsage.java | 33 ++
.../java/org/apache/activemq/usage/StoreUsage.java | 32 +-
.../org/apache/activemq/usage/SystemUsage.java | 0
.../java/org/apache/activemq/usage/TempUsage.java | 25 +-
.../activemq/util/DefaultIOExceptionHandler.java | 15 +-
.../java/org/apache/activemq/util/HexSupport.java | 0
.../java/org/apache/activemq/util/JMXSupport.java | 0
.../org/apache/activemq/util/SubscriptionKey.java | 0
.../apache/activemq/util/TransactionTemplate.java | 0
.../org/apache/activemq/util/WrappedException.java | 0
.../apache/activemq/JmsQueueTransactionTest.java | 0
.../apache/activemq/JmsTransactionTestSupport.java | 0
.../activemq/broker/BrokerInterceptorsTest.java | 61 +++
.../apache/activemq/broker/BrokerServiceTest.java | 60 +++
.../java/org/apache/activemq/broker/IDERunner.java | 31 +-
.../apache/activemq/broker/LinkStealingTest.java | 8 +-
.../broker/PublishedAddressPolicyTest.java | 70 +++
.../apache/activemq/test/JmsResourceProvider.java | 0
.../java/org/apache/activemq/test/TestSupport.java | 0
.../util/DefaultIOExceptionHandlerTest.java | 5 +
.../src/test/resources/log4j.properties | 0
activemq-camel/pom.xml | 6 +-
.../apache/activemq/camel/CamelShutdownHook.java | 73 +++
.../camel/camelplugin/CamelRoutesBroker.java | 2 +-
.../camel/component/ActiveMQComponent.java | 25 +-
.../camel/component/ActiveMQConfiguration.java | 34 +-
.../activemq/camel/BrokerPreShutdownHookTest.java | 80 ++++
.../camel/component/ActiveMQRouteTest.java | 39 +-
activemq-camel/src/test/resources/log4j.properties | 0
...melDestinationExclusiveConsumerTest-context.xml | 5 +
.../activemq/camel/SetHeaderTest-context.xml | 4 +
activemq-cf/pom.xml | 2 +-
.../osgi/cf/ConnectionFactoryProvider.java | 2 +-
activemq-client/pom.xml | 2 +-
.../org/apache/activemq/ActiveMQConnection.java | 6 +-
.../activemq/ActiveMQConnectionConsumer.java | 0
.../apache/activemq/ActiveMQConnectionFactory.java | 0
.../activemq/ActiveMQConnectionMetaData.java | 0
.../org/apache/activemq/ActiveMQDispatcher.java | 0
.../org/apache/activemq/ActiveMQMessageAudit.java | 0
.../activemq/ActiveMQMessageAuditNoSync.java | 0
.../apache/activemq/ActiveMQMessageConsumer.java | 9 +-
.../apache/activemq/ActiveMQMessageProducer.java | 0
.../activemq/ActiveMQMessageTransformation.java | 0
.../apache/activemq/ActiveMQPrefetchPolicy.java | 0
.../org/apache/activemq/ActiveMQQueueBrowser.java | 0
.../org/apache/activemq/ActiveMQQueueReceiver.java | 0
.../org/apache/activemq/ActiveMQQueueSender.java | 0
.../org/apache/activemq/ActiveMQQueueSession.java | 0
.../java/org/apache/activemq/ActiveMQSession.java | 5 +
.../apache/activemq/ActiveMQSessionExecutor.java | 0
.../apache/activemq/ActiveMQTopicPublisher.java | 0
.../org/apache/activemq/ActiveMQTopicSession.java | 0
.../apache/activemq/ActiveMQTopicSubscriber.java | 0
.../org/apache/activemq/ActiveMQXAConnection.java | 0
.../org/apache/activemq/ActiveMQXASession.java | 0
.../java/org/apache/activemq/AdvisoryConsumer.java | 0
.../apache/activemq/AlreadyClosedException.java | 0
.../main/java/org/apache/activemq/Closeable.java | 0
.../apache/activemq/ConfigurationException.java | 0
.../apache/activemq/ConnectionClosedException.java | 0
.../apache/activemq/ConnectionFailedException.java | 0
.../activemq/LocalTransactionEventListener.java | 0
.../apache/activemq/MessageDispatchChannel.java | 0
.../org/apache/activemq/NotStartedException.java | 0
.../java/org/apache/activemq/RedeliveryPolicy.java | 9 +
.../java/org/apache/activemq/ThreadPriorities.java | 0
.../org/apache/activemq/TransactionContext.java | 0
.../apache/activemq/TransportLoggerSupport.java | 6 +
.../apache/activemq/advisory/AdvisorySupport.java | 0
.../activemq/blob/DefaultBlobDownloadStrategy.java | 10 +-
.../activemq/blob/DefaultBlobUploadStrategy.java | 4 +-
.../activemq/broker/region/MessageReference.java | 0
.../activemq/command/ActiveMQBytesMessage.java | 5 +
.../activemq/command/ActiveMQDestination.java | 10 +-
.../activemq/command/ActiveMQMapMessage.java | 5 +
.../apache/activemq/command/ActiveMQMessage.java | 7 +
.../activemq/command/ActiveMQObjectMessage.java | 5 +
.../org/apache/activemq/command/ActiveMQQueue.java | 0
.../activemq/command/ActiveMQStreamMessage.java | 7 +-
.../activemq/command/ActiveMQTempDestination.java | 0
.../apache/activemq/command/ActiveMQTempQueue.java | 0
.../apache/activemq/command/ActiveMQTempTopic.java | 0
.../activemq/command/ActiveMQTextMessage.java | 5 +
.../org/apache/activemq/command/ActiveMQTopic.java | 0
.../org/apache/activemq/command/BaseCommand.java | 0
.../java/org/apache/activemq/command/BrokerId.java | 0
.../org/apache/activemq/command/BrokerInfo.java | 0
.../java/org/apache/activemq/command/Command.java | 0
.../org/apache/activemq/command/CommandTypes.java | 0
.../org/apache/activemq/command/ConnectionId.java | 0
.../apache/activemq/command/ConnectionInfo.java | 0
.../org/apache/activemq/command/ConsumerId.java | 0
.../org/apache/activemq/command/ConsumerInfo.java | 8 +
.../apache/activemq/command/DataArrayResponse.java | 0
.../org/apache/activemq/command/DataResponse.java | 0
.../org/apache/activemq/command/DataStructure.java | 0
.../apache/activemq/command/DestinationInfo.java | 0
.../apache/activemq/command/DiscoveryEvent.java | 0
.../apache/activemq/command/ExceptionResponse.java | 0
.../apache/activemq/command/IntegerResponse.java | 0
.../apache/activemq/command/JournalQueueAck.java | 0
.../apache/activemq/command/JournalTopicAck.java | 0
.../org/apache/activemq/command/JournalTrace.java | 0
.../activemq/command/JournalTransaction.java | 0
.../org/apache/activemq/command/KeepAliveInfo.java | 0
.../activemq/command/LocalTransactionId.java | 0
.../org/apache/activemq/command/MarshallAware.java | 0
.../java/org/apache/activemq/command/Message.java | 10 +-
.../org/apache/activemq/command/MessageAck.java | 0
.../apache/activemq/command/MessageDispatch.java | 0
.../command/MessageDispatchNotification.java | 0
.../org/apache/activemq/command/MessageId.java | 0
.../org/apache/activemq/command/MessagePull.java | 9 +-
.../org/apache/activemq/command/ProducerId.java | 0
.../org/apache/activemq/command/ProducerInfo.java | 0
.../org/apache/activemq/command/RemoveInfo.java | 0
.../activemq/command/RemoveSubscriptionInfo.java | 0
.../java/org/apache/activemq/command/Response.java | 0
.../org/apache/activemq/command/SessionId.java | 0
.../org/apache/activemq/command/SessionInfo.java | 0
.../org/apache/activemq/command/ShutdownInfo.java | 0
.../apache/activemq/command/SubscriptionInfo.java | 0
.../org/apache/activemq/command/TransactionId.java | 0
.../apache/activemq/command/TransactionInfo.java | 0
.../apache/activemq/command/WireFormatInfo.java | 0
.../apache/activemq/command/XATransactionId.java | 0
.../activemq/filter/ArithmeticExpression.java | 0
.../apache/activemq/filter/BinaryExpression.java | 0
.../apache/activemq/filter/BooleanExpression.java | 0
.../activemq/filter/ComparisonExpression.java | 0
.../filter/CompositeDestinationFilter.java | 0
.../apache/activemq/filter/ConstantExpression.java | 0
.../apache/activemq/filter/DestinationFilter.java | 0
.../org/apache/activemq/filter/DestinationMap.java | 0
.../apache/activemq/filter/DestinationMapNode.java | 0
.../apache/activemq/filter/DestinationPath.java | 0
.../org/apache/activemq/filter/Expression.java | 0
.../apache/activemq/filter/LogicExpression.java | 0
.../activemq/filter/MessageEvaluationContext.java | 0
.../activemq/filter/MultiExpressionEvaluator.java | 0
.../apache/activemq/filter/NoLocalExpression.java | 0
.../activemq/filter/PrefixDestinationFilter.java | 0
.../apache/activemq/filter/PropertyExpression.java | 0
.../activemq/filter/SimpleDestinationFilter.java | 0
.../apache/activemq/filter/UnaryExpression.java | 0
.../activemq/filter/WildcardDestinationFilter.java | 0
.../apache/activemq/filter/XPathExpression.java | 0
.../apache/activemq/filter/XQueryExpression.java | 0
.../jndi/ActiveMQInitialContextFactory.java | 0
.../apache/activemq/jndi/LazyCreateContext.java | 0
.../org/apache/activemq/jndi/NameParserImpl.java | 0
.../org/apache/activemq/jndi/ReadOnlyContext.java | 0
.../activemq/management/BoundaryStatisticImpl.java | 0
.../management/BoundedRangeStatisticImpl.java | 0
.../activemq/management/CountStatisticImpl.java | 0
.../management/JCAConnectionPoolStatsImpl.java | 0
.../management/JCAConnectionStatsImpl.java | 0
.../apache/activemq/management/JCAStatsImpl.java | 0
.../management/JMSConnectionStatsImpl.java | 0
.../activemq/management/JMSConsumerStatsImpl.java | 0
.../activemq/management/JMSEndpointStatsImpl.java | 0
.../activemq/management/JMSProducerStatsImpl.java | 0
.../activemq/management/JMSSessionStatsImpl.java | 0
.../apache/activemq/management/JMSStatsImpl.java | 0
.../management/PollCountStatisticImpl.java | 0
.../activemq/management/RangeStatisticImpl.java | 0
.../org/apache/activemq/management/Resettable.java | 0
.../apache/activemq/management/StatisticImpl.java | 0
.../apache/activemq/management/StatsCapable.java | 0
.../org/apache/activemq/management/StatsImpl.java | 0
.../activemq/management/TimeStatisticImpl.java | 0
.../apache/activemq/openwire/BooleanStream.java | 0
.../activemq/openwire/DataStreamMarshaller.java | 0
.../apache/activemq/openwire/OpenWireFormat.java | 0
.../activemq/openwire/OpenWireFormatFactory.java | 0
.../v1/ActiveMQBytesMessageMarshaller.java | 0
.../openwire/v1/ActiveMQDestinationMarshaller.java | 0
.../openwire/v1/ActiveMQMapMessageMarshaller.java | 0
.../openwire/v1/ActiveMQMessageMarshaller.java | 0
.../v1/ActiveMQObjectMessageMarshaller.java | 0
.../openwire/v1/ActiveMQQueueMarshaller.java | 0
.../v1/ActiveMQStreamMessageMarshaller.java | 0
.../v1/ActiveMQTempDestinationMarshaller.java | 0
.../openwire/v1/ActiveMQTempQueueMarshaller.java | 0
.../openwire/v1/ActiveMQTempTopicMarshaller.java | 0
.../openwire/v1/ActiveMQTextMessageMarshaller.java | 0
.../openwire/v1/ActiveMQTopicMarshaller.java | 0
.../openwire/v1/BaseCommandMarshaller.java | 0
.../openwire/v1/BaseDataStreamMarshaller.java | 0
.../activemq/openwire/v1/BrokerIdMarshaller.java | 0
.../activemq/openwire/v1/BrokerInfoMarshaller.java | 0
.../openwire/v1/ConnectionIdMarshaller.java | 0
.../openwire/v1/ConnectionInfoMarshaller.java | 0
.../activemq/openwire/v1/ConsumerIdMarshaller.java | 0
.../openwire/v1/ConsumerInfoMarshaller.java | 0
.../openwire/v1/DataArrayResponseMarshaller.java | 0
.../openwire/v1/DataResponseMarshaller.java | 0
.../openwire/v1/DestinationInfoMarshaller.java | 0
.../openwire/v1/ExceptionResponseMarshaller.java | 0
.../openwire/v1/IntegerResponseMarshaller.java | 0
.../openwire/v1/JournalQueueAckMarshaller.java | 0
.../openwire/v1/JournalTopicAckMarshaller.java | 0
.../openwire/v1/JournalTraceMarshaller.java | 0
.../openwire/v1/JournalTransactionMarshaller.java | 0
.../openwire/v1/KeepAliveInfoMarshaller.java | 0
.../openwire/v1/LocalTransactionIdMarshaller.java | 0
.../activemq/openwire/v1/MarshallerFactory.java | 0
.../activemq/openwire/v1/MessageAckMarshaller.java | 0
.../openwire/v1/MessageDispatchMarshaller.java | 0
.../activemq/openwire/v1/MessageIdMarshaller.java | 0
.../activemq/openwire/v1/MessageMarshaller.java | 0
.../activemq/openwire/v1/ProducerIdMarshaller.java | 0
.../openwire/v1/ProducerInfoMarshaller.java | 0
.../activemq/openwire/v1/RemoveInfoMarshaller.java | 0
.../v1/RemoveSubscriptionInfoMarshaller.java | 0
.../activemq/openwire/v1/ResponseMarshaller.java | 0
.../activemq/openwire/v1/SessionIdMarshaller.java | 0
.../openwire/v1/SessionInfoMarshaller.java | 0
.../openwire/v1/ShutdownInfoMarshaller.java | 0
.../openwire/v1/SubscriptionInfoMarshaller.java | 0
.../openwire/v1/TransactionIdMarshaller.java | 0
.../openwire/v1/TransactionInfoMarshaller.java | 0
.../openwire/v1/WireFormatInfoMarshaller.java | 0
.../openwire/v1/XATransactionIdMarshaller.java | 0
.../org/apache/activemq/state/CommandVisitor.java | 0
.../org/apache/activemq/state/ConnectionState.java | 0
.../activemq/state/ConnectionStateTracker.java | 0
.../org/apache/activemq/state/ConsumerState.java | 0
.../org/apache/activemq/state/ProducerState.java | 0
.../org/apache/activemq/state/SessionState.java | 0
.../apache/activemq/thread/DefaultThreadPools.java | 0
.../java/org/apache/activemq/thread/Scheduler.java | 0
.../main/java/org/apache/activemq/thread/Task.java | 0
.../org/apache/activemq/thread/TaskRunner.java | 0
.../apache/activemq/thread/TaskRunnerFactory.java | 0
.../activemq/transaction/Synchronization.java | 0
.../transport/DefaultTransportListener.java | 0
.../apache/activemq/transport/FutureResponse.java | 0
.../activemq/transport/InactivityMonitor.java | 0
.../org/apache/activemq/transport/LogWriter.java | 7 +
.../transport/MarshallingTransportFilter.java | 0
.../apache/activemq/transport/MutexTransport.java | 0
.../activemq/transport/ResponseCorrelator.java | 0
.../org/apache/activemq/transport/Transport.java | 0
.../transport/TransportAcceptListener.java | 0
.../activemq/transport/TransportFactory.java | 0
.../apache/activemq/transport/TransportFilter.java | 0
.../activemq/transport/TransportListener.java | 0
.../apache/activemq/transport/TransportServer.java | 0
.../activemq/transport/TransportServerFilter.java | 0
.../activemq/transport/WireFormatNegotiator.java | 0
.../transport/discovery/DiscoveryAgent.java | 0
.../transport/discovery/DiscoveryAgentFactory.java | 0
.../transport/discovery/DiscoveryListener.java | 0
.../transport/discovery/DiscoveryTransport.java | 0
.../discovery/DiscoveryTransportFactory.java | 0
.../multicast/MulticastDiscoveryAgent.java | 0
.../multicast/MulticastDiscoveryAgentFactory.java | 0
.../discovery/simple/SimpleDiscoveryAgent.java | 0
.../simple/SimpleDiscoveryAgentFactory.java | 0
.../discovery/zeroconf/ZeroconfDiscoveryAgent.java | 0
.../zeroconf/ZeroconfDiscoveryAgentFactory.java | 0
.../transport/failover/FailoverTransport.java | 0
.../failover/FailoverTransportFactory.java | 0
.../activemq/transport/fanout/FanoutTransport.java | 0
.../transport/fanout/FanoutTransportFactory.java | 0
.../transport/mock/MockTransportFactory.java | 0
.../activemq/transport/nio/SelectorManager.java | 34 +-
.../activemq/transport/nio/SelectorSelection.java | 2 +-
.../activemq/transport/tcp/ResponseHolder.java | 0
.../transport/tcp/TcpBufferedInputStream.java | 0
.../transport/tcp/TcpBufferedOutputStream.java | 0
.../activemq/transport/tcp/TcpTransport.java | 0
.../transport/tcp/TcpTransportFactory.java | 0
.../activemq/transport/tcp/TcpTransportServer.java | 10 +
.../activemq/transport/udp/UdpTransport.java | 0
.../transport/udp/UdpTransportFactory.java | 0
.../activemq/transport/udp/UdpTransportServer.java | 0
.../apache/activemq/transport/ws/WSTransport.java | 5 +
.../activemq/usage/DefaultUsageCapacity.java | 0
.../org/apache/activemq/usage/MemoryUsage.java | 0
.../main/java/org/apache/activemq/usage/Usage.java | 0
.../org/apache/activemq/usage/UsageCapacity.java | 0
.../org/apache/activemq/usage/UsageListener.java | 0
.../java/org/apache/activemq/util/BitArray.java | 0
.../java/org/apache/activemq/util/BitArrayBin.java | 0
.../org/apache/activemq/util/ByteSequence.java | 26 +-
.../java/org/apache/activemq/util/Callback.java | 0
.../activemq/util/DataByteArrayInputStream.java | 4 +-
.../activemq/util/DataByteArrayOutputStream.java | 0
.../apache/activemq/util/IOExceptionSupport.java | 0
.../java/org/apache/activemq/util/IdGenerator.java | 0
.../org/apache/activemq/util/IndentPrinter.java | 0
.../apache/activemq/util/IntrospectionSupport.java | 15 +-
.../apache/activemq/util/JMSExceptionSupport.java | 0
.../java/org/apache/activemq/util/LRUCache.java | 0
.../activemq/util/LongSequenceGenerator.java | 0
.../java/org/apache/activemq/util/MapHelper.java | 0
.../apache/activemq/util/MarshallingSupport.java | 0
.../activemq/util/TypeConversionSupport.java | 0
.../java/org/apache/activemq/util/URISupport.java | 0
.../command/ActiveMQMessageIsMarshalledTest.java | 188 ++++++++
.../org/apache/activemq/thread/TaskRunnerTest.java | 0
.../util/DataByteArrayInputStreamTest.java | 11 +
.../src/test/resources/log4j.properties | 0
activemq-console/pom.xml | 2 +-
.../console/command/AbstractJmxCommand.java | 5 +-
.../activemq/console/command/AmqBrowseCommand.java | 2 +-
.../activemq/console/command/ConsumerCommand.java | 2 +-
.../activemq/console/command/DstatCommand.java | 9 +-
.../activemq/console/command/ProducerCommand.java | 2 +-
.../activemq/console/command/PurgeCommand.java | 38 +-
.../console/filter/MapTransformFilter.java | 4 +-
.../apache/activemq/console/DstatCommandTest.java | 88 ++++
.../activemq/console/command/PurgeCommandTest.java | 124 +++++
.../console/filter/TestMapTransformFilter.java | 10 +
activemq-http/pom.xml | 14 +-
.../discovery/http/HTTPDiscoveryAgentFactory.java | 0
.../transport/http/BlockingQueueTransport.java | 0
.../transport/http/HttpClientTransport.java | 1 +
.../transport/http/HttpEmbeddedTunnelServlet.java | 0
.../transport/http/HttpTransportFactory.java | 0
.../transport/http/HttpTransportServer.java | 0
.../activemq/transport/http/HttpTunnelServlet.java | 0
.../transport/https/HttpsClientTransport.java | 0
.../transport/https/HttpsTransportServer.java | 0
.../activemq/transport/ws/StompWSConnection.java | 4 +-
.../activemq/transport/ws/WSTransportProxy.java | 7 +-
.../activemq/transport/ws/WSTransportServer.java | 4 +-
.../activemq/transport/ws/jetty9/MQTTSocket.java | 31 +-
.../activemq/transport/ws/jetty9/StompSocket.java | 2 +-
.../activemq/transport/ws/jetty9/WSServlet.java | 2 +-
.../transport/xstream/XStreamWireFormat.java | 0
.../transport/http/HttpJmsSendAndReceiveTest.java | 0
.../transport/http/HttpPullConsumerTest.java | 211 +++++++++
.../transport/http/HttpTransportBrokerTest.java | 0
.../activemq/transport/ws/MQTTWSConnection.java | 35 +-
.../transport/ws/MQTTWSSTransportTest.java | 22 +-
.../activemq/transport/ws/MQTTWSTransportTest.java | 26 +-
.../transport/ws/StompWSTransportTest.java | 32 ++
.../transport/xstream/XStreamWireFormatTest.java | 0
activemq-http/src/test/resources/log4j.properties | 0
activemq-http/src/webapp/WEB-INF/web.xml | 0
activemq-itests-spring31/pom.xml | 2 +-
.../src/test/resources/log4j.properties | 0
.../spring31/ActiveMQSpring31Test-context.xml | 0
.../ActiveMQSpringProfile31Test-context.xml | 0
activemq-jaas/pom.xml | 2 +-
activemq-jdbc-store/pom.xml | 2 +-
.../apache/activemq/store/jdbc/JDBCAdapter.java | 0
.../store/jdbc/JDBCMessageIdScanListener.java | 0
.../store/jdbc/JDBCMessageRecoveryListener.java | 0
.../activemq/store/jdbc/JDBCMessageStore.java | 12 +-
.../store/jdbc/JDBCPersistenceAdapter.java | 9 +-
.../activemq/store/jdbc/JDBCTopicMessageStore.java | 0
.../activemq/store/jdbc/LeaseDatabaseLocker.java | 2 +-
.../org/apache/activemq/store/jdbc/Statements.java | 6 +-
.../activemq/store/jdbc/TransactionContext.java | 0
.../store/jdbc/adapter/AxionJDBCAdapter.java | 0
.../store/jdbc/adapter/BlobJDBCAdapter.java | 0
.../store/jdbc/adapter/BytesJDBCAdapter.java | 0
.../store/jdbc/adapter/DefaultJDBCAdapter.java | 0
.../store/jdbc/adapter/HsqldbJDBCAdapter.java | 0
.../store/jdbc/adapter/ImageBasedJDBCAdaptor.java | 0
.../store/jdbc/adapter/InformixJDBCAdapter.java | 0
.../store/jdbc/adapter/OracleJDBCAdapter.java | 0
.../store/jdbc/adapter/StreamJDBCAdapter.java | 0
.../store/journal/JournalMessageStore.java | 0
.../store/journal/JournalPersistenceAdapter.java | 5 +
.../journal/JournalPersistenceAdapterFactory.java | 0
.../store/journal/JournalTopicMessageStore.java | 0
.../store/journal/JournalTransactionStore.java | 0
activemq-jms-pool/pom.xml | 3 +-
.../activemq/jms/pool/IntrospectionSupport.java | 0
.../apache/activemq/jms/pool/PooledConnection.java | 0
.../PooledConnectionSecurityExceptionTest.java | 2 +
.../activemq/jms/pool/PooledConnectionTest.java | 59 +++
.../src/test/resources/log4j.properties | 0
activemq-kahadb-store/pom.xml | 2 +-
.../kahadb/FilteredKahaDBPersistenceAdapter.java | 15 +-
.../store/kahadb/KahaDBPersistenceAdapter.java | 13 +-
.../apache/activemq/store/kahadb/KahaDBStore.java | 26 +-
.../store/kahadb/KahaDBTransactionStore.java | 0
.../activemq/store/kahadb/MessageDatabase.java | 54 ++-
.../kahadb/MultiKahaDBPersistenceAdapter.java | 60 ++-
.../store/kahadb/MultiKahaDBTransactionStore.java | 25 +
.../activemq/store/kahadb/TempKahaDBStore.java | 7 +
.../kahadb/disk/journal/DataFileAccessor.java | 41 +-
.../kahadb/disk/journal/DataFileAppender.java | 7 +-
.../store/kahadb/disk/journal/Journal.java | 225 +++++----
.../store/kahadb/disk/journal/Location.java | 11 +-
.../activemq/store/kahadb/disk/page/PageFile.java | 78 ++--
.../kahadb/disk/util/DataByteArrayInputStream.java | 0
.../disk/util/DataByteArrayOutputStream.java | 0
.../store/kahadb/disk/util/DiskBenchmark.java | 10 +-
.../activemq/store/kahadb/disk/util/Scheduler.java | 0
.../activemq/util/RecoverableRandomAccessFile.java | 16 +-
.../store/kahadb/ErrorOnFutureSendTest.java | 123 +++++
.../JournalCorruptionEofIndexRecoveryTest.java | 79 +++-
...st.java => JournalCorruptionExceptionTest.java} | 168 +++----
.../store/kahadb/JournalFdRecoveryTest.java | 82 +++-
.../activemq/store/kahadb/MessageDatabaseTest.java | 117 +++++
.../store/kahadb/disk/index/IndexBenchmark.java | 0
.../DataFileAppenderNoSpaceNoBatchTest.java | 57 ++-
.../disk/journal/PreallocationJournalTest.java | 35 ++
.../src/test/resources/log4j.properties | 0
activemq-karaf-itest/pom.xml | 11 +-
.../activemq/karaf/itest/AbstractFeatureTest.java | 320 ++++++-------
.../karaf/itest/AbstractJmsFeatureTest.java | 80 ----
.../karaf/itest/ActiveMQAMQPBrokerFeatureTest.java | 71 ++-
...eTest.java => ActiveMQBrokerBlueprintTest.java} | 34 +-
.../karaf/itest/ActiveMQBrokerFeatureTest.java | 166 +++----
.../itest/ActiveMQBrokerNdCamelFeatureTest.java | 71 +--
.../ActiveMQBrokerNdExternalCamelFeatureTest.java | 67 +--
.../ActiveMQBrokerNdWebConsoleFeatureTest.java | 109 -----
.../itest/ActiveMQBrokerRuntimeConfigTest.java | 68 ++-
.../karaf/itest/ActiveMQClientBundleTest.java | 13 +-
...ureTest.java => ActiveMQClientFactoryTest.java} | 56 +--
.../org/apache/activemq/karaf/itest/JMSTester.java | 121 +++++
.../activemq/karaf/itest/KarafShellHelper.java | 92 ++++
.../activemq/karaf/itest/ObrFeatureTest.java | 95 ++--
.../activemq/karaf/itest/activemq-blueprint.xml | 61 +++
.../karaf/itest/org.apache.activemq-local.cfg | 9 +-
activemq-karaf/pom.xml | 4 +-
.../src/main/resources/features-core.xml | 5 +-
activemq-karaf/src/main/resources/features.xml | 6 +
.../org/apache/activemq/karaf/commands/spring.xml | 144 ------
activemq-leveldb-store/pom.xml | 23 +-
activemq-leveldb-store/readme.md | 2 +-
.../org/apache/activemq/leveldb/LevelDBStore.scala | 2 +
.../leveldb/replicated/ProxyLevelDBStore.scala | 2 +
.../leveldb/test/MasterLevelDBStoreTest.java | 2 +
.../src/test/resources/log4j.properties | 0
activemq-log4j-appender/pom.xml | 2 +-
activemq-mqtt/pom.xml | 2 +-
.../apache/activemq/transport/mqtt/MQTTTest.java | 60 ++-
.../transport/mqtt/PahoVirtualTopicMQTTTest.java | 11 +-
activemq-mqtt/src/test/resources/log4j.properties | 0
activemq-openwire-generator/pom.xml | 2 +-
.../activemq/openwire/tool/OpenWireGenerator.java | 0
activemq-openwire-legacy/pom.xml | 2 +-
.../openwire/v2/BaseDataStreamMarshaller.java | 0
activemq-osgi/pom.xml | 47 +-
.../activemq/osgi/ActiveMQServiceFactory.java | 2 +-
.../src/main/resources/META-INF/spring.handlers | 1 -
.../src/main/resources/META-INF/spring.schemas | 5 +-
activemq-partition/pom.xml | 8 +-
activemq-pool/pom.xml | 2 +-
activemq-ra/pom.xml | 2 +-
.../activemq/ra/ActiveMQConnectionFactory.java | 0
.../activemq/ra/ActiveMQConnectionRequestInfo.java | 0
.../activemq/ra/ActiveMQEndpointActivationKey.java | 0
.../apache/activemq/ra/ActiveMQEndpointWorker.java | 0
.../activemq/ra/ActiveMQManagedConnection.java | 2 +-
.../ra/ActiveMQManagedConnectionFactory.java | 0
.../activemq/ra/ActiveMQResourceAdapter.java | 14 +-
.../apache/activemq/ra/InboundConnectionProxy.java | 0
.../activemq/ra/InboundConnectionProxyFactory.java | 0
.../org/apache/activemq/ra/InboundContext.java | 0
.../apache/activemq/ra/InboundContextSupport.java | 0
.../activemq/ra/InboundMessageProducerProxy.java | 0
.../apache/activemq/ra/InboundSessionProxy.java | 0
.../ra/InvalidMessageEndpointException.java | 0
.../apache/activemq/ra/LocalAndXATransaction.java | 0
.../apache/activemq/ra/ManagedConnectionProxy.java | 0
.../apache/activemq/ra/ManagedSessionProxy.java | 0
.../activemq/ra/ManagedTransactionContext.java | 0
.../apache/activemq/ra/MessageActivationSpec.java | 0
.../apache/activemq/ra/MessageEndpointProxy.java | 0
.../apache/activemq/ra/MessageResourceAdapter.java | 0
.../org/apache/activemq/ra/ServerSessionImpl.java | 0
.../apache/activemq/ra/ServerSessionPoolImpl.java | 0
.../activemq/ra/SimpleConnectionManager.java | 0
.../activemq/ra/ActiveMQActivationSpecTest.java | 0
...ctiveMQConnectionExecutorThreadCleanUpTest.java | 138 ++++++
...ctiveMQResourceAdapterJavaBeanEqualityTest.java | 0
.../ra/ConnectionEventListenerAdapter.java | 0
.../activemq/ra/ConnectionManagerAdapter.java | 0
.../activemq/ra/FailoverManagedConnectionTest.java | 0
.../test/java/org/apache/activemq/ra/MDBTest.java | 79 ++++
.../activemq/ra/ManagedConnectionFactoryTest.java | 0
.../apache/activemq/ra/ManagedConnectionTest.java | 0
.../activemq/ra/MessageEndpointProxyTest.java | 0
.../apache/activemq/ra/ServerSessionImplTest.java | 5 +-
activemq-ra/src/test/resources/jndi.properties | 0
activemq-ra/src/test/resources/log4j.properties | 0
activemq-rar/pom.xml | 2 +-
activemq-rar/src/main/rar/log4j.properties | 0
activemq-run/pom.xml | 2 +-
activemq-runtime-config/pom.xml | 2 +-
.../plugin/AuthorizationPluginProcessor.java | 1 +
.../plugin/DefaultConfigurationProcessor.java | 2 +-
.../apache/activemq/AbstractAuthorizationTest.java | 21 +
.../org/apache/activemq/AuthorizationTest.java | 32 ++
.../src/test/resources/log4j.properties | 0
.../authorizationTest-users-add-write-guest.xml | 55 +++
.../authorizationTest-users-dud-groupClass.xml | 53 +++
.../apache/activemq/emptyManualUpdateConfig.xml | 3 +
.../emptyUpdatableConfig1000-spring-bean.xml | 3 +
...0-spring-property-file-list-and-beanFactory.xml | 3 +
...datableConfig1000-spring-property-file-list.xml | 3 +
...UpdatableConfig1000-spring-property-file-nc.xml | 3 +
...ptyUpdatableConfig1000-spring-property-file.xml | 3 +
...emptyUpdatableConfig1000-spring-property-nc.xml | 3 +
.../emptyUpdatableConfig1000-spring-property.xml | 3 +
activemq-shiro/pom.xml | 2 +-
activemq-spring/pom.xml | 33 +-
.../activemq/hooks/osgi/SpringOsgiContextHook.java | 51 --
.../src/main/resources/META-INF/spring.schemas | 3 +
...velDBConfigTest.java => MKahaDBConfigTest.java} | 58 +--
.../activemq/store/leveldb/LevelDBConfigTest.java | 0
activemq-spring/src/test/resources/activemq.xml | 0
.../src/test/resources/log4j.properties | 0
.../org/apache/activemq/store/leveldb/leveldb.xml | 0
.../store/{leveldb/leveldb.xml => mKahaDB.xml} | 23 +-
.../src/test/resources/spring-embedded-pooled.xml | 0
activemq-stomp/pom.xml | 2 +-
.../activemq/transport/stomp/StompCodec.java | 8 +-
.../transport/stomp/StompInactivityMonitor.java | 0
.../transport/stomp/StompSubscription.java | 21 +-
.../activemq/transport/stomp/StompWireFormat.java | 52 ++-
.../activemq/transport/stomp/Stomp11Test.java | 138 ++++++
.../stomp/StompNIOSSLLargeMessageTest.java | 168 +++++++
.../apache/activemq/transport/stomp/StompTest.java | 91 ++++
activemq-stomp/src/test/resources/log4j.properties | 0
activemq-tooling/activemq-junit/pom.xml | 2 +-
.../junit/AbstractActiveMQClientResource.java | 250 ++++++++++
.../junit/AbstractActiveMQConsumerResource.java | 118 +++++
.../junit/AbstractActiveMQProducerResource.java | 132 ++++++
.../junit/ActiveMQDynamicQueueSenderResource.java | 137 ++++++
.../ActiveMQDynamicTopicPublisherResource.java | 136 ++++++
.../junit/ActiveMQQueueReceiverResource.java | 45 ++
.../junit/ActiveMQQueueSenderResource.java | 52 +++
.../ActiveMQTopicDurableSubscriberResource.java | 72 +++
.../junit/ActiveMQTopicPublisherResource.java | 64 +++
.../junit/ActiveMQTopicSubscriberResource.java | 46 ++
.../activemq/junit/EmbeddedActiveMQBroker.java | 515 ++++++++++++++++++---
activemq-tooling/activemq-maven-plugin/pom.xml | 2 +-
.../activemq-memtest-maven-plugin/pom.xml | 2 +-
.../activemq-perf-maven-plugin/pom.xml | 2 +-
activemq-tooling/pom.xml | 2 +-
activemq-unit-tests/pom.xml | 27 +-
.../src/test/eclipse-resources/log4j.properties | 0
.../activemq/ActiveMQConnectionFactoryTest.java | 0
.../apache/activemq/ActiveMQMessageAuditTest.java | 0
.../apache/activemq/BrokerDurableRejectedTest.java | 0
.../org/apache/activemq/ClientTestSupport.java | 0
.../apache/activemq/CombinationTestSupport.java | 0
.../org/apache/activemq/ConnectionCleanupTest.java | 0
...ConnectionCloseMultipleTimesConcurrentTest.java | 0
.../activemq/ConnectionCloseMultipleTimesTest.java | 0
.../java/org/apache/activemq/JMSConsumerTest.java | 125 ++++-
.../activemq/JMSDurableTopicRedeliverTest.java | 0
.../java/org/apache/activemq/JMSMessageTest.java | 0
.../org/apache/activemq/JMSQueueRedeliverTest.java | 0
.../java/org/apache/activemq/JMSUsecaseTest.java | 0
.../org/apache/activemq/JMSXAConsumerTest.java | 10 +
.../apache/activemq/JmsAutoAckListenerTest.java | 0
.../java/org/apache/activemq/JmsAutoAckTest.java | 0
.../java/org/apache/activemq/JmsBenchmark.java | 0
.../apache/activemq/JmsClientAckListenerTest.java | 0
.../java/org/apache/activemq/JmsClientAckTest.java | 0
.../activemq/JmsConnectionStartStopTest.java | 0
.../JmsConsumerResetActiveListenerTest.java | 0
.../activemq/JmsCreateConsumerInOnMessageTest.java | 0
.../JmsDurableQueueWildcardSendReceiveTest.java | 0
.../activemq/JmsDurableTopicSelectorTest.java | 0
.../activemq/JmsDurableTopicSendReceiveTest.java | 0
.../activemq/JmsDurableTopicTransactionTest.java | 0
.../JmsDurableTopicWildcardSendReceiveTest.java | 0
.../activemq/JmsMultipleClientsTestSupport.java | 2 +-
.../org/apache/activemq/JmsQueueBrowserTest.java | 0
.../activemq/JmsQueueCompositeSendReceiveTest.java | 0
.../apache/activemq/JmsQueueRequestReplyTest.java | 0
.../org/apache/activemq/JmsQueueSelectorTest.java | 0
.../apache/activemq/JmsQueueSendReceiveTest.java | 0
.../JmsQueueSendReceiveTwoConnectionsTest.java | 0
.../JmsQueueSendReceiveUsingTwoSessionsTest.java | 0
.../JmsQueueTopicCompositeSendReceiveTest.java | 0
.../activemq/JmsQueueWildcardSendReceiveTest.java | 0
.../org/apache/activemq/JmsRedeliveredTest.java | 0
.../apache/activemq/JmsSendReceiveTestSupport.java | 0
.../activemq/JmsSendWithAsyncCallbackTest.java | 0
.../org/apache/activemq/JmsSessionRecoverTest.java | 0
.../apache/activemq/JmsTempDestinationTest.java | 0
.../java/org/apache/activemq/JmsTestSupport.java | 0
.../activemq/JmsTopicCompositeSendReceiveTest.java | 0
.../org/apache/activemq/JmsTopicRedeliverTest.java | 0
.../apache/activemq/JmsTopicRequestReplyTest.java | 0
.../org/apache/activemq/JmsTopicSelectorTest.java | 0
.../JmsTopicSendReceiveSubscriberTest.java | 0
.../apache/activemq/JmsTopicSendReceiveTest.java | 0
.../JmsTopicSendReceiveWithTwoConnectionsTest.java | 0
.../activemq/JmsTopicSendSameMessageTest.java | 0
.../apache/activemq/JmsTopicTransactionTest.java | 0
.../activemq/JmsTopicWildcardSendReceiveTest.java | 0
.../apache/activemq/LargeMessageTestSupport.java | 0
.../activemq/MessageListenerRedeliveryTest.java | 1 +
.../apache/activemq/MessageTransformationTest.java | 0
.../apache/activemq/ProducerFlowControlTest.java | 50 +-
.../org/apache/activemq/RedeliveryPolicyTest.java | 150 +++++-
.../org/apache/activemq/SpringTestSupport.java | 0
.../test/java/org/apache/activemq/TestSupport.java | 11 +
.../apache/activemq/ZeroPrefetchConsumerTest.java | 7 +-
.../activemq/blob/BlobTransferPolicyUriTest.java | 34 ++
.../apache/activemq/broker/BrokerBenchmark.java | 0
.../activemq/broker/BrokerRedeliveryTest.java | 2 +-
.../apache/activemq/broker/BrokerServiceTest.java | 57 ++-
.../org/apache/activemq/broker/BrokerTest.java | 0
.../apache/activemq/broker/BrokerTestSupport.java | 0
.../broker/DedicatedTaskRunnerBrokerTest.java | 0
.../activemq/broker/DoubleSubscriptionTest.java | 12 +-
.../activemq/broker/MarshallingBrokerTest.java | 0
.../apache/activemq/broker/ProgressPrinter.java | 0
.../apache/activemq/broker/RecoveryBrokerTest.java | 0
.../broker/RedeliveryRestartWithExceptionTest.java | 7 +-
.../org/apache/activemq/broker/SpringTest.java | 0
.../org/apache/activemq/broker/StubBroker.java | 6 +
.../org/apache/activemq/broker/StubConnection.java | 0
.../activemq/broker/XARecoveryBrokerTest.java | 0
.../broker/advisory/AdvisoryBrokerTest.java | 0
.../broker/advisory/AdvisoryDuringStartTest.java | 105 +++++
.../ft/DbRestartJDBCQueueMasterSlaveTest.java | 5 +-
.../broker/ft/JDBCQueueMasterSlaveTest.java | 2 +
.../activemq/broker/jmx/ConcurrentMoveTest.java | 164 +++++++
.../org/apache/activemq/broker/jmx/MBeanTest.java | 66 +++
.../broker/policy/DeadLetterExpiryTest.java | 43 ++
.../broker/policy/DeadLetterTestSupport.java | 0
.../region/cursors/AbstractStoreCursorNpeTest.java | 0
.../region/cursors/StoreQueueCursorOrderTest.java | 12 +-
.../scheduler/JobSchedulerManagementTest.java | 4 +
...chedulerRedliveryPluginDLQStoreCleanupTest.java | 220 +++++++++
.../broker/store/DefaultStoreBrokerTest.java | 0
.../store/DefaultStoreRecoveryBrokerTest.java | 0
.../apache/activemq/broker/store/LoadTester.java | 0
.../virtual/CompositeTopicMemoryUsageTest.java | 138 ++++++
.../broker/virtual/VirtualTopicWildcardTest.java | 149 ++++++
.../apache/activemq/bugs/AMQ2149LevelDBTest.java | 5 +
.../java/org/apache/activemq/bugs/AMQ2489Test.java | 0
.../java/org/apache/activemq/bugs/AMQ2910Test.java | 6 +-
.../java/org/apache/activemq/bugs/AMQ3166Test.java | 2 +
.../java/org/apache/activemq/bugs/AMQ3274Test.java | 4 +-
.../java/org/apache/activemq/bugs/AMQ3779Test.java | 10 +-
.../java/org/apache/activemq/bugs/AMQ4407Test.java | 24 +
.../java/org/apache/activemq/bugs/AMQ4952Test.java | 25 +-
.../java/org/apache/activemq/bugs/AMQ5486Test.java | 135 ++++++
.../java/org/apache/activemq/bugs/AMQ5567Test.java | 0
.../java/org/apache/activemq/bugs/AMQ6059Test.java | 403 ++++++++--------
.../java/org/apache/activemq/bugs/AMQ6459Test.java | 213 +++++++++
.../java/org/apache/activemq/bugs/AMQ6463Test.java | 148 ++++++
.../bugs/CursorMemoryHighWaterMarkTest.java | 176 +++++++
.../activemq/bugs/DuplicateFromStoreTest.java | 345 ++++++++++++++
.../apache/activemq/bugs/DurableConsumerTest.java | 0
.../bugs/JmsDurableTopicSlowReceiveTest.java | 0
.../org/apache/activemq/bugs/PfcTimeoutTest.java | 274 +++++++++++
.../activemq/bugs/RedeliveryPluginHeaderTest.java | 2 +-
.../activemq/bugs/TrapMessageInJDBCStoreTest.java | 55 +--
.../activemq/bugs/embedded/ThreadExplorer.java | 2 +-
.../activemq/command/ActiveMQBytesMessageTest.java | 0
.../activemq/command/ActiveMQDestinationTest.java | 0
.../activemq/command/ActiveMQMapMessageTest.java | 0
.../activemq/command/ActiveMQMessageTest.java | 0
.../command/ActiveMQObjectMessageTest.java | 0
.../command/ActiveMQStreamMessageTest.java | 155 +++++--
.../activemq/command/ActiveMQTextMessageTest.java | 0
.../activemq/command/DataStructureTestSupport.java | 0
.../apache/activemq/command/MessageSendTest.java | 0
.../org/apache/activemq/command/MessageTest.java | 0
.../config/BrokerXmlConfigFromJNDITest.java | 0
.../activemq/config/BrokerXmlConfigTest.java | 0
.../org/apache/activemq/config/ConfigTest.java | 0
.../org/apache/activemq/demo/SimpleConsumer.java | 0
.../org/apache/activemq/demo/SimpleProducer.java | 0
.../apache/activemq/demo/SimpleQueueReceiver.java | 0
.../apache/activemq/demo/SimpleQueueSender.java | 0
.../apache/activemq/filter/DestinationMapTest.java | 0
.../activemq/filter/DestinationPathTest.java | 0
.../org/apache/activemq/jmx/JmxAuditLogTest.java | 25 +-
.../jndi/ActiveMQInitialContextFactoryTest.java | 0
.../jndi/CustomConnectionFactoryNameTest.java | 0
.../jndi/DestinationNameWithSlashTest.java | 0
.../apache/activemq/jndi/InitialContextTest.java | 0
.../org/apache/activemq/jndi/JNDITestSupport.java | 0
.../activemq/jndi/XAConnectionFactoryTest.java | 8 +-
.../activemq/management/BoundaryStatisticTest.java | 0
.../management/BoundedRangeStatisticTest.java | 0
.../activemq/management/CountStatisticTest.java | 0
.../activemq/management/RangeStatisticTest.java | 0
.../activemq/management/StatisticTestSupport.java | 0
.../activemq/management/TimeStatisticTest.java | 0
.../network/CompressionOverNetworkTest.java | 13 +-
.../network/DemandForwardingBridgeTest.java | 0
.../apache/activemq/network/DrainBridgeTest.java | 121 +++++
.../apache/activemq/network/DuplexNetworkTest.java | 0
.../activemq/network/ForwardingBridgeTest.java | 0
.../network/NetworkReconnectSslNioTest.java | 102 ++++
.../activemq/network/NetworkRestartTest.java | 2 +
.../apache/activemq/network/NetworkRouteTest.java | 6 +-
.../activemq/network/NetworkTestSupport.java | 0
.../apache/activemq/network/SimpleNetworkTest.java | 8 +
.../activemq/network/jms/QueueBridgeTest.java | 0
.../network/jms/TopicBridgeSpringTest.java | 0
.../openwire/OpenWireConnectionTimeoutTest.java | 43 +-
...ceiveTwoConnectionsWithSenderUsingPoolTest.java | 0
.../org/apache/activemq/proxy/AMQ4889Test.java | 47 +-
.../apache/activemq/proxy/ProxyConnectorTest.java | 0
.../apache/activemq/proxy/ProxyTestSupport.java | 0
...stractCachedLDAPAuthorizationMapLegacyTest.java | 0
.../security/JaasAuthenticationBrokerTest.java | 97 ++++
...sDualAuthenticationNetworkBridgeNioSslTest.java | 14 +-
.../JaasDualAuthenticationNetworkBridgeTest.java | 8 +-
.../security/LDAPAuthorizationMapTest.java | 0
.../security/SimpleAuthenticationPluginTest.java | 5 +-
.../activemq/selector/SelectorParserTest.java | 0
.../org/apache/activemq/selector/SelectorTest.java | 0
.../org/apache/activemq/spring/ConsumerBean.java | 7 +-
.../activemq/spring/Spring2XmlNamespacesTest.java | 0
.../org/apache/activemq/spring/SpringConsumer.java | 0
.../org/apache/activemq/spring/SpringProducer.java | 0
.../org/apache/activemq/spring/SpringTest.java | 0
.../store/jdbc/JDBCCleanupLimitedPoolTest.java | 4 +
.../activemq/store/jdbc/JDBCConcurrentDLQTest.java | 210 +++++++++
.../jdbc/JDBCIOExceptionHandlerMockeryTest.java | 3 +
.../store/jdbc/JDBCIOExceptionHandlerTest.java | 96 +++-
.../store/kahadb/KahaDBPersistenceAdapterTest.java | 49 +-
.../apache/activemq/store/kahadb/KahaDBTest.java | 2 +-
.../store/kahadb/MKahaDBIndexLocationTest.java | 163 +++++++
.../store/kahadb/MKahaDBStoreLimitTest.java | 263 +++++++++++
.../activemq/test/JmsSendReceiveTestSupport.java | 0
.../activemq/test/JmsTopicSendReceiveTest.java | 0
.../JmsTopicSendReceiveWithTwoConnectionsTest.java | 0
.../RetroactiveConsumerBrokerRestartedTest.java | 167 +++++++
.../activemq/transport/QueueClusterTest.java | 0
.../activemq/transport/TopicClusterTest.java | 0
.../transport/TransportBrokerTestSupport.java | 0
.../transport/auto/AutoSslTransportBrokerTest.java | 0
.../auto/AutoTransportConnectionsTest.java | 4 +-
.../failover/FailoverAutoTransportBrokerTest.java | 0
.../discovery/DiscoveryNetworkReconnectTest.java | 3 +
.../discovery/DiscoveryTransportBrokerTest.java | 0
.../failover/FailoverTransportBrokerTest.java | 0
.../failover/FailoverXATransactionTest.java | 220 +++++++++
.../fanout/FanoutTransportBrokerTest.java | 0
.../transport/nio/NIOAsyncSendWithPFCTest.java | 327 +++++++++++++
.../activemq/transport/peer/PeerTransportTest.java | 0
.../transport/tcp/ServerSocketTstFactory.java | 0
.../activemq/transport/tcp/SocketTstFactory.java | 0
.../transport/tcp/SslBrokerServiceTest.java | 4 +-
.../transport/tcp/SslTransportBrokerTest.java | 0
.../activemq/transport/tcp/TcpFaultyTransport.java | 0
.../transport/tcp/TcpFaultyTransportFactory.java | 0
.../transport/tcp/TcpFaultyTransportServer.java | 0
.../transport/tcp/TcpTransportBrokerTest.java | 0
.../udp/UdpSendReceiveWithTwoConnectionsTest.java | 0
.../transport/vm/VMTransportBrokerTest.java | 0
.../vm/VMTransportEmbeddedBrokerTest.java | 0
.../usage/QueueMemoryAndStoreUsageCleanupTest.java | 103 +++++
.../org/apache/activemq/usage/StoreUsageTest.java | 37 +-
.../org/apache/activemq/usecases/AMQ6446Test.java | 152 ++++++
.../usecases/BacklogNetworkCrossTalkTest.java | 4 +-
.../activemq/usecases/ChangeSentMessageTest.java | 0
.../usecases/ChangeSessionDeliveryModeTest.java | 0
.../activemq/usecases/CompositeConsumeTest.java | 0
.../activemq/usecases/CompositePublishTest.java | 0
.../usecases/ConsumeQueuePrefetchTest.java | 0
.../usecases/ConsumeTopicPrefetchTest.java | 0
.../CreateTemporaryQueueBeforeStartTest.java | 0
.../activemq/usecases/DuplexAdvisoryRaceTest.java | 246 ++++++++++
.../DurableConsumerCloseAndReconnectTcpTest.java | 0
.../DurableConsumerCloseAndReconnectTest.java | 0
.../activemq/usecases/DurableSubCacheTest.java | 197 ++++++++
.../usecases/DurableSubscriptionTestSupport.java | 0
.../activemq/usecases/ExceptionListenerTest.java | 0
.../activemq/usecases/ExpiredMessagesTest.java | 266 +++++++----
.../usecases/JDBCDurableSubscriptionTest.java | 0
.../usecases/JournalDurableSubscriptionTest.java | 0
.../usecases/LevelDBDurableSubscriptionTest.java | 0
.../usecases/ProducerConsumerTestSupport.java | 0
.../PublishOnDurableTopicConsumedMessageTest.java | 0
.../PublishOnQueueConsumedMessageTest.java | 0
...PublishOnTemporaryQueueConsumedMessageTest.java | 0
.../PublishOnTopicConsumedMessageTest.java | 0
.../QueueConsumerCloseAndReconnectTest.java | 0
.../activemq/usecases/QueueDuplicatesTest.java | 0
.../activemq/usecases/QueueRedeliverTest.java | 0
.../activemq/usecases/QueueRepeaterTest.java | 0
.../activemq/usecases/ReliableReconnectTest.java | 0
...VirtualDestinationsWithWildcardLevelDBTest.java | 15 +-
...eBrokerVirtualDestinationsWithWildcardTest.java | 4 +-
.../usecases/StartAndConcurrentStopBrokerTest.java | 0
.../activemq/usecases/StartAndStopBrokerTest.java | 0
.../SubscribeClosePublishThenConsumeTest.java | 0
.../org/apache/activemq/usecases/TestSupport.java | 0
.../usecases/TopicProducerFlowControlTest.java | 97 ++--
.../activemq/usecases/TopicRedeliverTest.java | 0
.../TopicSubscriptionZeroPrefetchTest.java | 4 +-
.../apache/activemq/usecases/TransactionTest.java | 0
.../usecases/TransientQueueRedeliverTest.java | 0
.../java/org/apache/activemq/util/LargeFile.java | 35 +-
.../activemq/util/ReflectionSupportTest.java | 0
.../java/org/apache/activemq/util/SimplePojo.java | 0
.../activemq/xbean/ConnectorXBeanConfigTest.java | 2 +
.../org/apache/activemq/xbean/XBeanXmlTest.java | 0
.../src/test/resources/activemq-partition.xml | 0
.../src/test/resources/activemq.xml | 0
.../src/test/resources/client.keystore | Bin 2197 -> 684 bytes
.../src/test/resources/handleReplyToActivemq.xml | 8 +-
.../src/test/resources/jndi.properties | 0
.../src/test/resources/log4j.properties | 1 +
.../apache/activemq/broker/ft/sharedFileMaster.xml | 0
.../apache/activemq/broker/ft/sharedFileSlave.xml | 0
.../apache/activemq/broker/store/kahabroker.xml | 0
.../apache/activemq/broker/store/loadtester.xml | 0
.../org/apache/activemq/config/config.xml | 0
.../org/apache/activemq/config/example.xml | 0
.../org/apache/activemq/config/spring-test.xml | 0
.../JaasDualAuthenticationNetworkBridge.xml | 4 +-
... JaasDualAuthenticationNetworkBridgeNioSsl.xml} | 6 +-
.../security/LDAPAuthorizationMap.properties | 0
.../apache/activemq/transport/tcp/activemq-ssl.xml | 0
.../activemq/usecases/receiver-activecluster.xml | 0
.../apache/activemq/usecases/receiver-secured.xml | 0
.../apache/activemq/usecases/receiver-zeroconf.xml | 0
.../org/apache/activemq/usecases/receiver.xml | 0
.../activemq/usecases/sender-activecluster.xml | 0
.../apache/activemq/usecases/sender-secured.xml | 0
.../apache/activemq/usecases/sender-zeroconf.xml | 0
.../org/apache/activemq/usecases/sender.xml | 0
.../org/apache/activemq/xbean/connector-test.xml | 16 +-
.../src/test/resources/server.keystore | Bin 2197 -> 1389 bytes
.../resources/spring-embedded-xbean-noversion.xml | 0
.../src/test/resources/spring-embedded-xbean.xml | 0
.../src/test/resources/spring-embedded.xml | 0
.../src/test/resources/spring-jndi.xml | 0
.../src/test/resources/spring-queue.xml | 0
activemq-unit-tests/src/test/resources/spring.xml | 0
...-JaasDualAuthenticationNetworkBridge.properties | 2 +-
activemq-web-console/pom.xml | 2 +-
.../src/main/resources/log4j.properties | 0
.../src/main/webapp/WEB-INF/activemq.xml | 6 +-
.../src/main/webapp/WEB-INF/web.xml | 0
activemq-web-console/src/main/webapp/browse.jsp | 2 +-
.../src/main/webapp/connection.jsp | 2 +-
.../src/main/webapp/connections.jsp | 2 +-
activemq-web-console/src/main/webapp/graph.jsp | 2 +-
activemq-web-console/src/main/webapp/index.jsp | 2 +-
activemq-web-console/src/main/webapp/message.jsp | 2 +-
activemq-web-console/src/main/webapp/network.jsp | 2 +-
.../src/main/webapp/queueConsumers.jsp | 2 +-
.../src/main/webapp/queueGraph.jsp | 2 +-
.../src/main/webapp/queueProducers.jsp | 2 +-
activemq-web-console/src/main/webapp/queues.jsp | 22 +-
activemq-web-console/src/main/webapp/scheduled.jsp | 2 +-
activemq-web-console/src/main/webapp/send.jsp | 2 +-
activemq-web-console/src/main/webapp/slave.jsp | 2 +-
.../src/main/webapp/subscribers.jsp | 2 +-
.../src/main/webapp/topicProducers.jsp | 2 +-
.../src/main/webapp/topicSubscribers.jsp | 2 +-
activemq-web-console/src/main/webapp/topics.jsp | 2 +-
.../src/main/webapp/xml/queues.jsp | 2 +
.../src/main/webapp/xml/subscribers.jsp | 2 +
.../src/main/webapp/xml/topics.jsp | 2 +
activemq-web-demo/pom.xml | 2 +-
.../src/main/resources/log4j.properties | 0
activemq-web-demo/src/main/webapp/WEB-INF/web.xml | 0
.../src/test/resources/log4j.properties | 0
activemq-web/pom.xml | 2 +-
.../org/apache/activemq/web/MessageServlet.java | 65 ++-
.../java/org/apache/activemq/web/WebClient.java | 29 +-
.../apache/activemq/web/RemoteJMXBrokerTest.java | 2 +
assembly/pom.xml | 14 +-
assembly/src/main/descriptors/common-bin.xml | 1 -
assembly/src/release/conf/activemq.xml | 0
assembly/src/release/conf/log4j.properties | 10 +-
.../examples/openwire/advanced-scenarios/pom.xml | 0
.../release/examples/openwire/swissarmy/build.xml | 0
.../openwire/swissarmy/src/ConsumerTool.java | 0
.../openwire/swissarmy/src/ProducerTool.java | 0
.../activemq/benchmark/BenchmarkSupport.java | 0
.../org/apache/activemq/benchmark/Consumer.java | 0
.../org/apache/activemq/benchmark/Producer.java | 0
.../activemq/benchmark/ProducerConsumer.java | 0
.../activemq/config/BrokerXmlConfigStartTest.java | 0
.../activemq/config/ValidateXMLConfigTest.java | 0
assembly/src/test/resources/log4j.properties | 0
docs/img/README.md | 127 +++++
pom.xml | 154 +++---
trash/activemq-optional/pom.xml | 0
.../activemq/benchmark/BenchmarkSupport.java | 0
.../org/apache/activemq/benchmark/Consumer.java | 0
.../org/apache/activemq/benchmark/Producer.java | 0
.../activemq/benchmark/ProducerConsumer.java | 0
.../org/apache/activemq/tool/AcidTestTool.java | 0
.../org/apache/activemq/tool/ConsumerTool.java | 0
.../org/apache/activemq/tool/JndiProducerTool.java | 0
.../org/apache/activemq/tool/ProducerTool.java | 0
.../java/org/apache/activemq/tool/ToolSupport.java | 0
.../java/org/apache/activemq/tool/WebServer.java | 0
1102 files changed, 14688 insertions(+), 4792 deletions(-)
--
Alioth's /usr/local/bin/git-commit-notice on
/srv/git.debian.org/git/pkg-java/activemq.git
_______________________________________________
pkg-java-commits mailing list
pkg-java-comm...@lists.alioth.debian.org
http://lists.alioth.debian.org/cgi-bin/mailman/listinfo/pkg-java-commits
