Fixed test to verify 'message' form

Author: andsel

lib/logstash/codecs/json_lines.rb

@@ -61,6 +61,7 @@ def register
       deprecation_logger.deprecated "The default value for `decode_size_limit_bytes`, currently at 512MB, will be lowered in a future version to prevent Out of Memory errors from abnormally large messages or missing delimiters. Please set a value that reflects the largest expected message size (e.g. 20971520 for 20MB)"
     end
     @buffer = FileWatch::BufferedTokenizer.new(@delimiter, @decode_size_limit_bytes)
+    puts "DNADBG>> delimiter is [#{@delimiter}]"
     @converter = LogStash::Util::Charset.new(@charset)
     @converter.logger = @logger
   end
@@ -71,7 +72,7 @@ def decode(data, &block)
     end
   rescue java.lang.IllegalStateException => e
     if e.message == "input buffer full" && @decode_size_limit_bytes != "none"
-      yield event_factory.new_event("message" => data[0..@decode_size_limit_bytes.to_i - 1], "tags" => ["_jsonparsetoobigfailure"]) #TODO check the failure tag
+      yield event_factory.new_event("message" => "Payload bigger than #{@decode_size_limit_bytes} bytes", "tags" => ["_jsonparsetoobigfailure"])
     else
       # re-raise the error if doesn't correspond to the buffer overflow condition
       raise e

spec/codecs/json_lines_spec.rb

@@ -131,17 +131,10 @@
       it "should raise an error if the max bytes are exceeded" do
         subject.decode(maximum_payload << "z") do |event|
           expect(event.get("tags")).to include("_jsonparsetoobigfailure")
-          expect(event.get("message").size).to eq(decode_size_limit_bytes)
+          expect(event.get("message")).to eq("Payload bigger than #{subject.decode_size_limit_bytes} bytes")
         end
       end
 
-      it "should raise an error if the max bytes are exceeded" do
-        subject.decode(maximum_payload << "z") do |event|
-          expect(event.get("tags")).to include("_jsonparse_too_big_failure")
-          expect(event.get("message").size).to eq(decode_size_limit_bytes)
-        end
-      end
-      
       it "should raise an error if the max bytes are exceeded" do
         expect {
           subject.decode(maximum_payload << "z")