I have not find consumer is removed from self._consumers.items() , so I am afraid "consumer.is_declared" is not necessary while they work well before rabbitmq restarting.
if not consumer.is_declared(self): consumer.declare(self)
I have not find consumer is removed from self._consumers .items( ) , so I am afraid "consumer. is_declared" is not necessary while they work well before rabbitmq restarting.
if not consumer. is_declared( self): declare( self)
consumer.