You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by sb...@apache.org on 2014/12/11 21:25:38 UTC
[37/50] [abbrv] incubator-streams git commit: Merge commit
'8a0b7df44c3b8097119c94f5b0e518bdf17f0027'
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/STREAMS-212
Commit: 658da115d6520b6835f248efcc88d707dcffd271
Parents: 88fcbd8 8a0b7df
Author: sblackmon <sb...@apache.org>
Authored: Mon Dec 1 10:40:35 2014 -0600
Committer: sblackmon <sb...@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");
}
/**