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 <tabish...@gmail.com> Authored: Sat Apr 14 10:47:47 2018 -0400 Committer: Timothy Bish <tabish...@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(-) ----------------------------------------------------------------------