From 526c5da0f1f69cc5b313901e70d32428c43c531d Mon Sep 17 00:00:00 2001 From: Simao Mata Date: Thu, 7 Dec 2023 10:29:26 +0000 Subject: [PATCH] Use explicit actorName in groupId prefix if provided --- .../libats/messaging/MessageListenerSupport.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/libats-messaging/src/main/scala/com/advancedtelematic/libats/messaging/MessageListenerSupport.scala b/libats-messaging/src/main/scala/com/advancedtelematic/libats/messaging/MessageListenerSupport.scala index 6f702ff..13aad49 100644 --- a/libats-messaging/src/main/scala/com/advancedtelematic/libats/messaging/MessageListenerSupport.scala +++ b/libats-messaging/src/main/scala/com/advancedtelematic/libats/messaging/MessageListenerSupport.scala @@ -31,7 +31,7 @@ trait MessageListenerSupport { val ref = system.actorOf( MessageListener - .props[T](globalConfig, loggedOperation, groupId, busListenerMonitor), + .props[T](globalConfig, loggedOperation, groupId + actorNamePrefix.getOrElse(""), busListenerMonitor), actorNamePrefix.getOrElse("") + ml.streamName + "-listener") ref ! Subscribe ref