This closes #1829
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/19147e49 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/19147e49 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/19147e49 Branch: refs/heads/master Commit: 19147e49869d23906baf2cc07d98564043b3b0e0 Parents: ce84c0c 51cb5df Author: Francesco Nigro <[email protected]> Authored: Thu Feb 1 16:23:54 2018 +0100 Committer: Francesco Nigro <[email protected]> Committed: Thu Feb 1 16:23:54 2018 +0100 ---------------------------------------------------------------------- .../core/postoffice/impl/PostOfficeImpl.java | 52 +++++++++++++++++--- .../server/impl/RemotingServiceImpl.java | 8 ++- .../core/server/cluster/ClusterManager.java | 8 ++- .../artemis/core/server/impl/QueueImpl.java | 12 ++--- .../core/server/impl/ServerConsumerImpl.java | 16 ++++-- .../core/server/impl/ServerSessionImpl.java | 39 ++++++++++----- .../server/plugin/ActiveMQServerPlugin.java | 48 ++++++++++++++++++ .../integration/plugin/AmqpPluginTest.java | 9 +++- .../integration/plugin/CorePluginTest.java | 25 ++++++---- .../plugin/MethodCalledVerifier.java | 30 +++++++++++ .../integration/plugin/MqttPluginTest.java | 7 ++- .../integration/plugin/OpenwirePluginTest.java | 7 ++- .../integration/plugin/StompPluginTest.java | 8 ++- 13 files changed, 220 insertions(+), 49 deletions(-) ----------------------------------------------------------------------
