diff options
| author |   Bogumil Zebek <bogumil.zebek@nokia.com> | 2020-04-21 11:08:16 +0000 |
|---|---|---|
| committer |   Gerrit Code Review <gerrit@onap.org> | 2020-04-21 11:08:16 +0000 |
| commit | d5b3ca3ee1549757e58c0dc77a1d4accdeaa0402 (patch) | |
| tree | 433d51909117dc3409807a095b7028f9e095484c /netconfsimulator/src | |
| parent | 1cc3f366b58bdd9f87dc37cc45e4b824be8e0b55 (diff) | |
| parent | ff63eb8dd2f9417d7b6e6f255fb707df10034dcb (diff) | |
Merge "Fix sonar issue NetconfEndpoint"
Diffstat (limited to 'netconfsimulator/src')
| -rw-r--r-- | netconfsimulator/src/main/java/org/onap/netconfsimulator/websocket/NetconfEndpoint.java | 4 |
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); } |