Make the example use the new stop semantic

Fixes #5

Gemfile

@@ -1,2 +1,2 @@
 source 'https://rubygems.org'
-gemspec
+gemspec

lib/logstash/inputs/example.rb

@@ -12,7 +12,7 @@ class LogStash::Inputs::Example < LogStash::Inputs::Base
   config_name "example"
 
   # If undefined, Logstash will complain, even if codec is unused.
-  default :codec, "plain" 
+  default :codec, "plain"
 
   # The message string to use in the event.
   config :message, :validate => :string, :default => "Hello World!"
@@ -28,11 +28,17 @@ def register
   end # def register
 
   def run(queue)
+    @thread = Thread.current
+
     Stud.interval(@interval) do
       event = LogStash::Event.new("message" => @message, "host" => @host)
       decorate(event)
       queue << event
+      break if stop?
     end # loop
   end # def run
 
-end # class LogStash::Inputs::Example
+  def stop
+    Stud.stop!(@thread)
+  end
+end # class LogStash::Inputs::Example

logstash-input-example.gemspec

@@ -20,6 +20,6 @@ Gem::Specification.new do |s|
   # Gem dependencies
   s.add_runtime_dependency "logstash-core", "~> 2.0.0.snapshot"
   s.add_runtime_dependency 'logstash-codec-plain'
-  s.add_runtime_dependency 'stud'
-  s.add_development_dependency 'logstash-devutils'
+  s.add_runtime_dependency 'stud', '>= 0.0.22'
+  s.add_development_dependency 'logstash-devutils', '>= 0.0.16'
 end

spec/inputs/example_spec.rb

@@ -1 +1,10 @@
-require "logstash/devutils/rspec/spec_helper"
+require "logstash/devutils/rspec/spec_helper"
+require "logstash/inputs/example"
+
+describe LogStash::Inputs::Example do
+
+  it_behaves_like "an interruptible input plugin" do
+    let(:config) { { "interval" => 100 } }
+  end
+
+end