diff --git a/processor/src/main/java/ca/bc/gov/app/service/legacy/LegacyPersistenceService.java b/processor/src/main/java/ca/bc/gov/app/service/legacy/LegacyPersistenceService.java
index 93a3c54077..6e6d03cc13 100644
--- a/processor/src/main/java/ca/bc/gov/app/service/legacy/LegacyPersistenceService.java
+++ b/processor/src/main/java/ca/bc/gov/app/service/legacy/LegacyPersistenceService.java
@@ -23,7 +23,7 @@ public Mono<MessagingWrapper<Integer>> persist(
         Flux
             .fromStream(persistenceServices.stream())
             .filter(service -> service.filterByType(
-                    message.parameters().get(ApplicationConstant.SUBMISSION_TYPE).toString()
+                    message.parameters().get(ApplicationConstant.CLIENT_TYPE_CODE).toString()
                 )
             )
             .next()