|
|
@@ -206,7 +206,7 @@ class RabbitMQ:
|
|
|
def _channel(self, channel: AmqpStormChannel):
|
|
|
self.__channel = channel
|
|
|
|
|
|
- def add_batch(self, queue, datas, exchange='', routing_key='', **kwargs):
|
|
|
+ def add_batch(self, queue, datas, exchange="", routing_key="", **kwargs):
|
|
|
"""
|
|
|
批量发布消息
|
|
|
|
|
|
@@ -219,7 +219,7 @@ class RabbitMQ:
|
|
|
for data in data_lst:
|
|
|
self.add(data, queue, exchange, routing_key, **kwargs)
|
|
|
|
|
|
- def add(self, data, queue='', exchange='', routing_key='', properties=None):
|
|
|
+ def add(self, data, queue="", exchange="", routing_key="", properties=None):
|
|
|
"""
|
|
|
发布消息
|
|
|
|
|
|
@@ -318,7 +318,7 @@ class RabbitMQ:
|
|
|
else:
|
|
|
raise why
|
|
|
|
|
|
- def declare_bind(self, queue='', exchange='', routing_key=''):
|
|
|
+ def declare_bind(self, queue="", exchange="", routing_key=""):
|
|
|
"""
|
|
|
声明队列和交换机，同时将队列绑定交换机
|
|
|
|
|
|
@@ -344,7 +344,7 @@ class RabbitMQ:
|
|
|
limit=None,
|
|
|
to_tuple=False,
|
|
|
auto_decode=True,
|
|
|
- correlation_id='',
|
|
|
+ correlation_id="",
|
|
|
use_filter=False
|
|
|
):
|
|
|
"""
|
