summaryrefslogtreecommitdiffstats
path: root/netconfsimulator/src
diff options
context:
space:
mode:
authorAleksandra Maciaga <aleksandra.maciaga@nokia.com>2020-04-21 11:45:58 +0200
committerAleksandra Maciaga <aleksandra.maciaga@nokia.com>2020-04-21 11:49:07 +0200
commitff63eb8dd2f9417d7b6e6f255fb707df10034dcb (patch)
treed427e811fe8413ada4972c13be53ca738115fb07 /netconfsimulator/src
parenteac5ff61f954cdbda1258de46a1ddca381c76325 (diff)
Fix sonar issue NetconfEndpoint
Issue-ID: INT-1517 Signed-off-by: Aleksandra Maciaga <aleksandra.maciaga@nokia.com> Change-Id: Ie6d5f5b32dc28ac64a95cec90d483476aee39451
Diffstat (limited to 'netconfsimulator/src')
-rw-r--r--netconfsimulator/src/main/java/org/onap/netconfsimulator/websocket/NetconfEndpoint.java4
1 files changed, 2 insertions, 2 deletions
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);
}