Method: RosettaQueue::Gateway::StompAdapter#send_message

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

#send_message(destination, message, options) ⇒ Object



49
50
51
52
# File 'lib/rosetta_queue/adapters/stomp.rb', line 49

def send_message(destination, message, options)
  RosettaQueue.logger.info("Publishing to #{destination} :: #{message}")        
  @conn.send(destination, message, options)
end