Yuta HIGUCHI

ClusterMessagingProtocolClient: disable retries at CopyCat Protocol layer

Change-Id: I92b4b975797eea10041d5eba056f8583c1f9ba56
...@@ -132,18 +132,18 @@ public class ClusterMessagingProtocolClient implements ProtocolClient { ...@@ -132,18 +132,18 @@ public class ClusterMessagingProtocolClient implements ProtocolClient {
132 future.complete(ClusterMessagingProtocol.SERIALIZER.decode(response)); 132 future.complete(ClusterMessagingProtocol.SERIALIZER.decode(response));
133 133
134 } catch (IOException | InterruptedException | ExecutionException | TimeoutException e) { 134 } catch (IOException | InterruptedException | ExecutionException | TimeoutException e) {
135 - if (message.subject().equals(ClusterMessagingProtocol.COPYCAT_SYNC) || 135 +// if (message.subject().equals(ClusterMessagingProtocol.COPYCAT_SYNC) ||
136 - message.subject().equals(ClusterMessagingProtocol.COPYCAT_PING)) { 136 +// message.subject().equals(ClusterMessagingProtocol.COPYCAT_PING)) {
137 - log.warn("{} Request to {} failed. Will retry in {} ms", 137 +// log.warn("{} Request to {} failed. Will retry in {} ms",
138 - message.subject(), remoteNode, RETRY_INTERVAL_MILLIS); 138 +// message.subject(), remoteNode, RETRY_INTERVAL_MILLIS);
139 - THREAD_POOL.schedule( 139 +// THREAD_POOL.schedule(
140 - this, 140 +// this,
141 - RETRY_INTERVAL_MILLIS, 141 +// RETRY_INTERVAL_MILLIS,
142 - TimeUnit.MILLISECONDS); 142 +// TimeUnit.MILLISECONDS);
143 - } else { 143 +// } else {
144 log.warn("RPCTask for {} failed.", request, e); 144 log.warn("RPCTask for {} failed.", request, e);
145 future.completeExceptionally(e); 145 future.completeExceptionally(e);
146 - } 146 +// }
147 } catch (Exception e) { 147 } catch (Exception e) {
148 log.warn("RPCTask for {} terribly failed.", request, e); 148 log.warn("RPCTask for {} terribly failed.", request, e);
149 future.completeExceptionally(e); 149 future.completeExceptionally(e);
......