You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2017/05/03 16:17:13 UTC
[3/3] activemq-artemis git commit: This closes #1242
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 <cl...@apache.org>
Authored: Wed May 3 12:17:01 2017 -0400
Committer: Clebert Suconic <cl...@apache.org>
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(-)
----------------------------------------------------------------------