Use correct method for getting queues; missed in replay PR

dcshock · Jun 4, 2017 · 9269acc · 9269acc
1 parent 1f84705
commit 9269acc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/plugins/replay/src/main/java/forklift/replay/ReplayES.java b/plugins/replay/src/main/java/forklift/replay/ReplayES.java
@@ -115,7 +115,7 @@ public void run() {
  .filter(source -> !source.isLogicalSource())
  .findFirst().get();
 
- this.producer = connector.getTopicProducer(primarySource
+ this.producer = connector.getQueueProducer(primarySource
  .apply(QueueSource.class, queue -> queue.getName())
  .apply(TopicSource.class, topic -> topic.getName())
  .apply(GroupedTopicSource.class, topic -> topic.getName())