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