diff --git a/provider/notification-gcp/src/main/java/org/opengroup/osdu/notification/provider/gcp/pubsub/OqmSubscriberManager.java b/provider/notification-gcp/src/main/java/org/opengroup/osdu/notification/provider/gcp/pubsub/OqmSubscriberManager.java
index 55bdc1fe9dd576ca44db3b08087f1d1c49a55615..36f57d916a8973e061d133ccf4b1e6c804853482 100644
--- a/provider/notification-gcp/src/main/java/org/opengroup/osdu/notification/provider/gcp/pubsub/OqmSubscriberManager.java
+++ b/provider/notification-gcp/src/main/java/org/opengroup/osdu/notification/provider/gcp/pubsub/OqmSubscriberManager.java
@@ -25,7 +25,7 @@ import org.opengroup.osdu.core.gcp.oqm.driver.OqmDriver;
 import org.opengroup.osdu.core.gcp.oqm.driver.OqmDriverRuntimeException;
 import org.opengroup.osdu.core.gcp.oqm.model.*;
 import org.opengroup.osdu.notification.provider.gcp.mappers.oqm.OqmConfigurationProperties;
-import org.opengroup.osdu.notification.service.NotificationHandler;
+import org.opengroup.osdu.notification.provider.gcp.pubsub.di.OqmNotificationHandler;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
 import org.springframework.context.annotation.Scope;
 import org.springframework.stereotype.Component;
@@ -70,7 +70,7 @@ public class OqmSubscriberManager {
 
     private final ITenantFactory tenantInfoFactory;
     private final OqmDriver driver;
-    private final NotificationHandler notificationHandler;
+    private final OqmNotificationHandler notificationHandler;
     private final OqmConfigurationProperties properties;
 
     private final Long constructDate = System.currentTimeMillis();