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
   )