Sha256: 858357355b8beffd034b3dc773aa419402dc1546dd065439a9f04af436d458d4
Contents?: true
Size: 1.2 KB
Versions: 10
Compression:
Stored size: 1.2 KB
Contents
# encoding: utf-8
require "lumberjack/beats/client"
require "lumberjack/beats/server"
require "flores/random"
require "flores/pki"
require "spec_helper"
Thread.abort_on_exception = true
describe "Server" do
let(:certificate) { Flores::PKI.generate }
let(:certificate_file_crt) { "certificate.crt" }
let(:certificate_file_key) { "certificate.key" }
let(:port) { Flores::Random.integer(1024..65335) }
let(:tcp_port) { port + 1 }
let(:host) { "127.0.0.1" }
let(:queue) { [] }
before do
expect(File).to receive(:read).at_least(1).with(certificate_file_crt) { certificate.first.to_s }
expect(File).to receive(:read).at_least(1).with(certificate_file_key) { certificate.last.to_s }
end
it "should not block when closing the server" do
server = Lumberjack::Beats::Server.new(:port => port,
:address => host,
:ssl_certificate => certificate_file_crt,
:ssl_key => certificate_file_key)
thread = Thread.new do
server.run do |event|
queue << event
end
end
sleep(1) while thread.status != "run"
server.close
sleep(2)
expect(thread.status).to be_falsey
end
end
Version data entries
10 entries across 10 versions & 1 rubygems