activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [1/3] activemq-artemis git commit: ARTEMIS-740 Auto-reload diverts from broker.xml
Date Wed, 21 Sep 2016 21:09:48 GMT
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.skytta@iki.fi>
Authored: Wed Sep 21 12:13:31 2016 +0300
Committer: Clebert Suconic <clebertsuconic@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);
+            }
+         }
       }
    }
 }


Mime
View raw message