From 2af4f01fa86fbac6b728ee83a1d95ec4717b0bd1 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 | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/adapter/internal/adapter/adapter.go b/adapter/internal/adapter/adapter.go index 1eaa32898e..f43e3a2585 100644 --- 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)