(self, event)
| 49 | self.address = address |
| 50 | |
| 51 | def on_start(self, event): |
| 52 | self.container = event.container |
| 53 | self.conn = event.container.connect(self.host, reconnect=False, desired_capabilities=["ANONYMOUS-RELAY"]) |
| 54 | self.receiver = event.container.create_receiver(self.conn, self.address) |
| 55 | self.senders = {} |
| 56 | self.relay = None |
| 57 | |
| 58 | def on_message(self, event): |
| 59 | sender = self.relay |
nothing calls this directly
no test coverage detected