diff --git a/processor/src/main/java/ca/bc/gov/app/service/legacy/LegacyClientPersistenceService.java b/processor/src/main/java/ca/bc/gov/app/service/legacy/LegacyClientPersistenceService.java
index dc7d11f002..52fc087e57 100644
--- a/processor/src/main/java/ca/bc/gov/app/service/legacy/LegacyClientPersistenceService.java
+++ b/processor/src/main/java/ca/bc/gov/app/service/legacy/LegacyClientPersistenceService.java
@@ -62,6 +62,11 @@ boolean filterByType(String clientTypeCode) {
     return !List.of("RSP", "USP", "I").contains(clientTypeCode);
   }
 
+  @Override
+  String getNextChannel() {
+    return ApplicationConstant.SUBMISSION_LEGACY_OTHER_CHANNEL;
+  }
+
   @ServiceActivator(
       inputChannel = ApplicationConstant.SUBMISSION_LEGACY_OTHER_CHANNEL,
       outputChannel = ApplicationConstant.SUBMISSION_LEGACY_CLIENT_PERSIST_CHANNEL,
diff --git a/processor/src/main/java/ca/bc/gov/app/service/legacy/LegacyIndividualPersistenceService.java b/processor/src/main/java/ca/bc/gov/app/service/legacy/LegacyIndividualPersistenceService.java
index 7013c04488..77e51f9560 100644
--- a/processor/src/main/java/ca/bc/gov/app/service/legacy/LegacyIndividualPersistenceService.java
+++ b/processor/src/main/java/ca/bc/gov/app/service/legacy/LegacyIndividualPersistenceService.java
@@ -60,6 +60,10 @@ boolean filterByType(String clientTypeCode) {
     return StringUtils.equalsIgnoreCase(clientTypeCode,"I");
   }
 
+  @Override
+  String getNextChannel() {
+    return ApplicationConstant.SUBMISSION_LEGACY_INDIVIDUAL_CHANNEL;
+  }
 
   /**
    * Generate the individual to be persisted into forest client database.
diff --git a/processor/src/main/java/ca/bc/gov/app/service/legacy/LegacyRegisteredSPPersistenceService.java b/processor/src/main/java/ca/bc/gov/app/service/legacy/LegacyRegisteredSPPersistenceService.java
index 12c71a6824..213ffda263 100644
--- a/processor/src/main/java/ca/bc/gov/app/service/legacy/LegacyRegisteredSPPersistenceService.java
+++ b/processor/src/main/java/ca/bc/gov/app/service/legacy/LegacyRegisteredSPPersistenceService.java
@@ -70,6 +70,11 @@ boolean filterByType(String clientTypeCode) {
     return StringUtils.equalsIgnoreCase(clientTypeCode, "RSP");
   }
 
+  @Override
+  String getNextChannel() {
+    return ApplicationConstant.SUBMISSION_LEGACY_RSP_CHANNEL;
+  }
+
   @ServiceActivator(
       inputChannel = ApplicationConstant.SUBMISSION_LEGACY_RSP_CHANNEL,
       outputChannel = ApplicationConstant.SUBMISSION_LEGACY_CLIENT_PERSIST_CHANNEL,
diff --git a/processor/src/main/java/ca/bc/gov/app/service/legacy/LegacyUnregisteredSPPersistenceService.java b/processor/src/main/java/ca/bc/gov/app/service/legacy/LegacyUnregisteredSPPersistenceService.java
index 1623a020b0..a4d24d4714 100644
--- a/processor/src/main/java/ca/bc/gov/app/service/legacy/LegacyUnregisteredSPPersistenceService.java
+++ b/processor/src/main/java/ca/bc/gov/app/service/legacy/LegacyUnregisteredSPPersistenceService.java
@@ -63,6 +63,11 @@ boolean filterByType(String clientTypeCode) {
     return StringUtils.equalsIgnoreCase(clientTypeCode,"USP");
   }
 
+  @Override
+  String getNextChannel() {
+    return ApplicationConstant.SUBMISSION_LEGACY_USP_CHANNEL;
+  }
+
   /**
    * This method is responsible for generating the forest client for unregistered sole proprietorship.
    * @param message - the message containing the submission id.