from stomping import Stomping, route

class MyStomping(Stomping):

  def init(self):
    self.send('/queue/test1', 'init test1')
    self.send('/queue/test2', 'init test2')

  @route('/queue/test1')
  def a_test(self, message):
    print 'a_test: %s' % message['body']

  @route('/queue/test1')
  @route('/queue/test2')
  def b_test(self, message):
    print 'b_test: %s' % message['body']

if __name__ == '__main__':
  #stomp = MyStomping(host='127.0.0.1', port=61613, username='guest', password='guest')
  stomp = MyStomping()
  stomp.run()