lib/rrj/janus/transactions/admin.rb in ruby_rabbitmq_janus-2.5.1 vs lib/rrj/janus/transactions/admin.rb in ruby_rabbitmq_janus-2.6.0.pre.226

- old
+ new

@@ -16,10 +16,10 @@ end # Begin connection with RabbitMQ def connect rabbit.transaction_short do - @publisher = Rabbit::Publisher::PublisherAdmin.new(rabbit.channel) + @publisher = Rabbit::Publisher::Admin.new(rabbit.channel) yield end rescue raise Errors::Janus::TransactionAdmin::Connect end