Repository: activemq-artemis Updated Branches: refs/heads/master 56e1df3c3 -> 4883b0360
This closes #1832 Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/4883b036 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/4883b036 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/4883b036 Branch: refs/heads/master Commit: 4883b0360ed54e950d4cda9fcfd8c5be3cf88cc6 Parents: 56e1df3 38c45c9 Author: Michael Andre Pearce <michael.andre.pea...@me.com> Authored: Wed Feb 7 15:27:29 2018 +0000 Committer: Michael Andre Pearce <michael.andre.pea...@me.com> Committed: Wed Feb 7 15:27:29 2018 +0000 ---------------------------------------------------------------------- .../artemis/api/core/ParameterisedAddress.java | 98 ++++++ .../artemis/api/core/QueueAttributes.java | 79 +++++ .../activemq/artemis/utils/uri/URISupport.java | 32 +- .../config/ActiveMQDefaultConfiguration.java | 12 + .../artemis/api/core/client/ClientSession.java | 77 +++++ .../core/management/ActiveMQServerControl.java | 16 + .../api/core/management/QueueControl.java | 12 + .../core/client/impl/AddressQueryImpl.java | 20 +- .../core/client/impl/ClientSessionImpl.java | 96 +++++- .../core/client/impl/QueueQueryImpl.java | 33 ++ .../core/impl/ActiveMQSessionContext.java | 45 ++- .../impl/wireformat/CreateQueueMessage_V2.java | 41 ++- .../wireformat/CreateSharedQueueMessage_V2.java | 75 ++++- .../SessionBindingQueryResponseMessage_V4.java | 35 +- .../SessionQueueQueryResponseMessage_V3.java | 49 ++- .../artemis/core/server/QueueQueryResult.java | 20 +- .../spi/core/remoting/SessionContext.java | 25 ++ .../artemis/jms/client/ActiveMQDestination.java | 28 +- .../jms/client/ActiveMQMessageProducer.java | 26 +- .../artemis/jms/client/ActiveMQSession.java | 88 ++++- .../jms/client/ActiveMQParameterTest.java | 63 ++++ .../client/HornetQClientSessionContext.java | 2 +- .../core/config/CoreQueueConfiguration.java | 36 +++ .../deployers/impl/FileConfigurationParser.java | 19 +- .../impl/ActiveMQServerControlImpl.java | 15 +- .../core/management/impl/QueueControlImpl.java | 24 ++ .../core/management/impl/view/QueueView.java | 8 +- .../view/predicate/QueueFilterPredicate.java | 6 +- .../core/persistence/QueueBindingInfo.java | 4 + .../journal/AbstractJournalStorageManager.java | 2 +- .../codec/PersistentQueueBindingEncoding.java | 26 +- .../artemis/core/postoffice/PostOffice.java | 3 +- .../core/postoffice/impl/PostOfficeImpl.java | 7 +- .../core/ServerSessionPacketHandler.java | 8 +- .../artemis/core/server/ActiveMQServer.java | 17 + .../artemis/core/server/BindingQueryResult.java | 20 +- .../activemq/artemis/core/server/Queue.java | 6 + .../artemis/core/server/QueueConfig.java | 39 ++- .../artemis/core/server/ServerSession.java | 31 ++ .../core/server/impl/ActiveMQServerImpl.java | 78 ++++- .../core/server/impl/LastValueQueue.java | 8 +- .../server/impl/PostOfficeJournalLoader.java | 1 + .../core/server/impl/QueueFactoryImpl.java | 11 +- .../artemis/core/server/impl/QueueImpl.java | 50 ++- .../core/server/impl/ServerSessionImpl.java | 71 ++++- .../core/settings/impl/AddressSettings.java | 60 +++- .../resources/schema/artemis-configuration.xsd | 22 +- .../impl/ScheduledDeliveryHandlerTest.java | 15 + .../test/resources/artemis-configuration.xsd | 23 +- .../tests/integration/amqp/JMSLVQTest.java | 2 +- .../client/MultipleProducersTest.java | 2 +- .../client/SessionCreateAndDeleteQueueTest.java | 2 +- .../integration/client/UpdateQueueTest.java | 2 +- .../integration/jms/client/ExclusiveTest.java | 319 +++++++++++++++++++ .../tests/integration/jms/client/LVQTest.java | 145 +++++++++ .../ActiveMQServerControlUsingCoreTest.java | 10 + .../management/QueueControlUsingCoreTest.java | 10 + .../integration/server/LVQRecoveryTest.java | 4 +- .../tests/integration/server/LVQTest.java | 2 +- .../jms/tests/message/MessageHeaderTest.java | 27 ++ .../unit/core/postoffice/impl/FakeQueue.java | 17 + .../core/server/impl/fakes/FakePostOffice.java | 3 +- 62 files changed, 1988 insertions(+), 139 deletions(-) ----------------------------------------------------------------------
