This is an automated email from the ASF dual-hosted git repository. clebertsuconic pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
commit 2fc78038bd664e306e6ba24365cf90742853fa73 Merge: 6c5e90a 98b3177 Author: Clebert Suconic <[email protected]> AuthorDate: Tue Apr 16 15:43:16 2019 -0400 This closes #2619 .../activemq/artemis/api/core/QueueAttributes.java | 13 ++ .../api/config/ActiveMQDefaultConfiguration.java | 6 + .../artemis/api/core/client/ClientSession.java | 2 + .../api/core/management/ActiveMQServerControl.java | 74 ++++++++ .../artemis/core/client/impl/QueueQueryImpl.java | 37 ++++ .../protocol/core/impl/ActiveMQSessionContext.java | 3 +- .../impl/wireformat/CreateQueueMessage_V2.java | 24 +++ .../wireformat/CreateSharedQueueMessage_V2.java | 23 ++- .../SessionQueueQueryResponseMessage_V3.java | 31 ++- .../artemis/core/server/QueueQueryResult.java | 9 + .../core/config/CoreQueueConfiguration.java | 20 ++ .../deployers/impl/FileConfigurationParser.java | 8 + .../management/impl/ActiveMQServerControlImpl.java | 69 ++++++- .../artemis/core/persistence/QueueBindingInfo.java | 2 + .../journal/AbstractJournalStorageManager.java | 2 +- .../codec/PersistentQueueBindingEncoding.java | 21 ++- .../artemis/core/postoffice/PostOffice.java | 1 + .../core/postoffice/impl/PostOfficeImpl.java | 5 + .../protocol/core/ServerSessionPacketHandler.java | 4 +- .../artemis/core/server/ActiveMQServer.java | 52 ++++++ .../apache/activemq/artemis/core/server/Queue.java | 4 + .../activemq/artemis/core/server/QueueConfig.java | 20 +- .../artemis/core/server/ServerSession.java | 42 +++++ .../core/server/impl/ActiveMQServerImpl.java | 132 +++++++++++-- .../server/impl/GroupFirstMessageReference.java | 208 +++++++++++++++++++++ .../artemis/core/server/impl/LastValueQueue.java | 3 +- .../core/server/impl/PostOfficeJournalLoader.java | 1 + .../artemis/core/server/impl/QueueFactoryImpl.java | 6 +- .../artemis/core/server/impl/QueueImpl.java | 63 ++++++- .../core/server/impl/ServerSessionImpl.java | 66 ++++++- .../core/settings/impl/AddressSettings.java | 18 ++ .../resources/schema/artemis-configuration.xsd | 10 + .../server/impl/ScheduledDeliveryHandlerTest.java | 10 + .../src/test/resources/artemis-configuration.xsd | 10 + .../integration/amqp/JMSMessageGroupsTest.java | 5 + .../tests/integration/jms/client/GroupingTest.java | 136 ++++++++++++++ .../ActiveMQServerControlUsingCoreTest.java | 12 +- .../tests/unit/core/postoffice/impl/FakeQueue.java | 10 + .../core/server/impl/fakes/FakePostOffice.java | 1 + 39 files changed, 1118 insertions(+), 45 deletions(-)
