ClusterMessagingProtocolServer: cosmetics
Change-Id: Ia44acfa8971196f4c06472d73890cf4fe5722bb6
diff --git a/core/store/dist/src/main/java/org/onlab/onos/store/service/impl/ClusterMessagingProtocolServer.java b/core/store/dist/src/main/java/org/onlab/onos/store/service/impl/ClusterMessagingProtocolServer.java
index 53c3f63..a5f207e 100644
--- a/core/store/dist/src/main/java/org/onlab/onos/store/service/impl/ClusterMessagingProtocolServer.java
+++ b/core/store/dist/src/main/java/org/onlab/onos/store/service/impl/ClusterMessagingProtocolServer.java
@@ -86,13 +86,17 @@
}
}
if (request.getClass().equals(PingRequest.class)) {
- handler.ping((PingRequest) request).whenComplete(new PostExecutionTask<PingResponse>(message));
+ handler.ping((PingRequest) request)
+ .whenComplete(new PostExecutionTask<PingResponse>(message));
} else if (request.getClass().equals(PollRequest.class)) {
- handler.poll((PollRequest) request).whenComplete(new PostExecutionTask<PollResponse>(message));
+ handler.poll((PollRequest) request)
+ .whenComplete(new PostExecutionTask<PollResponse>(message));
} else if (request.getClass().equals(SyncRequest.class)) {
- handler.sync((SyncRequest) request).whenComplete(new PostExecutionTask<SyncResponse>(message));
+ handler.sync((SyncRequest) request)
+ .whenComplete(new PostExecutionTask<SyncResponse>(message));
} else if (request.getClass().equals(SubmitRequest.class)) {
- handler.submit((SubmitRequest) request).whenComplete(new PostExecutionTask<SubmitResponse>(message));
+ handler.submit((SubmitRequest) request)
+ .whenComplete(new PostExecutionTask<SubmitResponse>(message));
} else {
throw new IllegalStateException("Unknown request type: " + request.getClass().getName());
}