def _connect(self):
self._conn = kombu.Connection(
self._hostname,
connect_timeout=self._connect_timeout
)
self._channel = self._conn.channel()
self._exchange = kombu.Exchange(
name=self._exchange_name,
channel=self._channel,
durable=False
)
self._callback_queue = self._create_callback_queue(
self._channel,
self._exchange
)
评论列表
文章目录