| 25 | |
| 26 | |
| 27 | class Recv(MessagingHandler): |
| 28 | def __init__(self, url, count): |
| 29 | super(Recv, self).__init__() |
| 30 | self.url = Url(url) |
| 31 | self.expected = count |
| 32 | self.received = 0 |
| 33 | |
| 34 | def on_start(self, event): |
| 35 | conn = event.container.connect(self.url) |
| 36 | event.container.create_receiver(conn, self.url.path, options=Selector("colour = 'green'")) |
| 37 | |
| 38 | def on_message(self, event): |
| 39 | print(event.message.body) |
| 40 | self.received += 1 |
| 41 | if self.received == self.expected: |
| 42 | event.receiver.close() |
| 43 | event.connection.close() |
| 44 | |
| 45 | |
| 46 | parser = optparse.OptionParser(usage="usage: %prog [options]") |