Merge pull request #3406 from arunans23/removecdc

Remove inbuilt CDC implementation
wso2 · Jul 11, 2024 · 9015ea5 · 9015ea5
2 parents 822ea28 + 75cf0e4
commit 9015ea5
Show file tree

Hide file tree

Showing 11 changed files with 2 additions and 830 deletions.
diff --git a/components/mediation/inbound-endpoints/org.wso2.micro.integrator.inbound.endpoint/pom.xml b/components/mediation/inbound-endpoints/org.wso2.micro.integrator.inbound.endpoint/pom.xml
@@ -170,10 +170,6 @@
             <groupId>org.apache.axis2.transport</groupId>
             <artifactId>axis2-transport-rabbitmq-amqp</artifactId>
         </dependency>
-        <dependency>
-            <groupId>org.wso2.orbit.debezium</groupId>
-            <artifactId>debezium</artifactId>
-        </dependency>
         <dependency>
             <groupId>org.apache.logging.log4j</groupId>
             <artifactId>log4j-core</artifactId>
@@ -184,14 +180,6 @@
             <artifactId>log4j-api</artifactId>
             <scope>test</scope>
         </dependency>
-        <dependency>
-            <groupId>com.google.code.gson</groupId>
-            <artifactId>gson</artifactId>
-        </dependency>
-        <dependency>
-            <groupId>org.wso2.carbon</groupId>
-            <artifactId>org.wso2.carbon.securevault</artifactId>
-        </dependency>
     </dependencies>
     <build>
         <plugins>
@@ -224,8 +212,7 @@
                         </Private-Package>
                         <Import-Package>
                             org.wso2.carbon.inbound.endpoint.persistence,
-                            org.wso2.carbon.inbound.endpoint.osgi.service,
-                            *;resolution:=optional
+                            org.wso2.carbon.inbound.endpoint.osgi.service;
                         </Import-Package>
                         <DynamicImport-Package>*</DynamicImport-Package>
                         <Fragment-Host>

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,6 @@
 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.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;
@@ -45,7 +44,7 @@
  */
 public class InboundRequestProcessorFactoryImpl implements InboundRequestProcessorFactory {
 
-    public static enum Protocols {jms, file, http, https, hl7, kafka, mqtt, rabbitmq, ws, wss, grpc, httpws, httpswss, cdc}
+    public static enum Protocols {jms, file, http, https, hl7, kafka, mqtt, rabbitmq, ws, wss, grpc, httpws, httpswss}
 
     /**
      * return underlying Request Processor Implementation according to protocol
@@ -98,8 +97,6 @@ public InboundRequestProcessor createInboundProcessor(InboundProcessorParams par
                 case grpc:
                     inboundRequestProcessor = new InboundGRPCListener(params);
                     break;
-                case cdc:
-                    inboundRequestProcessor = new CDCProcessor(params);
             }
         } else if (params.getClassImpl() != null) {
             if (GenericInboundListener.isListeningInboundEndpoint(params)) {

diff --git a/....endpoint/src/main/java/org/wso2/carbon/inbound/endpoint/protocol/cdc/CDCEventOutput.java b/....endpoint/src/main/java/org/wso2/carbon/inbound/endpoint/protocol/cdc/CDCEventOutput.java
diff --git a/...ndpoint/src/main/java/org/wso2/carbon/inbound/endpoint/protocol/cdc/CDCInjectHandler.java b/...ndpoint/src/main/java/org/wso2/carbon/inbound/endpoint/protocol/cdc/CDCInjectHandler.java