github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-24 22:57:16 -04:00
Code Issues Projects Releases Packages Wiki Activity

Test: Java proxied QueueReadClient unwrapping

Browse source 
Fixes #11391
This commit is contained in:
Karol Bucek 2019-12-12 20:18:39 +01:00
parent 9d497a13f2
commit fa199fe1ec
1 changed files with 10 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

10
logstash-core/spec/logstash/util/wrapped_synchronous_queue_spec.rb
View file

@ -117,6 +117,16 @@ describe LogStash::WrappedSynchronousQueue do
(0..2).each {|i| expect(received).to include("value-#{i}")} (0..2).each {|i| expect(received).to include("value-#{i}")}
(3..4).each {|i| expect(received).to include("generated-#{i}")} (3..4).each {|i| expect(received).to include("generated-#{i}")}
end end
it "handles Java proxied read-batch object" do
batch = []
3.times { |i| batch.push(LogStash::Event.new({"message" => "value-#{i}"})) }
write_client.push_batch(batch)
read_batch = read_client.read_batch
expect { read_client.close_batch(read_batch) }.to_not raise_error
expect { read_client.close_batch(read_batch.to_java) }.to_not raise_error
end
end end
end end
end end