commit cd48bfd694249c9852d94583f74a39078e12f4cd
author Madan Jampani <madan@onlab.us> Wed Mar 25 18:06:22 2015 -0700
committer Gerrit Code Review <gerrit@onlab.us> Thu Mar 26 03:08:48 2015 +0000
tree b185602e24de99c72ab62cf71b194c209116b9da
parent b5dcc51d10dcfcc9e06e9c05d88f06a9025b48a5

Make sure message handling executor references are appropriately managed when we modify the service configuration

Change-Id: I56866dd8c3359de0fcf827fc247024c65a63c5c2

utils/netty/src/main/java/org/onlab/netty/NettyMessagingService.java

diff --git a/utils/netty/src/main/java/org/onlab/netty/NettyMessagingService.java b/utils/netty/src/main/java/org/onlab/netty/NettyMessagingService.java
index 6628bb2..099880d 100644
--- a/utils/netty/src/main/java/org/onlab/netty/NettyMessagingService.java
+++ b/utils/netty/src/main/java/org/onlab/netty/NettyMessagingService.java
@@ -200,12 +200,12 @@
 
     @Override
     public void registerHandler(String type, MessageHandler handler) {
-        handlers.putIfAbsent(type, handler);
+        handlers.put(type, handler);
     }
 
     @Override
     public void registerHandler(String type, MessageHandler handler, ExecutorService executor) {
-        handlers.putIfAbsent(type, new MessageHandler() {
+        handlers.put(type, new MessageHandler() {
             @Override
             public void handle(Message message) throws IOException {
                 executor.submit(() -> {