From ac375cd23c198a84b456b0bd8b701d4d29137125 Mon Sep 17 00:00:00 2001
From: Rostislav_Dublin <Rostislav_Dublin@epam.com>
Date: Wed, 1 Dec 2021 17:23:10 +0300
Subject: [PATCH] OQM stuff added to register Subscribers on all Pull
Subscriptions. OQM successfully receives events from subscriptions and
conduct to finite clients webhook endpoints
---
.../provider/gcp/pubsub/OqmSubscriberManager.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
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 55bdc1fe9..36f57d916 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();
--
GitLab