Merge pull request #329 from uptane/listener-name

Use explicit actorName in groupId prefix if provided
uptane · Dec 7, 2023 · e24e809 · e24e809
2 parents a08b4ca + 526c5da
commit e24e809
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...saging/src/main/scala/com/advancedtelematic/libats/messaging/MessageListenerSupport.scala b/...saging/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