eagle-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ralp...@apache.org
Subject [2/2] incubator-eagle git commit: EAGLE-756: make sure publish change is sent to runtime bolts
Date Wed, 09 Nov 2016 02:43:09 GMT
EAGLE-756: make sure publish change is sent to runtime bolts

Author: Zeng, Bryant
Reviewer: ralphsu

This closes #630


Project: http://git-wip-us.apache.org/repos/asf/incubator-eagle/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-eagle/commit/6ec92894
Tree: http://git-wip-us.apache.org/repos/asf/incubator-eagle/tree/6ec92894
Diff: http://git-wip-us.apache.org/repos/asf/incubator-eagle/diff/6ec92894

Branch: refs/heads/master
Commit: 6ec928941364bcb565ec2b20d6da20336aaa3578
Parents: bd5f242
Author: mizeng <mizeng@ebaysf.com>
Authored: Tue Nov 8 15:37:39 2016 -0800
Committer: Ralph, Su <suliangfei@gmail.com>
Committed: Wed Nov 9 10:30:42 2016 +0800

----------------------------------------------------------------------
 .../eagle/alert/engine/publisher/impl/AlertPublisherImpl.java   | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/6ec92894/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/publisher/impl/AlertPublisherImpl.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/publisher/impl/AlertPublisherImpl.java
b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/publisher/impl/AlertPublisherImpl.java
index a4038e7..7cb4a73 100644
--- a/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/publisher/impl/AlertPublisherImpl.java
+++ b/eagle-core/eagle-alert-parent/eagle-alert/alert-engine/src/main/java/org/apache/eagle/alert/engine/publisher/impl/AlertPublisherImpl.java
@@ -174,7 +174,10 @@ public class AlertPublisherImpl implements AlertPublisher {
                 addPublishmentPoliciesStreams(newPSPublishPluginMapping, newPolicies, newStreams,
pubName);
             }
             Publishment newPub = afterModified.get(i);
-            newPublishMap.get(pubName).update(newPub.getDedupIntervalMin(), newPub.getProperties());
+
+            // for updated publishment, need to init them too
+            AlertPublishPlugin newPlugin = AlertPublishPluginsFactory.createNotificationPlugin(newPub,
config, conf);
+            newPublishMap.replace(pubName, newPlugin);
         }
 
         // now do the swap


Mime
View raw message