Method: Klomp::Connection#unsubscribe

Defined in:
lib/klomp/connection.rb

#unsubscribe(queue, headers = {}) ⇒ Object 



59
60
61
62
 
# File 'lib/klomp/connection.rb', line 59

def unsubscribe(queue, headers = {})
  queue = queue.headers['destination'] if Frames::Subscribe === queue
  write Frames::Unsubscribe.new(queue, headers) if subscriptions.delete queue
end