lib/amqp/channel.rb in amqp-1.2.1 vs lib/amqp/channel.rb in amqp-1.3.0
- old
+ new
@@ -170,11 +170,11 @@
DEFAULT_REPLY_TEXT = "Goodbye".freeze
attr_reader :id
- attr_reader :exchanges_awaiting_declare_ok, :exchanges_awaiting_delete_ok
+ attr_reader :exchanges_awaiting_declare_ok, :exchanges_awaiting_delete_ok, :exchanges_awaiting_bind_ok, :exchanges_awaiting_unbind_ok
attr_reader :queues_awaiting_declare_ok, :queues_awaiting_delete_ok, :queues_awaiting_bind_ok, :queues_awaiting_unbind_ok, :queues_awaiting_purge_ok, :queues_awaiting_get_response
attr_reader :consumers_awaiting_consume_ok, :consumers_awaiting_cancel_ok
attr_accessor :flow_is_active
@@ -1422,9 +1422,11 @@
def reset_state!
@flow_is_active = true
@queues_awaiting_declare_ok = Array.new
@exchanges_awaiting_declare_ok = Array.new
+ @exchanges_awaiting_bind_ok = Array.new
+ @exchanges_awaiting_unbind_ok = Array.new
@queues_awaiting_delete_ok = Array.new
@exchanges_awaiting_delete_ok = Array.new
@queues_awaiting_purge_ok = Array.new