You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@activemq.apache.org by jb...@apache.org on 2017/11/29 16:52:15 UTC

[3/3] activemq-artemis git commit: This closes #1678

This closes #1678


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/a822af47
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/a822af47
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/a822af47

Branch: refs/heads/master
Commit: a822af4712a5a10f0c32ac9a0f7dbe28bd6eebad
Parents: 4584ac6 8b7282d
Author: Justin Bertram <jb...@apache.org>
Authored: Wed Nov 29 10:49:36 2017 -0600
Committer: Justin Bertram <jb...@apache.org>
Committed: Wed Nov 29 10:49:36 2017 -0600

----------------------------------------------------------------------
 .../artemis/utils/ReferenceCounter.java         |  15 ++
 .../artemis/utils/ReferenceCounterUtil.java     |  54 +++-
 .../artemis/utils/ReferenceCounterTest.java     |  15 +-
 .../amqp/broker/AMQPSessionCallback.java        |  33 ++-
 .../activemq/artemis/core/server/Queue.java     |   4 +
 .../artemis/core/server/impl/QueueImpl.java     |  20 ++
 .../core/server/impl/QueueManagerImpl.java      |  80 +++---
 .../core/server/impl/ServerConsumerImpl.java    |   2 +
 .../server/impl/TransientQueueManagerImpl.java  |  41 +--
 .../impl/ScheduledDeliveryHandlerTest.java      |   5 +
 .../integration/amqp/TopicDurableTests.java     | 259 +++++++++++++++++++
 .../tests/integration/client/ConsumerTest.java  |  18 +-
 .../unit/core/postoffice/impl/FakeQueue.java    |   6 +
 13 files changed, 458 insertions(+), 94 deletions(-)
----------------------------------------------------------------------