Sha256: bde71ece9aafc6a40685234fb24aef59769f65c2f3cab802c97dbac37c775f25
Contents?: true
Size: 878 Bytes
Versions: 28
Compression:
Stored size: 878 Bytes
Contents
require 'spec_helper'
describe 'Reply' do
let(:freddy) { Freddy.build(logger, config) }
let(:destination) { random_destination }
let(:request_payload) { {req: 'load'} }
let(:response_payload) { {res: 'load'} }
after { freddy.close }
context 'when a synchronized request' do
before do
freddy.respond_to(destination) do |payload, msg_handler|
msg_handler.success(response_payload)
end
end
it 'sends reply' do
response = freddy.deliver_with_response(destination, request_payload)
expect(response).to eq(response_payload)
end
it 'does not send the reply to the topic queue' do
freddy.tap_into 'amq.*' do |payload|
@message_received = true
end
freddy.deliver_with_response(destination, request_payload)
default_sleep
expect(@message_received).to be_falsy
end
end
end
Version data entries
28 entries across 28 versions & 2 rubygems