From da01c4a78a1f3f092dad345395b8b4bd1bb21968 Mon Sep 17 00:00:00 2001 From: nishantmonu51 Date: Fri, 10 Jan 2014 02:02:06 +0530 Subject: [PATCH] Add registration for backward compatibility --- .../indexing/common/index/EventReceiverFirehoseFactory.java | 3 +++ 1 file changed, 3 insertions(+) diff --git 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 index 225d1b0f2cf..31716232207 100644 --- 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 @@ -86,6 +86,9 @@ public class EventReceiverFirehoseFactory implements FirehoseFactory 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"); }