lib/rrj/janus/transactions/session.rb in ruby_rabbitmq_janus-3.0.0.pre.366 vs lib/rrj/janus/transactions/session.rb in ruby_rabbitmq_janus-3.0.0.pre.382
- old
+ new
@@ -26,9 +26,10 @@
choose_queue
yield
end
end
+ # Publish a message to "standard" RabbitMQ queue.
def publish_message(type, options = {})
msg = Janus::Messages::Standard.new(type, opts.merge!(options))
response = read_response(publisher.publish(msg))
Janus::Responses::Standard.new(response)
end