zeromq_spec.rb in logstash-input-zeromq-2.0.0

- old
+ new

@@ -1,26 +1,52 @@
-require "logstash/devutils/rspec/spec_helper"
+# encoding: utf-8
+require_relative "../spec_helper"
+require "logstash/plugin"
+require "logstash/event"
+
+describe LogStash::Inputs::ZeroMQ, :zeromq => true do
+
+  context "when register and close" do
+
+    let(:plugin) { LogStash::Plugin.lookup("input", "zeromq").new({ "topology" => "pushpull" }) }
+
+    it "should register and close without errors" do
+      expect { plugin.register }.to_not raise_error
+      expect { plugin.close }.to_not raise_error
+    end
+
+    context "when interrupting the plugin" do
+      it_behaves_like "an interruptible input plugin" do
+        let(:config) { { "topology" => "pushpull" } }
+        after do
+          subject.close
+        end
+      end
+    end
+
+  end
+end