ClusterMessagingProtocolClient: add sanity check

Change-Id: Iae7ffcc9c6e0676bc3e68d89744ee9d2bce3054c

 package org.onlab.onos.store.service.impl;
 package org.onlab.onos.store.service.impl;
 
 
+import static com.google.common.base.Verify.verifyNotNull;
 import static org.slf4j.LoggerFactory.getLogger;
 import static org.slf4j.LoggerFactory.getLogger;
+import static org.onlab.onos.store.service.impl.ClusterMessagingProtocol.SERIALIZER;
 
 
 import java.io.IOException;
 import java.io.IOException;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.CompletableFuture;
@@ -122,7 +124,7 @@ public class ClusterMessagingProtocolClient implements ProtocolClient {
                     new ClusterMessage(
                     new ClusterMessage(
                             localNode.id(),
                             localNode.id(),
                             messageType(request),
                             messageType(request),
-                            ClusterMessagingProtocol.SERIALIZER.encode(request));
+                            verifyNotNull(SERIALIZER.encode(request)));
             this.future = future;
             this.future = future;
         }
         }
 
 
@@ -132,7 +134,7 @@ public class ClusterMessagingProtocolClient implements ProtocolClient {
                 byte[] response = clusterCommunicator
                 byte[] response = clusterCommunicator
                     .sendAndReceive(message, remoteNode.id())
                     .sendAndReceive(message, remoteNode.id())
                     .get(RETRY_INTERVAL_MILLIS, TimeUnit.MILLISECONDS);
                     .get(RETRY_INTERVAL_MILLIS, TimeUnit.MILLISECONDS);
-                future.complete(ClusterMessagingProtocol.SERIALIZER.decode(response));
+                future.complete(verifyNotNull(SERIALIZER.decode(response)));
 
 
             } catch (IOException | InterruptedException | ExecutionException | TimeoutException e) {
             } catch (IOException | InterruptedException | ExecutionException | TimeoutException e) {
                 log.warn("RPCTask for {} failed.", request, e);
                 log.warn("RPCTask for {} failed.", request, e);