lib/message_driver/adapters/bunny_adapter.rb in message-driver-1.0.0 vs lib/message_driver/adapters/bunny_adapter.rb in message-driver-1.0.1
- old
+ new
@@ -339,10 +339,10 @@
raise MessageDriver::TransactionError,
"you can't finish the transaction unless you already in one!"
end
begin
if @in_confirms_transaction
- @channel.wait_for_confirms unless @rollback_only || @channel.nil?
+ @channel.wait_for_confirms unless @rollback_only || @channel.nil? || !@channel.using_publisher_confirms?
elsif is_transactional? && valid? && !@need_channel_reset && @require_commit
handle_errors do
if @rollback_only
@channel.tx_rollback
else