(self)
| 98 | self.close() |
| 99 | |
| 100 | def enable(self): |
| 101 | self.producer = Producer(self.channel or self.connection, |
| 102 | exchange=self.exchange, |
| 103 | serializer=self.serializer, |
| 104 | auto_declare=False) |
| 105 | self.enabled = True |
| 106 | for callback in self.on_enabled: |
| 107 | callback() |
| 108 | |
| 109 | def disable(self): |
| 110 | if self.enabled: |