[choreo] Remove JMS event listener initiator

wso2 · Dec 16, 2024 · 2af4f01 · 2af4f01
1 parent b300035
commit 2af4f01
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)