From ecbc9eda48422c5ade57a21209f717f6aba24a86 Mon Sep 17 00:00:00 2001
From: fjy <fangjin@metamarkets.com>
Date: Tue, 29 Jul 2014 21:55:05 -0700
Subject: [PATCH] revert breakage to chat handlers

---
 .../realtime/firehose/EventReceiverFirehoseFactory.java      | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/server/src/main/java/io/druid/segment/realtime/firehose/EventReceiverFirehoseFactory.java b/server/src/main/java/io/druid/segment/realtime/firehose/EventReceiverFirehoseFactory.java
index 7b33688c1ce..5b8311c665e 100644
--- a/server/src/main/java/io/druid/segment/realtime/firehose/EventReceiverFirehoseFactory.java
+++ b/server/src/main/java/io/druid/segment/realtime/firehose/EventReceiverFirehoseFactory.java
@@ -91,6 +91,9 @@ public class EventReceiverFirehoseFactory implements FirehoseFactory<MapInputRow
     if (chatHandlerProvider.isPresent()) {
       log.info("Found chathandler of class[%s]", chatHandlerProvider.get().getClass().getName());
       chatHandlerProvider.get().register(serviceName, firehose);
+      if (serviceName.contains(":")) {
+        chatHandlerProvider.get().register(serviceName.replaceAll(".*:", ""), firehose); // rofl
+      }
     } else {
       log.info("No chathandler detected");
     }
@@ -143,7 +146,7 @@ public class EventReceiverFirehoseFactory implements FirehoseFactory<MapInputRow
       for (final Map<String, Object> event : events) {
         // Might throw an exception. We'd like that to happen now, instead of while adding to the row buffer.
         InputRow row = parser.parse(event);
-        rows.add(Rows.toCaseInsensitiveInputRow(row,row.getDimensions()));
+        rows.add(Rows.toCaseInsensitiveInputRow(row, row.getDimensions()));
       }
 
       try {