Module | EventMachine::Protocols::Stomp |
In: |
lib/em/protocols/stomp.rb
|
Implements Stomp (docs.codehaus.org/display/STOMP/Protocol).
module StompClient include EM::Protocols::Stomp def connection_completed connect :login => 'guest', :passcode => 'guest' end def receive_msg msg if msg.command == "CONNECTED" subscribe '/some/topic' else p ['got a message', msg] puts msg.body end end end EM.run{ EM.connect 'localhost', 61613, StompClient }
ACK command, for acknowledging receipt of messages
module StompClient include EM::P::Stomp def connection_completed connect :login => 'guest', :passcode => 'guest' # subscribe with ack mode subscribe '/some/topic', true end def receive_msg msg if msg.command == "MESSAGE" ack msg.headers['message-id'] puts msg.body end end end