From 2b0c8a27c337f4fe375fbfb536b5973d9269b269 Mon Sep 17 00:00:00 2001
From: wluyima <wyclif@openmrs.org>
Date: Sun, 21 Nov 2021 14:31:19 -0600
Subject: [PATCH] Deleted unused camel route

---
 .../openmrs/eip/BaseDbBackedCamelTest.java    |  2 +-
 .../resources/camel/db-event-listener.xml     | 50 -------------------
 .../watcher-application-test.properties       |  2 +
 3 files changed, 3 insertions(+), 51 deletions(-)
 delete mode 100644 openmrs-watcher/src/main/resources/camel/db-event-listener.xml

diff --git a/commons/src/test/java/org/openmrs/eip/BaseDbBackedCamelTest.java b/commons/src/test/java/org/openmrs/eip/BaseDbBackedCamelTest.java
index e7d1ebe81..4ba4870e8 100644
--- a/commons/src/test/java/org/openmrs/eip/BaseDbBackedCamelTest.java
+++ b/commons/src/test/java/org/openmrs/eip/BaseDbBackedCamelTest.java
@@ -44,7 +44,7 @@ public abstract class BaseDbBackedCamelTest extends BaseCamelTest {
 	protected DataSource openmrsDataSource;
 	
 	@BeforeClass
-	public static void startContainers() {
+	public static void startMysql() {
 		mysqlContainer.withEnv("MYSQL_ROOT_PASSWORD", "test");
 		mysqlContainer.withDatabaseName("openmrs");
 		mysqlContainer.withCopyFileToContainer(MountableFile.forClasspathResource("my.cnf"), "/etc/mysql/my.cnf");
diff --git a/openmrs-watcher/src/main/resources/camel/db-event-listener.xml b/openmrs-watcher/src/main/resources/camel/db-event-listener.xml
deleted file mode 100644
index 72869ca38..000000000
--- a/openmrs-watcher/src/main/resources/camel/db-event-listener.xml
+++ /dev/null
@@ -1,50 +0,0 @@
-<routes xmlns="http://camel.apache.org/schema/spring">
-    <route id="db-event-listener" errorHandlerRef="watcherErrorHandler">
-        <from uri="direct:db-event-listener" />
-
-        <log message="Received DB event: ${exchangeProperty.event}" />
-
-        <setProperty name="route-retry-count-map">
-            <spel>#{new java.util.HashMap()}</spel>
-        </setProperty>
-        <split>
-            <simple>{{db-event.destinations}}</simple>
-            <script>
-                <spel>#{getProperty('route-retry-count-map').put(body.trim(), 0)}</spel>
-            </script>
-        </split>
-
-        <setProperty name="table-names">
-            <!-- We need to look up failed events for rows in both the parent and subclass tables -->
-            <method beanType="org.openmrs.eip.Utils" method="getTablesInHierarchy(${exchangeProperty.event.tableName})" />
-        </setProperty>
-
-        <when>
-            <simple>${exchangeProperty.event.operation} != 'c'</simple>
-
-            <toD uri="jpa:SenderRetryQueueItem?query=SELECT r FROM SenderRetryQueueItem r WHERE r.event.tableName IN (${exchangeProperty.table-names}) AND r.event.primaryKeyId='${exchangeProperty.event.primaryKeyId}'" />
-
-            <split stopOnException="true">
-                <simple>${body}</simple>
-                <choice>
-                    <when>
-                        <simple>${exchangeProperty.route-retry-count-map.containsKey(${body.route.trim()})} != true</simple>
-                        <throwException exceptionType="java.lang.Exception" message="No listener route found with name ${body.route.trim()}" />
-                    </when>
-                    <otherwise>
-                        <script>
-                            <spel>#{getProperty('route-retry-count-map').put(body.route, getProperty('route-retry-count-map').get(body.route.trim()) + 1)}</spel>
-                        </script>
-                    </otherwise>
-                </choice>
-            </split>
-        </when>
-
-        <setBody>
-            <simple>${exchangeProperty.event}</simple>
-        </setBody>
-
-        <toD uri="{{watcher.uri.event.processor}}" />
-
-    </route>
-</routes>
diff --git a/openmrs-watcher/src/test/resources/watcher-application-test.properties b/openmrs-watcher/src/test/resources/watcher-application-test.properties
index ca7a0515b..b4b58da54 100644
--- a/openmrs-watcher/src/test/resources/watcher-application-test.properties
+++ b/openmrs-watcher/src/test/resources/watcher-application-test.properties
@@ -17,3 +17,5 @@ debezium.db.user=root
 debezium.db.password=test
 debezium.snapshotMode=schema_only
 debezium.snapshotLockingMode=extended
+
+camel.component.direct.block=false