[choreo] Remove JMS event listener initiator

wso2 · Dec 16, 2024 · b894023 · b894023
1 parent b300035
commit b894023
Showing 1 changed file with 1 addition and 6 deletions.
diff --git a/adapter/internal/adapter/adapter.go b/adapter/internal/adapter/adapter.go
@@ -286,12 +286,7 @@ func Run(conf *config.Config) {
 			fetchAPIsOnStartUp(conf, nil)
 		}
 
-		var connectionURLList = conf.ControlPlane.BrokerConnectionParameters.EventListeningEndpoints
-		if strings.Contains(connectionURLList[0], amqpProtocol) {
-			go messaging.ProcessEvents(conf)
-		} else {
-			messaging.InitiateAndProcessEvents(conf)
-		}
+		messaging.InitiateAndProcessEvents(conf)
 
 		go synchronizer.UpdateRevokedTokens()
 		// Fetch Key Managers from APIM