diff options
Diffstat (limited to 'kombu/transport')
| -rw-r--r-- | kombu/transport/SLMQ.py | 2 | ||||
| -rw-r--r-- | kombu/transport/azurestoragequeues.py | 2 | ||||
| -rw-r--r-- | kombu/transport/base.py | 1 | ||||
| -rw-r--r-- | kombu/transport/filesystem.py | 2 | ||||
| -rw-r--r-- | kombu/transport/qpid.py | 8 | ||||
| -rw-r--r-- | kombu/transport/virtual/base.py | 2 |
6 files changed, 7 insertions, 10 deletions
diff --git a/kombu/transport/SLMQ.py b/kombu/transport/SLMQ.py index 4c9ea743..489db3bd 100644 --- a/kombu/transport/SLMQ.py +++ b/kombu/transport/SLMQ.py @@ -46,7 +46,7 @@ class Channel(virtual.Channel): if no_ack: self._noack_queues.add(queue) return super().basic_consume(queue, no_ack, - *args, **kwargs) + *args, **kwargs) def basic_cancel(self, consumer_tag): if consumer_tag in self._consumers: diff --git a/kombu/transport/azurestoragequeues.py b/kombu/transport/azurestoragequeues.py index b3a93662..a38aa748 100644 --- a/kombu/transport/azurestoragequeues.py +++ b/kombu/transport/azurestoragequeues.py @@ -59,7 +59,7 @@ class Channel(virtual.Channel): self._noack_queues.add(queue) return super().basic_consume(queue, no_ack, - *args, **kwargs) + *args, **kwargs) def entity_name(self, name, table=CHARS_REPLACE_TABLE): """Format AMQP queue name into a valid Azure Storage Queue name.""" diff --git a/kombu/transport/base.py b/kombu/transport/base.py index 724b9078..1b7fa5b0 100644 --- a/kombu/transport/base.py +++ b/kombu/transport/base.py @@ -93,7 +93,6 @@ class StdChannel: Reply queue semantics: can be used to delete the queue after transient reply message received. """ - pass def prepare_queue_arguments(self, arguments, **kwargs): return arguments diff --git a/kombu/transport/filesystem.py b/kombu/transport/filesystem.py index 038632b9..5dc64162 100644 --- a/kombu/transport/filesystem.py +++ b/kombu/transport/filesystem.py @@ -66,7 +66,7 @@ class Channel(virtual.Channel): def _put(self, queue, payload, **kwargs): """Put `message` onto `queue`.""" filename = '{}_{}.{}.msg'.format(int(round(monotonic() * 1000)), - uuid.uuid4(), queue) + uuid.uuid4(), queue) filename = os.path.join(self.data_folder_out, filename) try: diff --git a/kombu/transport/qpid.py b/kombu/transport/qpid.py index 3d5a7029..897d9ba4 100644 --- a/kombu/transport/qpid.py +++ b/kombu/transport/qpid.py @@ -468,12 +468,12 @@ class Channel(base.StdChannel): """ if not exchange: - address = '{}; {{assert: always, node: {{type: queue}}}}'.format( - routing_key) + address = f'{routing_key}; ' \ + '{{assert: always, node: {{type: queue}}}}' msg_subject = None else: - address = '{}/{}; {{assert: always, node: {{type: topic}}}}'.format( - exchange, routing_key) + address = f'{exchange}/{routing_key}; '\ + '{{assert: always, node: {{type: topic}}}}' msg_subject = str(routing_key) sender = self.transport.session.sender(address) qpid_message = qpid.messaging.Message(content=message, diff --git a/kombu/transport/virtual/base.py b/kombu/transport/virtual/base.py index f1477c66..1f1b563e 100644 --- a/kombu/transport/virtual/base.py +++ b/kombu/transport/virtual/base.py @@ -302,7 +302,6 @@ class QoS: This is implementation optional, and currently only used by the Redis transport. """ - pass class Message(base.Message): @@ -385,7 +384,6 @@ class AbstractChannel: Your transport can override this method if it needs to do something whenever a new queue is declared. """ - pass def _has_queue(self, queue, **kwargs): """Verify that queue exists. |