mirror of https://github.com/celery/kombu.git
parent
3a0454c21d
commit
e9e1edf396
|
@ -21,7 +21,12 @@ from .utils.objects import cached_property
|
||||||
__all__ = ('ConsumerMixin', 'ConsumerProducerMixin')
|
__all__ = ('ConsumerMixin', 'ConsumerProducerMixin')
|
||||||
|
|
||||||
logger = get_logger(__name__)
|
logger = get_logger(__name__)
|
||||||
debug, info, warn, error = logger.debug, logger.info, logger.warn, logger.error
|
debug, info, warn, error = (
|
||||||
|
logger.debug,
|
||||||
|
logger.info,
|
||||||
|
logger.warning,
|
||||||
|
logger.error
|
||||||
|
)
|
||||||
|
|
||||||
W_CONN_LOST = """\
|
W_CONN_LOST = """\
|
||||||
Connection to broker lost, trying to re-establish connection...\
|
Connection to broker lost, trying to re-establish connection...\
|
||||||
|
|
|
@ -53,7 +53,7 @@ def parse_url(url):
|
||||||
query[key] = getattr(ssl, query[key])
|
query[key] = getattr(ssl, query[key])
|
||||||
else:
|
else:
|
||||||
query[key] = None
|
query[key] = None
|
||||||
logger.warn('Defaulting to insecure SSL behaviour.')
|
logger.warning('Defaulting to insecure SSL behaviour.')
|
||||||
|
|
||||||
if 'ssl' not in query:
|
if 'ssl' not in query:
|
||||||
query['ssl'] = {}
|
query['ssl'] = {}
|
||||||
|
|
Loading…
Reference in New Issue