(self, event)
| 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) |
nothing calls this directly
no test coverage detected