fix broken event receiving firehose

2013-11-07 16:59:01 -08:00 · 2013-11-07 16:59:01 -08:00 · 7f85a126ac
parent 621133d6f2
commit 7f85a126ac
1 changed files with 1 additions and 0 deletions
--- a/indexing-service/src/main/java/io/druid/indexing/common/index/EventReceiverFirehoseFactory.java
+++ b/indexing-service/src/main/java/io/druid/indexing/common/index/EventReceiverFirehoseFactory.java
@ -103,6 +103,7 @@ public class EventReceiverFirehoseFactory implements FirehoseFactory
    if (chatHandlerProvider.isPresent()) {
      log.info("Found chathandler of class[%s]", chatHandlerProvider.get().getClass().getName());
      chatHandlerProvider.get().register(serviceName, firehose);
+      chatHandlerProvider.get().register(serviceName.replaceAll(".*:", ""), firehose); // rofl
    } else {
      log.info("No chathandler detected");
    }