[TESTING] Fix Kafka output test

When doing randomized testing, one of the tests failed because kafka was not initialized yet Fixes elastic#1758
ttyard · Sep 30, 2014 · 6daeb22 · 6daeb22
1 parent 42fa9ea
commit 6daeb22
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/spec/outputs/kafka_spec.rb b/spec/outputs/kafka_spec.rb
@@ -26,13 +26,13 @@
   end
 
   it "should send logstash event to kafka broker" do
+    kafka = LogStash::Outputs::Kafka.new(kafka_config)
+    kafka.register
     timestamp = LogStash::Timestamp.now
     expect_any_instance_of(Kafka::Producer)
     .to receive(:sendMsg)
         .with("test", nil, "{\"message\":\"hello world\",\"host\":\"test\",\"@timestamp\":\"#{timestamp}\",\"@version\":\"1\"}")
     e = LogStash::Event.new({"message" => "hello world", "host" => "test", "@timestamp" => timestamp})
-    kafka = LogStash::Outputs::Kafka.new(kafka_config)
-    kafka.register
     kafka.receive(e)
   end