From c2f1f9e8a2a87733720eb5fc64430fb6fdc5c428 Mon Sep 17 00:00:00 2001 From: tawoe Date: Thu, 12 Mar 2026 20:36:38 +0100 Subject: [PATCH] fix obp derfault request queue --- .env.example | 2 +- src/main/scala/com/tesobe/obp/adapter/config/Config.scala | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/.env.example b/.env.example index 1cfb670..55cacc3 100644 --- a/.env.example +++ b/.env.example @@ -17,7 +17,7 @@ RABBITMQ_USERNAME=guest RABBITMQ_PASSWORD=guest # Queue names (must match OBP-API configuration) -RABBITMQ_REQUEST_QUEUE=obp.request +RABBITMQ_REQUEST_QUEUE=obp_rpc_queue RABBITMQ_RESPONSE_QUEUE=obp.response # Performance tuning diff --git a/src/main/scala/com/tesobe/obp/adapter/config/Config.scala b/src/main/scala/com/tesobe/obp/adapter/config/Config.scala index ceaf1b6..3655674 100644 --- a/src/main/scala/com/tesobe/obp/adapter/config/Config.scala +++ b/src/main/scala/com/tesobe/obp/adapter/config/Config.scala @@ -105,7 +105,7 @@ object Config { ) val queueConfig = QueueConfig( - requestQueue = env("RABBITMQ_REQUEST_QUEUE", "obp.request"), + requestQueue = env("RABBITMQ_REQUEST_QUEUE", "obp_rpc_queue"), responseQueue = env("RABBITMQ_RESPONSE_QUEUE", "obp.response"), prefetchCount = env("RABBITMQ_PREFETCH_COUNT", "10").toInt,