Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 3B991200B2B for ; Mon, 13 Jun 2016 20:21:24 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 3A26C160A3C; Mon, 13 Jun 2016 18:21:24 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 6252A160A61 for ; Mon, 13 Jun 2016 20:21:23 +0200 (CEST) Received: (qmail 41410 invoked by uid 500); 13 Jun 2016 18:21:22 -0000 Mailing-List: contact commits-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list commits@activemq.apache.org Received: (qmail 41271 invoked by uid 99); 13 Jun 2016 18:21:22 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 13 Jun 2016 18:21:22 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 5CCEFDFB74; Mon, 13 Jun 2016 18:21:22 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: clebertsuconic@apache.org To: commits@activemq.apache.org Date: Mon, 13 Jun 2016 18:21:28 -0000 Message-Id: <5265c519bf514234b57c16e8513aa382@git.apache.org> In-Reply-To: <5ddced850418467e9f280e96de0cbb30@git.apache.org> References: <5ddced850418467e9f280e96de0cbb30@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [7/7] activemq-artemis git commit: This closes #578 archived-at: Mon, 13 Jun 2016 18:21:24 -0000 This closes #578 Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/369f2e00 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/369f2e00 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/369f2e00 Branch: refs/heads/master Commit: 369f2e0063e69934ba23b0ba7e8f89f09e581f53 Parents: a624a81 3923ae4 Author: Clebert Suconic Authored: Mon Jun 13 14:17:16 2016 -0400 Committer: Clebert Suconic Committed: Mon Jun 13 14:17:16 2016 -0400 ---------------------------------------------------------------------- .../artemis/cli/commands/tools/PrintData.java | 2 +- .../cli/commands/tools/XmlDataExporter.java | 2 +- .../cli/commands/tools/XmlDataImporter.java | 3 +- .../core/buffers/impl/ChannelBufferWrapper.java | 4 +- .../apache/activemq/artemis/utils/Base64.java | 3 +- .../activemq/artemis/utils/ReusableLatch.java | 2 +- .../activemq/artemis/utils/TypedProperties.java | 42 ++++++++++---------- .../api/core/UDPBroadcastEndpointFactory.java | 2 +- .../core/management/CoreNotificationType.java | 2 +- .../core/client/impl/ClientMessageImpl.java | 2 +- .../core/client/impl/ClientSessionImpl.java | 6 +-- .../CompressedLargeMessageControllerImpl.java | 2 +- .../client/impl/LargeMessageControllerImpl.java | 9 ++--- .../core/client/impl/ServerLocatorImpl.java | 2 +- .../artemis/core/message/impl/MessageImpl.java | 2 +- .../remoting/impl/netty/NettyConnector.java | 4 +- .../artemis/utils/OrderedExecutorFactory.java | 2 +- .../artemis/utils/SoftValueHashMap.java | 2 +- .../apache/activemq/artemis/dto/XmlUtil.java | 2 +- .../jdbc/store/journal/TransactionHolder.java | 2 +- .../file/JDBCSequentialFileFactoryTest.java | 2 +- .../artemis/jms/client/ActiveMQJMSConsumer.java | 2 +- .../artemis/jms/client/ActiveMQJMSProducer.java | 2 +- .../jms/client/ActiveMQMessageProducer.java | 6 +-- .../artemis/jms/bridge/impl/JMSBridgeImpl.java | 4 +- .../server/management/JMSNotificationType.java | 2 +- .../core/io/aio/AIOSequentialFileFactory.java | 2 +- .../artemis/core/journal/impl/JournalBase.java | 2 +- .../core/journal/impl/JournalCompactor.java | 8 ++-- .../artemis/core/journal/impl/JournalImpl.java | 2 +- .../artemis/jlibaio/test/LibaioTest.java | 2 +- .../core/protocol/mqtt/MQTTProtocolManager.java | 2 +- .../org/proton/plug/util/CreditsSemaphore.java | 2 +- .../org/proton/plug/util/ReusableLatch.java | 2 +- .../context/AbstractConnectionContextTest.java | 2 +- .../plug/test/minimalserver/MinimalServer.java | 2 +- .../protocol/stomp/ActiveMQStompException.java | 2 +- .../protocol/stomp/StompProtocolManager.java | 8 ++-- .../core/protocol/stomp/StompVersions.java | 2 +- .../stomp/v11/StompFrameHandlerV11.java | 2 +- .../activemq/artemis/ra/ActiveMQRALogger.java | 2 +- .../artemis/rest/test/AutoAckTopicTest.java | 4 +- .../selector/filter/ComparisonExpression.java | 2 +- .../selector/filter/ConstantExpression.java | 2 +- .../selector/filter/UnaryExpression.java | 2 +- .../artemis/osgi/ProtocolTrackerTest.java | 2 +- .../core/config/HAPolicyConfiguration.java | 2 +- .../artemis/core/config/StoreConfiguration.java | 2 +- .../artemis/core/filter/impl/FilterImpl.java | 2 +- .../core/paging/cursor/impl/PageCacheImpl.java | 2 +- .../impl/PageSubscriptionCounterImpl.java | 2 +- .../cursor/impl/PageSubscriptionImpl.java | 4 +- .../paging/impl/PageTransactionInfoImpl.java | 4 +- .../core/paging/impl/PagingStoreImpl.java | 6 +-- .../core/persistence/StorageManager.java | 2 +- .../nullpm/NullStorageLargeServerMessage.java | 4 +- .../artemis/core/protocol/ProtocolHandler.java | 2 +- .../protocol/core/impl/CoreProtocolManager.java | 10 ++--- .../BackupReplicationStartFailedMessage.java | 2 +- .../ReplicationLiveIsStoppingMessage.java | 2 +- .../wireformat/ReplicationStartSyncMessage.java | 2 +- .../wireformat/ReplicationSyncFileMessage.java | 2 +- .../impl/netty/HttpAcceptorHandler.java | 6 +-- .../core/server/cluster/BackupManager.java | 28 ++++++------- .../core/server/cluster/ClusterController.java | 10 ++--- .../core/server/cluster/impl/BridgeImpl.java | 4 +- .../cluster/impl/ClusterConnectionImpl.java | 16 ++++---- .../server/cluster/qourum/QuorumManager.java | 4 +- .../server/impl/BackupTopologyListener.java | 2 +- .../core/server/impl/ColocatedActivation.java | 6 +-- .../artemis/core/server/impl/QueueImpl.java | 6 +-- .../core/server/impl/ReplicationError.java | 2 +- .../impl/ScheduledDeliveryHandlerImpl.java | 2 +- .../core/server/impl/ServerConsumerImpl.java | 2 +- .../impl/SharedNothingLiveActivation.java | 2 +- .../artemis/core/transaction/Transaction.java | 2 +- .../transaction/impl/ResourceManagerImpl.java | 2 +- .../jaas/PropertiesLoginModuleTest.java | 2 +- .../cluster/impl/BroadcastGroupImplTest.java | 2 +- .../impl/ScheduledDeliveryHandlerTest.java | 2 +- .../artemis/core/settings/RepositoryTest.java | 2 +- .../artemis/tests/util/ActiveMQTestBase.java | 2 +- .../cli/test/WebServerComponentTest.java | 2 +- .../activemq/artemis/jms/example/PerfBase.java | 2 +- .../jms/example/MessageGroupExample.java | 2 +- .../jms/example/MessageGroup2Example.java | 2 +- .../jms/example/MessagePriorityExample.java | 2 +- .../jms/example/QueueSelectorExample.java | 2 +- .../jms/example/StaticSelectorExample.java | 2 +- .../jms/example/TopicSelectorExample2.java | 2 +- .../artemis/jms/example/XASendExample.java | 2 +- .../aerogear/AeroGearConnectorService.java | 2 +- pom.xml | 2 +- tests/activemq5-unit-tests/pom.xml | 2 +- .../HierarchicalObjectRepositoryTest.java | 2 +- .../aerogear/AeroGearBasicServerTest.java | 2 +- .../integration/client/AutogroupIdTest.java | 2 +- .../integration/client/CommitRollbackTest.java | 2 +- .../client/DeadLetterAddressTest.java | 2 +- .../integration/client/DeliveryOrderTest.java | 2 +- .../integration/client/HangConsumerTest.java | 42 ++++++++++---------- .../client/InterruptedLargeMessageTest.java | 38 +++++++++--------- .../client/MessageConsumerRollbackTest.java | 2 +- .../MessageGroupingConnectionFactoryTest.java | 2 +- .../integration/client/MessageGroupingTest.java | 2 +- .../integration/client/MessageHandlerTest.java | 6 +-- .../client/MultipleThreadFilterOneTest.java | 4 +- .../tests/integration/client/PagingTest.java | 10 ++--- .../client/ServerLocatorConnectTest.java | 2 +- .../client/SessionStopStartTest.java | 8 ++-- .../integration/client/TemporaryQueueTest.java | 2 +- .../integration/cluster/NodeManagerTest.java | 2 +- .../distribution/ClusteredGroupingTest.java | 12 +++--- .../cluster/failover/FailBackManualTest.java | 2 +- .../cluster/failover/QuorumFailOverTest.java | 2 +- .../MultiThreadReattachSupportTestBase.java | 2 +- .../cluster/reattach/RandomReattachTest.java | 2 +- .../jms/client/NewQueueRequestorTest.java | 2 +- .../jms/connection/ExceptionListenerTest.java | 2 +- .../jms/jms2client/JmsContextTest.java | 6 +-- .../server/management/JMSServerControlTest.java | 2 +- .../journal/ValidateTransactionHealthTest.java | 10 ++--- .../ManagementWithPagingServerTest.java | 6 +-- .../openwire/amq/JMSConsumer2Test.java | 2 +- .../amq/MessageListenerRedeliveryTest.java | 2 +- .../PagingWithFailoverAndCountersTest.java | 6 +-- .../ra/ActiveMQMessageHandlerTest.java | 4 +- .../ra/ActiveMQMessageHandlerXATest.java | 4 +- .../integration/server/ExpiryRunnerTest.java | 2 +- .../stomp/StompOverWebsocketTest.java | 2 +- .../stomp/util/AbstractClientStompFrame.java | 2 +- .../util/AbstractStompClientConnection.java | 2 +- .../tests/integration/xa/BasicXaTest.java | 2 +- .../tests/integration/xa/XaTimeoutTest.java | 2 +- .../jms/tests/AutoAckMesageListenerTest.java | 2 +- .../artemis/jms/tests/MessageConsumerTest.java | 30 +++++++------- .../artemis/jms/tests/MessageProducerTest.java | 6 +-- .../artemis/jms/tests/MiscellaneousTest.java | 2 +- .../jms/tests/TransactedSessionTest.java | 2 +- .../jms/tests/message/MessageHeaderTest.java | 2 +- .../paging/MeasurePagingMultiThreadTest.java | 2 +- .../sends/AbstractSendReceivePerfTest.java | 4 +- .../JournalCleanupCompactStressTest.java | 6 +-- .../tests/stress/remote/PingStressTest.java | 2 +- .../jms/bridge/impl/JMSBridgeImplTest.java | 2 +- .../MultiThreadAsynchronousFileTest.java | 8 ++-- .../core/paging/impl/PagingStoreImplTest.java | 8 ++-- .../impl/WildcardAddressManagerUnitTest.java | 4 +- .../tests/unit/core/remoting/AcceptorsTest.java | 3 +- .../unit/core/server/impl/QueueImplTest.java | 8 ++-- 150 files changed, 321 insertions(+), 327 deletions(-) ----------------------------------------------------------------------