def reset_state!
@flow_is_active = true
@queues_awaiting_declare_ok = Array.new
@exchanges_awaiting_declare_ok = Array.new
@queues_awaiting_delete_ok = Array.new
@exchanges_awaiting_delete_ok = Array.new
@queues_awaiting_purge_ok = Array.new
@queues_awaiting_bind_ok = Array.new
@queues_awaiting_unbind_ok = Array.new
@consumers_awaiting_consume_ok = Array.new
@consumers_awaiting_cancel_ok = Array.new
@queues_awaiting_get_response = Array.new
@callbacks = @callbacks.delete_if { |k, v| !RECOVERY_EVENTS.include?(k) }
end