Module | EventMachine::Protocols::Stomp |
In: |
lib/protocols/stomp.rb
|
Implements Stomp (docs.codehaus.org/display/STOMP/Protocol).
class StompClient < EM::Connection 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 }