feat: 🔧 add possibility to enable/disable exclusive queue feature

juntossomosmais · Jul 28, 2023 · c73de9c · c73de9c
1 parent ba1300d
commit c73de9c
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 1 deletion.
diff --git a/django_outbox_pattern/consumers.py b/django_outbox_pattern/consumers.py
@@ -114,6 +114,7 @@ def _subscribe(self, destination, subscribe_id, headers, queue_name=None, dlq=Fa
             queue_name = f"DLQ.{queue_name}"
         headers.update(
             {
+                "exclusive": settings.DAFAULT_EXCLUSIVE_QUEUE,
                 "x-queue-name": queue_name,
                 "x-dead-letter-routing-key": f"DLQ.DLQ.{queue_name}" if dlq else f"DLQ.{queue_name}",
                 "x-dead-letter-exchange": "",

diff --git a/django_outbox_pattern/settings.py b/django_outbox_pattern/settings.py
@@ -33,6 +33,7 @@
 DEFAULT_STOMP_CERT_VALIDATOR = DJANGO_OUTBOX_PATTERN.get("DEFAULT_STOMP_CERT_VALIDATOR", None)
 DEFAULT_STOMP_SSL_VERSION = DJANGO_OUTBOX_PATTERN.get("DEFAULT_STOMP_SSL_VERSION", None)
 DEFAULT_STOMP_SSL_PASSWORD = DJANGO_OUTBOX_PATTERN.get("DEFAULT_STOMP_SSL_PASSWORD", None)
+DAFAULT_EXCLUSIVE_QUEUE = DJANGO_OUTBOX_PATTERN.get("DAFAULT_EXCLUSIVE_QUEUE", False)
 DAYS_TO_KEEP_DATA = DJANGO_OUTBOX_PATTERN.get("DAYS_TO_KEEP_DATA", 30)
 REMOVE_DATA_CACHE_TTL = DJANGO_OUTBOX_PATTERN.get("REMOVE_DATA_CACHE_TTL", 86400)
 OUTBOX_PATTERN_PUBLISHER_CACHE_KEY = DJANGO_OUTBOX_PATTERN.get(

diff --git a/pyproject.toml b/pyproject.toml
@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "django-outbox-pattern"
-version = "0.14.0"
+version = "0.15.0"
 description = "A django application to make it easier to use the transactional outbox pattern"
 license = "MIT"
 authors = ["Hugo Brilhante <[email protected]>"]