def connect(self):
"""
Create blocking connection in RMQ
:return: pika.BlockingConnection
"""
return BlockingConnection(
parameters=ConnectionParameters(
host=self.host,
port=self.port,
virtual_host=self.vhost,
credentials=PlainCredentials(
username=self.user,
password=self.passwd,
)
)
)
评论列表
文章目录