1 files changed, 3 insertions, 3 deletions
diff --git a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/DmaapPublisherTaskImpl.java b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/DmaapPublisherTaskImpl.java
index 85b18b8a..c25528bd 100644
--- a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/DmaapPublisherTaskImpl.java
+++ b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/DmaapPublisherTaskImpl.java
@@ -46,7 +46,7 @@ import reactor.core.publisher.Mono;
 public class DmaapPublisherTaskImpl implements DmaapPublisherTask {
 
     private static final Logger LOGGER = LoggerFactory.getLogger(DmaapPublisherTaskImpl.class);
-    private DmaapPublisherConfiguration dmaapPublisherConfiguration;
+    private Config config;
 
     private final PublisherReactiveHttpClientFactory httpClientFactory;
 
@@ -56,7 +56,7 @@ public class DmaapPublisherTaskImpl implements DmaapPublisherTask {
     }
 
     DmaapPublisherTaskImpl(Config config, PublisherReactiveHttpClientFactory httpClientFactory) {
-        this.dmaapPublisherConfiguration = config.getDmaapPublisherConfiguration();
+        this.config = config;
         this.httpClientFactory = httpClientFactory;
     }
 
@@ -72,7 +72,7 @@ public class DmaapPublisherTaskImpl implements DmaapPublisherTask {
 
     @Override
     public DMaaPPublisherReactiveHttpClient resolveClient() throws SSLException{
-            return httpClientFactory.create(dmaapPublisherConfiguration);
+            return httpClientFactory.create(config.getDmaapPublisherConfiguration());
 
     }
 }
 \ No newline at end of file