create BroadcastMessagePersister when BroadcastURI is provided.
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/b65e198d Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/b65e198d Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/b65e198d Branch: refs/heads/asf-master Commit: b65e198dba3a97535b91afe1c9898af23426911b Parents: c775391 Author: sblackmon <[email protected]> Authored: Wed Feb 11 18:07:03 2015 -0600 Committer: sblackmon <[email protected]> Committed: Wed Feb 11 18:07:03 2015 -0600 ---------------------------------------------------------------------- .../streams/monitoring/tasks/BroadcastMonitorThread.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/b65e198d/streams-monitoring/src/main/java/org/apache/streams/monitoring/tasks/BroadcastMonitorThread.java ---------------------------------------------------------------------- diff --git a/streams-monitoring/src/main/java/org/apache/streams/monitoring/tasks/BroadcastMonitorThread.java b/streams-monitoring/src/main/java/org/apache/streams/monitoring/tasks/BroadcastMonitorThread.java index ea7edd1..6867bd3 100644 --- a/streams-monitoring/src/main/java/org/apache/streams/monitoring/tasks/BroadcastMonitorThread.java +++ b/streams-monitoring/src/main/java/org/apache/streams/monitoring/tasks/BroadcastMonitorThread.java @@ -20,6 +20,7 @@ package org.apache.streams.monitoring.tasks; import com.fasterxml.jackson.databind.DeserializationFeature; import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.module.SimpleModule; +import com.google.common.base.Strings; import com.google.common.collect.Lists; import org.apache.streams.jackson.*; import org.apache.streams.monitoring.persist.MessagePersister; @@ -58,11 +59,13 @@ public class BroadcastMonitorThread extends NotificationBroadcasterSupport imple server = ManagementFactory.getPlatformMBeanServer(); - setBroadcastURI(); setWaitTime(); - messagePersister = new SLF4JMessagePersister(); + if( !Strings.isNullOrEmpty(broadcastURI)) + messagePersister = new BroadcastMessagePersister(broadcastURI); + else + messagePersister = new SLF4JMessagePersister(); initializeObjectMapper();
