Implementation for Polling mode with clustering support

Add dependencies for MSSQL, Oracle and Postgres
wso2 · Sep 11, 2023 · 0f29089 · 0f29089
1 parent ac7671b
commit 0f29089
Show file tree

Hide file tree

Showing 14 changed files with 699 additions and 634 deletions.
diff --git a/...a/org/wso2/carbon/inbound/endpoint/inboundfactory/InboundRequestProcessorFactoryImpl.java b/...a/org/wso2/carbon/inbound/endpoint/inboundfactory/InboundRequestProcessorFactoryImpl.java
@@ -21,7 +21,7 @@
 import org.apache.synapse.inbound.InboundProcessorParams;
 import org.apache.synapse.inbound.InboundRequestProcessor;
 import org.apache.synapse.inbound.InboundRequestProcessorFactory;
-import org.wso2.carbon.inbound.endpoint.protocol.cdc.CDCListener;
+import org.wso2.carbon.inbound.endpoint.protocol.cdc.CDCProcessor;
 import org.wso2.carbon.inbound.endpoint.protocol.generic.GenericEventBasedConsumer;
 import org.wso2.carbon.inbound.endpoint.protocol.generic.GenericEventBasedListener;
 import org.wso2.carbon.inbound.endpoint.protocol.generic.GenericInboundListener;
@@ -99,7 +99,7 @@ public InboundRequestProcessor createInboundProcessor(InboundProcessorParams par
                     inboundRequestProcessor = new InboundGRPCListener(params);
                     break;
                 case cdc:
-                    inboundRequestProcessor = new CDCListener(params);
+                    inboundRequestProcessor = new CDCProcessor(params);
             }
         } else if (params.getClassImpl() != null) {
             if (GenericInboundListener.isListeningInboundEndpoint(params)) {

diff --git a/...point/src/main/java/org/wso2/carbon/inbound/endpoint/protocol/cdc/CDCEndpointManager.java b/...point/src/main/java/org/wso2/carbon/inbound/endpoint/protocol/cdc/CDCEndpointManager.java
diff --git a/.../src/main/java/org/wso2/carbon/inbound/endpoint/protocol/cdc/CDCEventExecutorManager.java b/.../src/main/java/org/wso2/carbon/inbound/endpoint/protocol/cdc/CDCEventExecutorManager.java