Skip to content

Commit

Permalink
out_http: Add test for connection recreation
Browse files Browse the repository at this point in the history
Signed-off-by: Christian Norbert Menges <christian.norbert.menges@sap.com>
  • Loading branch information
Garfield96 committed Nov 6, 2023
1 parent 8fc7ddb commit 7ba811d
Showing 1 changed file with 36 additions and 0 deletions.
36 changes: 36 additions & 0 deletions test/plugin/test_out_http.rb
Expand Up @@ -426,4 +426,40 @@ def test_write_with_https
assert_not_empty result.headers
end
end

sub_test_case 'connection_reuse' do
def server_port
19883
end

def test_connection_recreation
d = create_driver(%[
endpoint http://127.0.0.1:#{server_port}/test
reuse_connections true
])

d.run(default_tag: 'test.http', shutdown: false) do
d.feed(test_events[0])
end

data = @@result.data

# Restart server to simulate connection loss
@@http_server_thread.kill
@@http_server_thread.join
@@http_server_thread = Thread.new do
run_http_server
end

d.run(default_tag: 'test.http') do
d.feed(test_events[1])
end

result = @@result
assert_equal 'POST', result.method
assert_equal 'application/x-ndjson', result.content_type
assert_equal test_events, data.concat(result.data)
assert_not_empty result.headers
end
end
end

0 comments on commit 7ba811d

Please sign in to comment.