Method: ActiveMessaging::Adapters::Jms::Connection#unsubscribe

Defined in:
lib/activemessaging/adapters/jms.rb

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



54
55
56
57
58
59
60
61
 
# File 'lib/activemessaging/adapters/jms.rb', line 54

def unsubscribe queue_name, headers={}
  queue_name = check_destination_type queue_name, headers
  consumer = @consumers[queue_name]
  unless consumer.nil?
    consumer.close
    @consumers.delete queue_name
  end
end