From ff63eb8dd2f9417d7b6e6f255fb707df10034dcb Mon Sep 17 00:00:00 2001
From: Aleksandra Maciaga <aleksandra.maciaga@nokia.com>
Date: Tue, 21 Apr 2020 11:45:58 +0200
Subject: Fix sonar issue NetconfEndpoint

Issue-ID: INT-1517
Signed-off-by: Aleksandra Maciaga <aleksandra.maciaga@nokia.com>
Change-Id: Ie6d5f5b32dc28ac64a95cec90d483476aee39451
---
 .../java/org/onap/netconfsimulator/websocket/NetconfEndpoint.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

(limited to 'netconfsimulator')

diff --git a/netconfsimulator/src/main/java/org/onap/netconfsimulator/websocket/NetconfEndpoint.java b/netconfsimulator/src/main/java/org/onap/netconfsimulator/websocket/NetconfEndpoint.java
index 5870ee1..5719214 100644
--- a/netconfsimulator/src/main/java/org/onap/netconfsimulator/websocket/NetconfEndpoint.java
+++ b/netconfsimulator/src/main/java/org/onap/netconfsimulator/websocket/NetconfEndpoint.java
@@ -84,11 +84,11 @@ class NetconfEndpoint extends Endpoint {
 
 
     private void addKafkaListener(RemoteEndpoint.Basic remoteEndpoint) {
-        MessageListener messageListener = new NetconfMessageListener(remoteEndpoint);
+        MessageListener<String, String> messageListener = new NetconfMessageListener(remoteEndpoint);
 
         KafkaListenerEntry kafkaListener = kafkaListenerHandler.createKafkaListener(messageListener, TOPIC_NAME);
 
-        AbstractMessageListenerContainer listenerContainer = kafkaListener.getListenerContainer();
+        AbstractMessageListenerContainer<String,String> listenerContainer = kafkaListener.getListenerContainer();
         listenerContainer.start();
         entry = Optional.of(kafkaListener);
     }
-- 
cgit 1.2.3-korg