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 2018/10/18 00:53:24 UTC
[5/5] activemq-artemis git commit: This closes #2362
This closes #2362
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/f70075a7
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/f70075a7
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/f70075a7
Branch: refs/heads/master
Commit: f70075a78912ba94d88c583c638d9bcb40360000
Parents: 44fa690 547b2aa
Author: Clebert Suconic <cl...@apache.org>
Authored: Wed Oct 17 20:53:14 2018 -0400
Committer: Clebert Suconic <cl...@apache.org>
Committed: Wed Oct 17 20:53:14 2018 -0400
----------------------------------------------------------------------
.../artemis/api/core/QueueAttributes.java | 106 ++++-
.../config/ActiveMQDefaultConfiguration.java | 14 +-
.../artemis/api/core/client/ClientSession.java | 49 ++
.../core/management/ActiveMQServerControl.java | 4 +
.../core/client/impl/AddressQueryImpl.java | 38 +-
.../core/client/impl/ClientSessionImpl.java | 176 ++++---
.../core/client/impl/QueueQueryImpl.java | 57 +++
.../core/impl/ActiveMQSessionContext.java | 90 +++-
.../impl/wireformat/CreateQueueMessage_V2.java | 115 ++++-
.../wireformat/CreateSharedQueueMessage_V2.java | 84 +++-
.../SessionBindingQueryResponseMessage_V4.java | 76 ++-
.../SessionQueueQueryResponseMessage_V3.java | 96 +++-
.../artemis/core/server/QueueQueryResult.java | 36 ++
.../spi/core/remoting/SessionContext.java | 20 +
.../jms/client/ActiveMQMessageProducer.java | 40 +-
.../artemis/jms/client/ActiveMQSession.java | 132 +++---
.../client/HornetQClientSessionContext.java | 2 +-
.../core/protocol/openwire/amq/AMQConsumer.java | 4 +-
.../core/config/CoreQueueConfiguration.java | 38 ++
.../deployers/impl/FileConfigurationParser.java | 16 +-
.../impl/ActiveMQServerControlImpl.java | 33 +-
.../core/paging/cursor/PagedReferenceImpl.java | 10 +
.../core/persistence/QueueBindingInfo.java | 8 +
.../journal/AbstractJournalStorageManager.java | 2 +-
.../codec/PersistentQueueBindingEncoding.java | 46 ++
.../artemis/core/postoffice/PostOffice.java | 1 +
.../core/postoffice/impl/PostOfficeImpl.java | 5 +
.../core/ServerSessionPacketHandler.java | 9 +-
.../artemis/core/server/ActiveMQServer.java | 13 +-
.../artemis/core/server/BindingQueryResult.java | 38 +-
.../artemis/core/server/MessageReference.java | 3 +
.../activemq/artemis/core/server/Queue.java | 10 +-
.../artemis/core/server/QueueConfig.java | 38 +-
.../artemis/core/server/ServerSession.java | 30 ++
.../artemis/core/server/impl/AckReason.java | 2 +-
.../core/server/impl/ActiveMQServerImpl.java | 72 ++-
.../core/server/impl/LastValueQueue.java | 77 ++-
.../core/server/impl/MessageReferenceImpl.java | 10 +
.../server/impl/PostOfficeJournalLoader.java | 2 +
.../core/server/impl/QueueFactoryImpl.java | 31 +-
.../artemis/core/server/impl/QueueImpl.java | 272 ++++++-----
.../core/server/impl/ServerSessionImpl.java | 68 ++-
.../core/settings/impl/AddressSettings.java | 62 ++-
.../resources/schema/artemis-configuration.xsd | 20 +
.../impl/ScheduledDeliveryHandlerTest.java | 15 +
.../test/resources/artemis-configuration.xsd | 20 +
docs/user-manual/en/last-value-queues.md | 120 ++++-
docs/user-manual/en/message-expiry.md | 21 +
.../integration/DuplicateDetectionTest.java | 2 +-
.../integration/amqp/JMSClientTestSupport.java | 4 +
.../tests/integration/amqp/JMSLVQTest.java | 129 +++--
.../integration/amqp/JMSNonDestructiveTest.java | 467 +++++++++++++++++++
.../jms/client/ConsumerDelayDispatchTest.java | 4 +-
.../tests/integration/jms/client/LVQTest.java | 94 ++++
.../ActiveMQServerControlUsingCoreTest.java | 7 +-
.../persistence/QueueConfigRestartTest.java | 4 +-
.../jms/tests/message/MessageHeaderTest.java | 18 +-
.../unit/core/postoffice/impl/FakeQueue.java | 15 +
.../core/server/impl/fakes/FakePostOffice.java | 2 +-
59 files changed, 2522 insertions(+), 455 deletions(-)
----------------------------------------------------------------------