| 23 | |
| 24 | |
| 25 | class Recv(MessagingHandler): |
| 26 | def __init__(self): |
| 27 | super(Recv, self).__init__() |
| 28 | |
| 29 | def on_start(self, event): |
| 30 | conn = event.container.connect("localhost:5672") |
| 31 | event.container.create_receiver(conn, "examples", options=Copy()) |
| 32 | |
| 33 | def on_message(self, event): |
| 34 | print(event.message) |
| 35 | if event.receiver.queued == 0 and event.receiver.drained: |
| 36 | event.connection.close() |
| 37 | |
| 38 | |
| 39 | try: |