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