This closes #1242
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/5391d42e Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/5391d42e Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/5391d42e Branch: refs/heads/master Commit: 5391d42e474a323b84bcd0e2dd7162bbeaffeefe Parents: 303d97c 1e1ede8 Author: Clebert Suconic <[email protected]> Authored: Wed May 3 12:17:01 2017 -0400 Committer: Clebert Suconic <[email protected]> Committed: Wed May 3 12:17:01 2017 -0400 ---------------------------------------------------------------------- .../artemis/core/config/Configuration.java | 21 ++ .../core/config/impl/ConfigurationImpl.java | 24 ++ .../core/postoffice/impl/PostOfficeImpl.java | 4 + .../server/impl/RemotingServiceImpl.java | 7 +- .../artemis/core/server/ActiveMQServer.java | 18 +- .../core/server/cluster/ClusterManager.java | 3 + .../core/server/impl/ActiveMQServerImpl.java | 57 +++- .../core/server/impl/LastValueQueue.java | 6 +- .../core/server/impl/QueueFactoryImpl.java | 19 +- .../artemis/core/server/impl/QueueImpl.java | 31 +- .../core/server/impl/ServerConsumerImpl.java | 7 + .../core/server/impl/ServerSessionImpl.java | 33 +- .../server/plugin/ActiveMQPluginRunnable.java | 24 ++ .../server/plugin/ActiveMQServerPlugin.java | 336 +++++++++++++++++++ .../integration/amqp/AmqpClientTestSupport.java | 7 + .../integration/client/HangConsumerTest.java | 37 +- .../client/InterruptedLargeMessageTest.java | 18 +- .../jms/client/TopicCleanupTest.java | 12 +- .../openwire/amq/JmsResourceProvider.java | 2 +- .../integration/plugin/AmqpPluginTest.java | 131 ++++++++ .../integration/plugin/CorePluginTest.java | 257 ++++++++++++++ .../plugin/MethodCalledVerifier.java | 276 +++++++++++++++ .../integration/plugin/MqttPluginTest.java | 132 ++++++++ .../integration/plugin/OpenwirePluginTest.java | 109 ++++++ .../integration/plugin/StompPluginTest.java | 126 +++++++ .../timing/core/server/impl/QueueImplTest.java | 15 +- .../unit/core/server/impl/QueueImplTest.java | 3 +- .../server/impl/fakes/FakeQueueFactory.java | 7 +- 28 files changed, 1664 insertions(+), 58 deletions(-) ----------------------------------------------------------------------
