mirror of
https://github.com/zulip/zulip.git
synced 2025-11-04 22:13:26 +00:00
queue: Refactor Pika credentials code to be a bit cleaner.
This commit is contained in:
@@ -38,9 +38,10 @@ class SimpleQueueClient(object):
|
|||||||
self._connect()
|
self._connect()
|
||||||
|
|
||||||
def _get_parameters(self):
|
def _get_parameters(self):
|
||||||
|
credentials = pika.PlainCredentials(settings.RABBITMQ_USERNAME,
|
||||||
|
settings.RABBITMQ_PASSWORD)
|
||||||
return pika.ConnectionParameters(settings.RABBITMQ_HOST,
|
return pika.ConnectionParameters(settings.RABBITMQ_HOST,
|
||||||
credentials = pika.PlainCredentials(
|
credentials=credentials)
|
||||||
settings.RABBITMQ_USERNAME, settings.RABBITMQ_PASSWORD))
|
|
||||||
|
|
||||||
def _generate_ctag(self, queue_name):
|
def _generate_ctag(self, queue_name):
|
||||||
return "%s_%s" % (queue_name, str(random.getrandbits(16)))
|
return "%s_%s" % (queue_name, str(random.getrandbits(16)))
|
||||||
|
|||||||
Reference in New Issue
Block a user