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

Posted to commits@activemq.apache.org by ta...@apache.org on 2018/04/14 14:48:14 UTC

[2/2] activemq-artemis git commit: This closes #2012

This closes #2012


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

Branch: refs/heads/master
Commit: c4763bc088c0d83c323b42ce5be0f542779368dd
Parents: 5535af1 bddfa48
Author: Timothy Bish <ta...@gmail.com>
Authored: Sat Apr 14 10:47:47 2018 -0400
Committer: Timothy Bish <ta...@gmail.com>
Committed: Sat Apr 14 10:47:47 2018 -0400

----------------------------------------------------------------------
 .../core/protocol/openwire/amq/AMQConsumer.java | 10 ++--
 .../core/paging/cursor/PagedReferenceImpl.java  | 14 +++--
 .../artemis/core/server/MessageReference.java   |  4 +-
 .../activemq/artemis/core/server/Queue.java     |  8 ++-
 .../core/server/impl/LastValueQueue.java        | 10 +++-
 .../core/server/impl/MessageReferenceImpl.java  | 14 +++--
 .../artemis/core/server/impl/QueueImpl.java     | 54 ++++++++++++--------
 .../core/server/impl/ServerConsumerImpl.java    |  8 +--
 .../core/server/impl/ServerSessionImpl.java     |  5 +-
 .../server/plugin/ActiveMQServerPlugin.java     | 35 +++++++++++++
 .../impl/LoggingActiveMQServerPlugin.java       |  5 +-
 .../impl/LoggingActiveMQServerPluginLogger.java |  6 +--
 .../impl/ScheduledDeliveryHandlerTest.java      | 15 +++++-
 .../integration/plugin/CorePluginTest.java      | 45 ++++++++++++++--
 .../plugin/MethodCalledVerifier.java            |  4 +-
 .../unit/core/postoffice/impl/FakeQueue.java    | 17 +++++-
 16 files changed, 193 insertions(+), 61 deletions(-)
----------------------------------------------------------------------