From b894023e7d3a692897e0a4bc4fde8db12ab96d1b Mon Sep 17 00:00:00 2001 From: VajiraPrabuddhaka Date: Mon, 16 Dec 2024 17:28:51 +0530 Subject: [PATCH] [choreo] Remove JMS event listener initiator --- adapter/internal/adapter/adapter.go | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) diff --git a/adapter/internal/adapter/adapter.go b/adapter/internal/adapter/adapter.go index 1eaa32898e..715eab5191 100644 --- 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