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