Method: RosettaQueue::Gateway::StompAdapter#initialize

Defined in:
lib/rosetta_queue/adapters/stomp.rb

#initialize(user, password, host, port) ⇒ StompAdapter

Returns a new instance of StompAdapter.



12
13
14
# File 'lib/rosetta_queue/adapters/stomp.rb', line 12

def initialize(user, password, host, port)
  @conn = Stomp::Connection.open(user, password, host, port, true)
end