Skip to content

Commit 2f6618e

Browse files
committed
fix(RabbitMQ): add some default value, force auth
1 parent 2740d0e commit 2f6618e

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

khl/rabbitmq.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,8 +22,8 @@ class RabbitMQ:
2222
_queue: AbstractRobustQueue = None
2323
_exchange: AbstractExchange = None
2424

25-
def __init__(self, host: str, port: int, queue: str, qos: int, heartbeat: int, login: str = '', password: str = '',
26-
key: str = '', key_digits: int = 16, is_producer: bool = False):
25+
def __init__(self, login: str, password: str, host: str = '127.0.0.1', port: int = 5672, queue: str = 'kook',
26+
qos: int = 10, heartbeat: int = 30, key: str = '', key_digits: int = 16, is_producer: bool = False):
2727
self._host = host
2828
self._port = port
2929
self.queue = queue

0 commit comments

Comments
 (0)