STREAMS-283 | Ensuring that logic in BroadcastMonitorThread actually creates a Message Persister
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/ef2b167f Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/ef2b167f Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/ef2b167f Branch: refs/heads/asf-master Commit: ef2b167f28fb9815cbd2e51d4f837ef6f6386bcf Parents: f471d78 Author: Robert Douglas <rdoug...@w2ogroup.com> Authored: Wed Feb 18 14:02:22 2015 -0600 Committer: Robert Douglas <rdoug...@w2ogroup.com> Committed: Wed Feb 18 14:02:22 2015 -0600 ---------------------------------------------------------------------- .../monitoring/tasks/BroadcastMonitorThread.java | 13 +++++++++---- 1 file changed, 9 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/ef2b167f/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 948863e..561ee70 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 @@ -64,13 +64,18 @@ public class BroadcastMonitorThread extends NotificationBroadcasterSupport imple setBroadcastURI(); setWaitTime(); - if( broadcastURI != null ) - if( broadcastURI.getScheme().equals("http")) + if( broadcastURI != null ) { + if (broadcastURI.getScheme().equals("http")) { messagePersister = new BroadcastMessagePersister(broadcastURI.toString()); - else if( broadcastURI.getScheme().equals("udp")) + } else if (broadcastURI.getScheme().equals("udp")) { messagePersister = new LogstashUdpMessagePersister(broadcastURI.toString()); - else + } else { + LOGGER.error("You need to specify a broadcast URI with either a HTTP or UDP protocol defined."); + throw new RuntimeException(); + } + } else { messagePersister = new SLF4JMessagePersister(); + } initializeObjectMapper();
