Sha256: a5592d4fc826dee230486febb3397497fbc0faba54fc3ca73f6a08f5e19664bc
Contents?: true
Size: 739 Bytes
Versions: 11
Compression:
Stored size: 739 Bytes
Contents
require 'spec_helper'
describe Freddy::ResponderHandler do
let(:freddy) { Freddy.build(logger, config) }
let(:destination) { random_destination }
let(:payload) { {pay: 'load'} }
it 'can cancel listening for messages' do
consumer_handler = freddy.respond_to destination do
@messages_count ||= 0
@messages_count += 1
end
deliver
consumer_handler.cancel
deliver
expect(@messages_count).to eq 1
end
it 'can join the thread to the consumer' do
consumer_handler = freddy.respond_to destination do
end
unreachable = true
Thread.new do
consumer_handler.join
unreachable = false
end
wait_for { unreachable }
expect(unreachable).to be(true)
end
end
Version data entries
11 entries across 11 versions & 1 rubygems