From 0edfbaffab652d22f0fa1e5c0ed329d996531741 Mon Sep 17 00:00:00 2001 From: cheddar Date: Thu, 18 Jul 2013 13:17:11 -0700 Subject: [PATCH] Errr, needed to make the ConnectionFactory a JacksonifiedConnectionFactory --- .../metamx/druid/realtime/firehose/RabbitMQFirehoseFactory.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/realtime/src/main/java/com/metamx/druid/realtime/firehose/RabbitMQFirehoseFactory.java b/realtime/src/main/java/com/metamx/druid/realtime/firehose/RabbitMQFirehoseFactory.java index b5565f2b39a..48c45145612 100644 --- a/realtime/src/main/java/com/metamx/druid/realtime/firehose/RabbitMQFirehoseFactory.java +++ b/realtime/src/main/java/com/metamx/druid/realtime/firehose/RabbitMQFirehoseFactory.java @@ -72,7 +72,7 @@ public class RabbitMQFirehoseFactory implements FirehoseFactory @JsonCreator public RabbitMQFirehoseFactory( - @JsonProperty("connection") ConnectionFactory connectionFactory, + @JsonProperty("connection") JacksonifiedConnectionFactory connectionFactory, @JsonProperty("config") RabbitMQFirehoseConfig config, @JsonProperty("parser") StringInputRowParser parser )