Skip to content
This repository was archived by the owner on Dec 5, 2025. It is now read-only.

Commit 297a574

Browse files
committed
[client] Turn on delivery confirmation when sending message to queues (#513)
1 parent a39c78e commit 297a574

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

pycti/connector/opencti_connector_helper.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -307,6 +307,10 @@ def run(self) -> None:
307307
)
308308
self.pika_connection = pika.BlockingConnection(self.pika_parameters)
309309
self.channel = self.pika_connection.channel()
310+
try:
311+
self.channel.confirm_delivery()
312+
except Exception as err: # pylint: disable=broad-except
313+
LOGGER.error("%s", err)
310314
self.channel.basic_qos(prefetch_count=1)
311315
assert self.channel is not None
312316
self.channel.basic_consume(

0 commit comments

Comments
 (0)