Name	Size	Mode	Actions
__pycache__/	-	0755	rm
agent.py	525	0644	editdlrm
connection.py	1026	0644	editdlrm
consumer.py	29091	0644	editdlrm
control.py	946	0644	editdlrm
events.py	2054	0644	editdlrm
gossip.py	6863	0644	editdlrm
heart.py	930	0644	editdlrm
mingle.py	2519	0644	editdlrm
tasks.py	1960	0644	editdlrm
__init__.py	391	0644	editdlrm

"""Consumer Broker Connection Bootstep.""" from kombu.common import ignore_errors from celery import bootsteps from celery.utils.log import get_logger __all__ = ('Connection',) logger = get_logger(__name__) info = logger.info class Connection(bootsteps.StartStopStep): """Service managing the consumer broker connection.""" def __init__(self, c, **kwargs): c.connection = None super().__init__(c, **kwargs) def start(self, c): c.connection = c.connect() info('Connected to %s', c.connection.as_uri()) def shutdown(self, c): # We must set self.connection to None here, so # that the green pidbox thread exits. connection, c.connection = c.connection, None if connection: ignore_errors(connection, connection.close) def info(self, c): params = 'N/A' if c.connection: params = c.connection.info() params.pop('password', None) # don't send password. return {'broker': params}