This closes #1008
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/c0c48592 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/c0c48592 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/c0c48592 Branch: refs/heads/master Commit: c0c4859215468a11a38660cdae76cb6168ce99ea Parents: 2cf594a 150a591 Author: Clebert Suconic <[email protected]> Authored: Mon Feb 13 12:02:30 2017 -0500 Committer: Clebert Suconic <[email protected]> Committed: Mon Feb 13 12:02:30 2017 -0500 ---------------------------------------------------------------------- .../cli/commands/tools/XmlDataExporter.java | 2 +- .../cli/commands/tools/XmlDataImporter.java | 2 +- .../artemis/integration/FileBroker.java | 2 +- .../activemq/artemis/api/core/RoutingType.java | 44 ++++++++++++++++++++ .../config/ActiveMQDefaultConfiguration.java | 2 +- .../artemis/api/core/client/ClientSession.java | 2 +- .../api/core/management/AddressControl.java | 2 +- .../api/core/management/ObjectNameBuilder.java | 2 +- .../core/client/impl/ClientSessionImpl.java | 2 +- .../core/client/impl/QueueQueryImpl.java | 2 +- .../core/impl/ActiveMQSessionContext.java | 2 +- .../impl/wireformat/CreateAddressMessage.java | 2 +- .../impl/wireformat/CreateQueueMessage_V2.java | 2 +- .../wireformat/CreateSharedQueueMessage_V2.java | 2 +- .../SessionQueueQueryResponseMessage_V3.java | 2 +- .../artemis/core/server/AddressQueryResult.java | 1 + .../artemis/core/server/QueueQueryResult.java | 1 + .../artemis/core/server/RoutingType.java | 44 -------------------- .../spi/core/remoting/SessionContext.java | 2 +- .../activemq/artemis/utils/PrefixUtil.java | 2 +- .../artemis/jms/client/ActiveMQMessage.java | 2 +- .../jms/client/ActiveMQMessageProducer.java | 2 +- .../artemis/jms/client/ActiveMQSession.java | 2 +- .../jms/server/impl/JMSServerManagerImpl.java | 2 +- .../artemis/junit/ActiveMQConsumerResource.java | 2 +- .../artemis/junit/EmbeddedActiveMQResource.java | 2 +- .../amqp/broker/AMQPSessionCallback.java | 2 +- .../amqp/broker/ProtonProtocolManager.java | 2 +- .../proton/ProtonServerReceiverContext.java | 2 +- .../amqp/proton/ProtonServerSenderContext.java | 2 +- .../core/protocol/mqtt/MQTTProtocolHandler.java | 2 +- .../protocol/mqtt/MQTTSubscriptionManager.java | 2 +- .../protocol/openwire/OpenWireConnection.java | 2 +- .../openwire/OpenWireProtocolManager.java | 2 +- .../core/protocol/openwire/amq/AMQConsumer.java | 2 +- .../core/protocol/openwire/amq/AMQSession.java | 2 +- .../core/protocol/stomp/StompConnection.java | 2 +- .../core/protocol/stomp/StompSession.java | 2 +- .../stomp/VersionedStompFrameHandler.java | 2 +- .../artemis/rest/queue/QueueServiceManager.java | 2 +- .../rest/topic/TopicDestinationsResource.java | 2 +- .../artemis/rest/topic/TopicServiceManager.java | 2 +- .../artemis/rest/test/FindDestinationTest.java | 2 +- .../activemq/artemis/rest/test/RawAckTest.java | 2 +- .../core/config/CoreAddressConfiguration.java | 2 +- .../core/config/CoreQueueConfiguration.java | 2 +- .../artemis/core/config/impl/Validators.java | 2 +- .../deployers/impl/FileConfigurationParser.java | 2 +- .../impl/ActiveMQServerControlImpl.java | 2 +- .../management/impl/AddressControlImpl.java | 2 +- .../core/persistence/AddressBindingInfo.java | 2 +- .../codec/PersistentAddressBindingEncoding.java | 2 +- .../artemis/core/postoffice/AddressManager.java | 2 +- .../artemis/core/postoffice/PostOffice.java | 2 +- .../core/postoffice/impl/LocalQueueBinding.java | 2 +- .../core/postoffice/impl/PostOfficeImpl.java | 2 +- .../postoffice/impl/SimpleAddressManager.java | 2 +- .../core/ServerSessionPacketHandler.java | 2 +- .../core/impl/ActiveMQPacketHandler.java | 2 +- .../protocol/core/impl/CoreProtocolManager.java | 2 +- .../core/server/ActiveMQMessageBundle.java | 1 + .../artemis/core/server/ActiveMQServer.java | 1 + .../activemq/artemis/core/server/Queue.java | 1 + .../artemis/core/server/QueueConfig.java | 1 + .../artemis/core/server/RoutingContext.java | 1 + .../artemis/core/server/ServerSession.java | 9 ++-- .../cluster/impl/ClusterConnectionImpl.java | 2 +- .../core/server/impl/ActiveMQServerImpl.java | 2 +- .../artemis/core/server/impl/AddressInfo.java | 2 +- .../artemis/core/server/impl/DivertImpl.java | 2 +- .../core/server/impl/LastValueQueue.java | 2 +- .../server/impl/PostOfficeJournalLoader.java | 2 +- .../artemis/core/server/impl/QueueImpl.java | 2 +- .../core/server/impl/RoutingContextImpl.java | 2 +- .../core/server/impl/ServerSessionImpl.java | 2 +- .../server/management/ManagementService.java | 2 +- .../management/impl/ManagementServiceImpl.java | 2 +- .../core/settings/impl/AddressSettings.java | 2 +- .../core/protocol/AbstractProtocolManager.java | 2 +- .../spi/core/protocol/ProtocolManager.java | 2 +- .../core/config/impl/FileConfigurationTest.java | 2 +- .../core/message/impl/MessagePropertyTest.java | 2 +- .../group/impl/ClusteredResetMockTest.java | 2 +- .../impl/ScheduledDeliveryHandlerTest.java | 2 +- .../artemis/jms/example/JMXExample.java | 4 +- .../jms/example/MessageCounterExample.java | 4 +- .../artemiswrapper/ArtemisBrokerWrapper.java | 2 +- .../org/apache/activemq/JMSConsumerTest.java | 2 +- .../tests/extras/byteman/PagingLeakTest.java | 2 +- .../tests/extras/byteman/TimeoutXATest.java | 2 +- .../artemis/tests/integration/SimpleTest.java | 2 +- .../integration/SingleServerSimpleTest.java | 2 +- .../addressing/AddressConfigTest.java | 2 +- .../integration/addressing/AddressingTest.java | 2 +- .../integration/addressing/AnycastTest.java | 2 +- .../integration/addressing/MulticastTest.java | 2 +- .../integration/amqp/AmqpClientTestSupport.java | 2 +- .../amqp/AmqpDurableReceiverTest.java | 2 +- .../integration/amqp/AmqpSecurityTest.java | 2 +- .../integration/amqp/AmqpSendReceiveTest.java | 2 +- .../amqp/BrokerDefinedAnycastConsumerTest.java | 2 +- .../BrokerDefinedMulticastConsumerTest.java | 2 +- .../amqp/ClientDefinedMultiConsumerTest.java | 2 +- .../integration/amqp/ProtonPubSubTest.java | 2 +- .../tests/integration/amqp/ProtonTest.java | 2 +- .../integration/cli/AddressCommandTest.java | 2 +- .../tests/integration/cli/QueueCommandTest.java | 2 +- .../client/AutoDeleteAddressTest.java | 2 +- .../integration/client/AutoDeleteQueueTest.java | 2 +- .../integration/client/BlockingSendTest.java | 2 +- .../ConcurrentCreateDeleteProduceTest.java | 2 +- .../integration/client/ConsumerFilterTest.java | 2 +- .../integration/client/CreateQueueTest.java | 2 +- .../client/ExpiryLargeMessageTest.java | 2 +- .../integration/client/HangConsumerTest.java | 2 +- .../InVMNonPersistentMessageBufferTest.java | 2 +- .../client/InterruptedLargeMessageTest.java | 2 +- .../client/JmsNettyNioStressTest.java | 2 +- .../integration/client/MessageBufferTest.java | 2 +- .../tests/integration/client/NIOvsOIOTest.java | 2 +- .../tests/integration/client/ProducerTest.java | 2 +- .../tests/integration/client/ReceiveTest.java | 2 +- .../tests/integration/client/RoutingTest.java | 2 +- ...onClosedOnRemotingConnectionFailureTest.java | 2 +- .../client/SimpleSendMultipleQueuesTest.java | 2 +- .../integration/client/SlowConsumerTest.java | 2 +- .../integration/client/TemporaryQueueTest.java | 2 +- .../clientcrash/PendingDeliveriesTest.java | 2 +- .../integration/cluster/bridge/BridgeTest.java | 2 +- .../AnycastRoutingWithClusterTest.java | 2 +- .../cluster/distribution/ClusterTestBase.java | 2 +- .../ExpireWhileLoadBalanceTest.java | 2 +- .../cluster/failover/BackupSyncJournalTest.java | 2 +- .../cluster/failover/FailoverTest.java | 2 +- .../ReplicatedMultipleServerFailoverTest.java | 2 +- .../cluster/reattach/OrderReattachTest.java | 2 +- .../cluster/reattach/ReattachTest.java | 2 +- .../topology/TopologyClusterTestBase.java | 2 +- .../crossprotocol/AMQPToOpenwireTest.java | 2 +- .../crossprotocol/OpenWireToAMQPTest.java | 2 +- .../tests/integration/divert/DivertTest.java | 2 +- .../divert/ReplicationWithDivertTest.java | 2 +- .../interceptors/InterceptorTest.java | 2 +- .../jms/ActiveMQConnectionFactoryTest.java | 2 +- .../tests/integration/jms/JmsProducerTest.java | 2 +- .../jms/cluster/JMSFailoverListenerTest.java | 2 +- .../jms/cluster/JMSFailoverTest.java | 2 +- .../jms/cluster/JMSReconnectTest.java | 2 +- .../largemessage/ServerLargeMessageTest.java | 2 +- .../management/ActiveMQServerControlTest.java | 2 +- .../management/ManagementControlHelper.java | 2 +- .../management/QueueControlTest.java | 2 +- .../integration/mqtt/imported/MQTTTest.java | 2 +- .../integration/openwire/BasicOpenWireTest.java | 2 +- .../openwire/SimpleOpenWireTest.java | 2 +- .../openwire/VerySimpleOenwireTest.java | 2 +- .../integration/paging/PagingCounterTest.java | 2 +- .../integration/paging/PagingOrderTest.java | 2 +- .../integration/paging/PagingReceiveTest.java | 2 +- .../integration/paging/PagingSyncTest.java | 2 +- .../tests/integration/paging/PagingTest.java | 2 +- .../PagingWithFailoverAndCountersTest.java | 2 +- .../persistence/XmlImportExportTest.java | 2 +- .../integration/remoting/BatchDelayTest.java | 2 +- .../integration/remoting/DirectDeliverTest.java | 2 +- .../rest/RestDeserializationTest.java | 2 +- .../integration/security/LDAPSecurityTest.java | 2 +- ...cyLDAPSecuritySettingPluginListenerTest.java | 2 +- .../LegacyLDAPSecuritySettingPluginTest.java | 2 +- .../integration/security/SecurityTest.java | 2 +- .../integration/server/ExpiryRunnerTest.java | 2 +- .../server/GracefulShutdownTest.java | 2 +- .../server/QueuePeristPauseTest.java | 2 +- .../integration/server/ResourceLimitTest.java | 2 +- .../ssl/CoreClientOverOneWaySSLTest.java | 2 +- .../tests/integration/stomp/StompTest.java | 2 +- .../tests/integration/stomp/StompTestBase.java | 2 +- .../integration/stomp/v11/StompV11Test.java | 2 +- .../integration/stomp/v12/StompV12Test.java | 2 +- .../tests/integration/xa/BasicXaTest.java | 2 +- .../tests/integration/xa/XaTimeoutTest.java | 2 +- .../artemis/jms/tests/MessageProducerTest.java | 2 +- .../jms/tests/message/MessageHeaderTest.java | 2 +- .../activemq/artemis/common/AbstractAdmin.java | 2 +- .../storage/SendReceiveMultiThreadTest.java | 2 +- .../tests/stress/client/SendStressTest.java | 2 +- .../journal/JournalRestartStressTest.java | 2 +- .../paging/MultipleConsumersPageStressTest.java | 2 +- .../stress/paging/PageCursorStressTest.java | 2 +- .../jms/bridge/impl/JMSBridgeImplTest.java | 2 +- .../unit/core/postoffice/impl/FakeQueue.java | 2 +- .../core/server/impl/fakes/FakePostOffice.java | 2 +- 192 files changed, 242 insertions(+), 230 deletions(-) ----------------------------------------------------------------------
