queue name param is :name, not :queue

ttyard · Feb 22, 2012 · 0c61374 · 0c61374
1 parent 6e7860d
commit 0c61374
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/logstash/outputs/elasticsearch_river.rb b/lib/logstash/outputs/elasticsearch_river.rb
@@ -99,7 +99,7 @@ def prepare_river
       "user" => [@user],
       "password" => [@password],
       "exchange_type" => ["direct"],
-      "queue_name" => [@queue],
+      "queue_name" => [@name],
       "name" => [@exchange],
       "key" => [@key],
       "vhost" => [@vhost],