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 <clebertsuco...@apache.org>
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(-)

Reply via email to