lib/rrj/admin.rb in ruby_rabbitmq_janus-2.0.0 vs lib/rrj/admin.rb in ruby_rabbitmq_janus-2.1.0.pre.128
- old
+ new
@@ -27,8 +27,10 @@
# @since 2.0.0
def start_transaction_admin(options = {})
session = option.use_current_session?(options)
transaction = Janus::Transactions::Admin.new(session)
transaction.connect { yield(transaction) }
+ rescue
+ raise Errors::RRJAdmin::StartTransactionAdmin, options
end
end
end