from kombu import Connection
from tapiriik.settings import RABBITMQ_BROKER_URL
mq = Connection(RABBITMQ_BROKER_URL)
mq.connect()
from kombu import Connection
from tapiriik.settings import RABBITMQ_BROKER_URL
mq = Connection(RABBITMQ_BROKER_URL, transport_options={'confirm_publish': True})
mq.connect()

Enable MQ publish confirmations for scheduler
Enable MQ publish confirmations for scheduler

  from kombu import Connection
  from tapiriik.settings import RABBITMQ_BROKER_URL
- mq = Connection(RABBITMQ_BROKER_URL)
+ mq = Connection(RABBITMQ_BROKER_URL, transport_options={'confirm_publish': True})
  mq.connect()
+ 
Enable MQ publish confirmations for scheduler
## Code Before:
from kombu import Connection
from tapiriik.settings import RABBITMQ_BROKER_URL
mq = Connection(RABBITMQ_BROKER_URL)
mq.connect()
## Instruction:
Enable MQ publish confirmations for scheduler
## Code After:
from kombu import Connection
from tapiriik.settings import RABBITMQ_BROKER_URL
mq = Connection(RABBITMQ_BROKER_URL, transport_options={'confirm_publish': True})
mq.connect()
