gaspersic/robot-shop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fixed reconnection to rabbitmq in payment app

Browse Source
This commit is contained in:
Dusan Ugarkovic
2019-10-10 13:32:20 +02:00
parent 3ea4306eff
commit 5972124be1
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
payment/rabbitmq.py
View File

@@ -19,7 +19,7 @@ class Publisher:
self._channel = None self._channel = None
def _connect(self): def _connect(self):
if not self._conn or self._conn.is_closed: if not self._conn or self._conn.is_closed or self._channel is None or self._channel.is_closed:
self._conn = pika.BlockingConnection(self._params) self._conn = pika.BlockingConnection(self._params)
self._channel = self._conn.channel() self._channel = self._conn.channel()
self._channel.exchange_declare(exchange=self.EXCHANGE, exchange_type=self.TYPE, durable=True) self._channel.exchange_declare(exchange=self.EXCHANGE, exchange_type=self.TYPE, durable=True)
@@ -34,7 +34,7 @@ class Publisher:
#Publish msg, reconnecting if necessary. #Publish msg, reconnecting if necessary.
def publish(self, msg, headers): def publish(self, msg, headers):
if self._channel is None: if self._channel is None or self._channel.is_closed or self._conn is None or self._conn.is_closed:
self._connect() self._connect()
try: try:
self._publish(msg, headers) self._publish(msg, headers)