plugin-api 2.0 migration

Author: colinsurprenant

.travis.yml

@@ -1,7 +1,11 @@
 sudo: false
+jdk:
+  - oraclejdk8
 language: ruby
 cache: bundler
 rvm:
-  - jruby-1.7.23
-script: 
+  - jruby-1.7.25
+before_install:
+  - git clone -b feature/event_interface https://github.com/elastic/logstash
+script:
   - bundle exec rspec spec

Gemfile

@@ -1,2 +1,8 @@
 source 'https://rubygems.org'
-gemspec
+gemspec
+
+# this is temporary for the feature/plugin-api-2_0 branch and is meant for travis testing
+gem "logstash-core", :path => "./logstash/logstash-core"
+gem "logstash-core-plugin-api", :path => "./logstash/logstash-core-plugin-api"
+gem "logstash-core-event-java", :path => "./logstash/logstash-core-event-java"
+gem "logstash-devutils", :github => "elastic/logstash-devutils", :branch => "feature/plugin-api-2_0"

logstash-codec-line.gemspec

@@ -20,7 +20,7 @@ Gem::Specification.new do |s|
   s.metadata = { "logstash_plugin" => "true", "logstash_group" => "codec" }
 
   # Gem dependencies
-  s.add_runtime_dependency "logstash-core-plugin-api", "~> 1.0"
+  s.add_runtime_dependency "logstash-core-plugin-api", "~> 2.0"
 
   s.add_development_dependency 'logstash-devutils'
 end

spec/codecs/line_spec.rb

@@ -51,15 +51,15 @@
       subject.decode("hello world\n") do |e|
         decoded = true
         insist { e.is_a?(LogStash::Event) }
-        insist { e["message"] } == "hello world"
+        insist { e.get("message") } == "hello world"
       end
       insist { decoded } == true
     end
 
     it "should return an event from a valid utf-8 string" do
       subject.decode("München\n") do |e|
         insist { e.is_a?(LogStash::Event) }
-        insist { e["message"] } == "München"
+        insist { e.get("message") } == "München"
       end
     end
 
@@ -74,17 +74,17 @@
         subject.decode(line) { |e| result << e }
         subject.flush { |e| result << e }
         expect(result.size).to eq(1)
-        expect(result[0]["message"]).to eq(line)
+        expect(result[0].get("message")).to eq(line)
       end
 
       it "should break lines by that delimiter" do
         result = []
         subject.decode("line1|line2|line3|") { |e| result << e }
         subject.flush { |e| result << e }
         expect(result.size).to eq(3)
-        expect(result[0]["message"]).to eq("line1")
-        expect(result[1]["message"]).to eq("line2")
-        expect(result[2]["message"]).to eq("line3")
+        expect(result[0].get("message")).to eq("line1")
+        expect(result[1].get("message")).to eq("line2")
+        expect(result[2].get("message")).to eq("line3")
       end
     end
   end
@@ -98,7 +98,7 @@
       count = 0
       subject.flush do |event|
         count += 1
-        insist { event["message"].encoding } == Encoding::UTF_8
+        insist { event.get("message").encoding } == Encoding::UTF_8
       end
       insist { count } == 1
     end