You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by an...@apache.org on 2017/08/17 09:57:52 UTC
[4/4] activemq-artemis git commit: This closes #1462 Manage client
objects
This closes #1462 Manage client objects
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/133dd437
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/133dd437
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/133dd437
Branch: refs/heads/master
Commit: 133dd4377309932787152a91c932c2f23c4dd212
Parents: f2f4708 06ea18d
Author: Andy Taylor <an...@gmail.com>
Authored: Thu Aug 17 10:55:11 2017 +0100
Committer: Andy Taylor <an...@gmail.com>
Committed: Thu Aug 17 10:55:11 2017 +0100
----------------------------------------------------------------------
.../core/management/ActiveMQServerControl.java | 30 ++
.../core/impl/RemotingConnectionImpl.java | 19 +-
.../protocol/AbstractRemotingConnection.java | 11 +
.../spi/core/protocol/RemotingConnection.java | 18 ++
.../activemq/artemis/utils/StringUtil.java | 3 +-
.../src/main/webapp/plugin/html/addresses.html | 54 ++++
.../main/webapp/plugin/html/connections.html | 53 ++++
.../src/main/webapp/plugin/html/consumers.html | 54 ++++
.../src/main/webapp/plugin/html/producers.html | 54 ++++
.../src/main/webapp/plugin/html/queues.html | 54 ++++
.../src/main/webapp/plugin/html/sessions.html | 53 ++++
.../src/main/webapp/plugin/js/addresses.js | 196 ++++++++++++
.../src/main/webapp/plugin/js/artemisHelpers.js | 23 ++
.../src/main/webapp/plugin/js/artemisPlugin.js | 96 +++++-
.../src/main/webapp/plugin/js/connections.js | 214 +++++++++++++
.../src/main/webapp/plugin/js/consumers.js | 239 +++++++++++++++
.../src/main/webapp/plugin/js/producers.js | 220 ++++++++++++++
.../src/main/webapp/plugin/js/queues.js | 298 +++++++++++++++++++
.../src/main/webapp/plugin/js/sessions.js | 233 +++++++++++++++
.../amqp/broker/AMQPSessionCallback.java | 9 +
.../ActiveMQProtonRemotingConnection.java | 15 +
.../broker/ProtonProtocolManagerFactory.java | 2 +-
.../amqp/proton/AMQPSessionContext.java | 5 +
.../core/protocol/mqtt/MQTTConnection.java | 33 ++
.../protocol/mqtt/MQTTConnectionManager.java | 1 +
.../core/protocol/mqtt/MQTTPublishManager.java | 1 +
.../protocol/openwire/OpenWireConnection.java | 9 +
.../core/protocol/stomp/StompConnection.java | 12 +
.../impl/ActiveMQServerControlImpl.java | 111 +++++++
.../impl/view/ActiveMQAbstractView.java | 164 ++++++++++
.../core/management/impl/view/AddressView.java | 63 ++++
.../management/impl/view/ConnectionView.java | 67 +++++
.../core/management/impl/view/ConsumerView.java | 56 ++++
.../core/management/impl/view/ProducerView.java | 55 ++++
.../core/management/impl/view/QueueView.java | 56 ++++
.../core/management/impl/view/SessionView.java | 50 ++++
.../view/predicate/ActiveMQFilterPredicate.java | 106 +++++++
.../view/predicate/AddressFilterPredicate.java | 69 +++++
.../predicate/ConnectionFilterPredicate.java | 79 +++++
.../view/predicate/ConsumerFilterPredicate.java | 71 +++++
.../view/predicate/ProducerFilterPredicate.java | 71 +++++
.../view/predicate/QueueFilterPredicate.java | 107 +++++++
.../view/predicate/SessionFilterPredicate.java | 65 ++++
.../core/impl/ActiveMQPacketHandler.java | 6 +-
.../artemis/core/server/ServerProducer.java | 35 +++
.../artemis/core/server/ServerSession.java | 9 +
.../core/server/impl/ServerProducerImpl.java | 78 +++++
.../core/server/impl/ServerSessionImpl.java | 26 ++
.../ActiveMQServerControlUsingCoreTest.java | 41 +++
49 files changed, 3373 insertions(+), 21 deletions(-)
----------------------------------------------------------------------