You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2016/06/13 18:21:28 UTC
[7/7] activemq-artemis git commit: This closes #578
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 <cl...@apache.org>
Authored: Mon Jun 13 14:17:16 2016 -0400
Committer: Clebert Suconic <cl...@apache.org>
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(-)
----------------------------------------------------------------------