ONOS-180 Suppressing a few superfluous stack traces on shutdown.

Change-Id: If648b9d7658e8ee57a0e9eb157b12120f0ea20bd

@@ -21,6 +21,7 @@ import java.net.InetSocketAddress;
 import java.net.SocketAddress;
 import java.net.SocketAddress;
 import java.util.Collections;
 import java.util.Collections;
 import java.util.List;
 import java.util.List;
+import java.util.concurrent.RejectedExecutionException;
 import java.util.concurrent.atomic.AtomicInteger;
 import java.util.concurrent.atomic.AtomicInteger;
 
 
 import org.jboss.netty.channel.Channel;
 import org.jboss.netty.channel.Channel;
@@ -50,6 +51,8 @@ public abstract class AbstractOpenFlowSwitch implements OpenFlowSwitchDriver {
 
 
     protected final Logger log = LoggerFactory.getLogger(getClass());
     protected final Logger log = LoggerFactory.getLogger(getClass());
 
 
+    private static final String SHUTDOWN_MSG = "Worker has already been shutdown";
+
     protected Channel channel;
     protected Channel channel;
     protected String channelId;
     protected String channelId;
 
 
@@ -97,14 +100,26 @@ public abstract class AbstractOpenFlowSwitch implements OpenFlowSwitchDriver {
     @Override
     @Override
     public final void sendMsg(OFMessage m) {
     public final void sendMsg(OFMessage m) {
         if (role == RoleState.MASTER) {
         if (role == RoleState.MASTER) {
-            this.write(m);
+            try {
+                this.write(m);
+            } catch (RejectedExecutionException e) {
+                if (!e.getMessage().contains(SHUTDOWN_MSG)) {
+                    throw e;
+                }
+            }
         }
         }
     }
     }
 
 
     @Override
     @Override
     public final void sendMsg(List<OFMessage> msgs) {
     public final void sendMsg(List<OFMessage> msgs) {
         if (role == RoleState.MASTER) {
         if (role == RoleState.MASTER) {
-            this.write(msgs);
+            try {
+                this.write(msgs);
+            } catch (RejectedExecutionException e) {
+                if (!e.getMessage().contains(SHUTDOWN_MSG)) {
+                    throw e;
+                }
+            }
         }
         }
     }
     }
 
 
@@ -296,7 +311,6 @@ public abstract class AbstractOpenFlowSwitch implements OpenFlowSwitchDriver {
             }
             }
         }  else {
         }  else {
             log.warn("Failed to set role for {}", this.getStringId());
             log.warn("Failed to set role for {}", this.getStringId());
-            return;
         }
         }
     }
     }