Repository: activemq-artemis Updated Branches: refs/heads/master bf073f19a -> f346347b0
This closes #2231 Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/f346347b Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/f346347b Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/f346347b Branch: refs/heads/master Commit: f346347b0195f52a120c2336e47c91cb7c2db346 Parents: bf073f1 19e1bbe Author: Clebert Suconic <[email protected]> Authored: Thu Aug 9 19:42:28 2018 -0400 Committer: Clebert Suconic <[email protected]> Committed: Thu Aug 9 19:42:28 2018 -0400 ---------------------------------------------------------------------- .../artemis/core/config/Configuration.java | 64 +- .../core/config/impl/ConfigurationImpl.java | 131 +++- .../core/postoffice/impl/PostOfficeImpl.java | 48 +- .../server/impl/RemotingServiceImpl.java | 8 +- .../artemis/core/server/ActiveMQServer.java | 73 +- .../core/server/cluster/ClusterManager.java | 8 +- .../core/server/cluster/impl/BridgeImpl.java | 12 +- .../core/server/impl/ActiveMQServerImpl.java | 203 +++++- .../artemis/core/server/impl/QueueImpl.java | 12 +- .../core/server/impl/ServerConsumerImpl.java | 16 +- .../core/server/impl/ServerSessionImpl.java | 36 +- .../server/plugin/ActiveMQPluginRunnable.java | 4 +- .../plugin/ActiveMQServerAddressPlugin.java | 95 +++ .../server/plugin/ActiveMQServerBasePlugin.java | 52 ++ .../plugin/ActiveMQServerBindingPlugin.java | 73 ++ .../plugin/ActiveMQServerBridgePlugin.java | 85 +++ .../plugin/ActiveMQServerConnectionPlugin.java | 49 ++ .../plugin/ActiveMQServerConsumerPlugin.java | 97 +++ .../plugin/ActiveMQServerCriticalPlugin.java | 36 + .../plugin/ActiveMQServerMessagePlugin.java | 236 +++++++ .../server/plugin/ActiveMQServerPlugin.java | 673 +------------------ .../plugin/ActiveMQServerQueuePlugin.java | 81 +++ .../plugin/ActiveMQServerSessionPlugin.java | 126 ++++ .../core/config/impl/FileConfigurationTest.java | 3 +- 24 files changed, 1450 insertions(+), 771 deletions(-) ----------------------------------------------------------------------
