Use right queue variable

elastic · Jan 31, 2013 · 6735ee4 · 6735ee4
1 parent 1a02aa1
commit 6735ee4
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
@@ -133,7 +133,7 @@ def prepare_river
       hostname = Socket.gethostname
 
       # Replace spaces with hyphens and remove all non-alpha non-dash non-underscore characters
-      river_name = "#{hostname} #{queue}".gsub(' ', '-').gsub(/[^\w-]/, '')
+      river_name = "#{hostname} #{@queue}".gsub(' ', '-').gsub(/[^\w-]/, '')
 
       api_path = "/_river/logstash-#{river_name}/_meta"
       @status_path = "/_river/logstash-#{river_name}/_status"