Merge commit '8a0b7df44c3b8097119c94f5b0e518bdf17f0027'
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/658da115 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/658da115 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/658da115 Branch: refs/heads/master Commit: 658da115d6520b6835f248efcc88d707dcffd271 Parents: 88fcbd8 8a0b7df Author: sblackmon <sblack...@apache.org> Authored: Mon Dec 1 10:40:35 2014 -0600 Committer: sblackmon <sblack...@apache.org> Committed: Mon Dec 1 10:40:35 2014 -0600 ---------------------------------------------------------------------- .../persist/impl/SLF4JMessagePersister.java | 25 ++++++++++++++++++++ .../tasks/BroadcastMonitorThread.java | 3 ++- 2 files changed, 27 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/658da115/streams-monitoring/src/main/java/org/apache/streams/monitoring/tasks/BroadcastMonitorThread.java ---------------------------------------------------------------------- diff --cc streams-monitoring/src/main/java/org/apache/streams/monitoring/tasks/BroadcastMonitorThread.java index 1854163,6c3ec4f..6f6dda5 --- 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 @@@ -61,11 -58,9 +62,11 @@@ public class BroadcastMonitorThread ext setBroadcastURI(); setWaitTime(); - messagePersister = new BroadcastMessagePersister(broadcastURI); + messagePersister = new SLF4JMessagePersister(); initializeObjectMapper(); + + LOGGER.info("BroadcastMonitorThread started"); } /**
