Merge pull request #3630 from VajiraPrabuddhaka/asb-conn-fix

[choreo] Fix unnecessary JMS listener initiating logic when ASBDataplaneTopics specified
wso2 · Dec 16, 2024 · bf94ff8 · bf94ff8
2 parents b300035 + 2af4f01
commit bf94ff8
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/adapter/internal/adapter/adapter.go b/adapter/internal/adapter/adapter.go
@@ -287,7 +287,9 @@ func Run(conf *config.Config) {
 		}
 
 		var connectionURLList = conf.ControlPlane.BrokerConnectionParameters.EventListeningEndpoints
-		if strings.Contains(connectionURLList[0], amqpProtocol) {
+		if len(conf.ControlPlane.ASBDataplaneTopics) > 0 {
+			messaging.InitiateAndProcessEvents(conf)
+		} else if strings.Contains(connectionURLList[0], amqpProtocol) {
 			go messaging.ProcessEvents(conf)
 		} else {
 			messaging.InitiateAndProcessEvents(conf)