def connected(self, msg):
stomper.Engine.connected(self, msg)<EOL>self.log.info("<STR_LIT>" % msg['<STR_LIT>']['<STR_LIT>'])<EOL>def setup_looping_call():<EOL><INDENT>lc = LoopingCall(self.send)<EOL>lc.start(<NUM_LIT:2>)<EOL><DEDENT>reactor.callLater(<NUM_LIT:1>, setup_looping_call)<EOL>f = stomper.Frame()<EOL>f.unpack(stomper.subscribe(DESTINATION))<EOL>f.headers['<STR_LIT>'] = '<STR_LIT:true>'<EOL>return f.pack()<EOL>
Once I've connected I want to subscribe to my the message queue.