Repository: activemq-artemis
Updated Branches:
  refs/heads/master df0d5d71e -> 5ea53c48e


ARTEMIS-740 Auto-reload diverts from broker.xml


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/589adbcc
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/589adbcc
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/589adbcc

Branch: refs/heads/master
Commit: 589adbccacb34aa0ff9c933ff5b240bb71dc5463
Parents: df0d5d7
Author: Ville Skyttä <ville.sky...@iki.fi>
Authored: Wed Sep 21 12:13:31 2016 +0300
Committer: Clebert Suconic <clebertsuco...@apache.org>
Committed: Wed Sep 21 17:00:21 2016 -0400

----------------------------------------------------------------------
 .../activemq/artemis/core/server/impl/ActiveMQServerImpl.java  | 6 ++++++
 1 file changed, 6 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/589adbcc/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java
----------------------------------------------------------------------
diff --git 
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java
 
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java
index 7f67abc..38005ed 100644
--- 
a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java
+++ 
b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java
@@ -2451,6 +2451,12 @@ public class ActiveMQServerImpl implements 
ActiveMQServer {
          securityRepository.swap(config.getSecurityRoles().entrySet());
          ActiveMQServerLogger.LOGGER.reloadingConfiguration("address 
settings");
          
addressSettingsRepository.swap(config.getAddressesSettings().entrySet());
+         ActiveMQServerLogger.LOGGER.reloadingConfiguration("diverts");
+         for (DivertConfiguration divertConfig : 
config.getDivertConfigurations()) {
+            if (postOffice.getBinding(new 
SimpleString(divertConfig.getName())) == null) {
+               deployDivert(divertConfig);
+            }
+         }
       }
    }
 }

Reply via email to