Added log at RetryEmiFailureHnadler

artem-v · artem-v · commit 8a6255401ad9 · 2021-04-12T21:27:46.000+03:00
diff --git a/services-discovery/src/main/java/io/scalecube/services/discovery/ScalecubeServiceDiscovery.java b/services-discovery/src/main/java/io/scalecube/services/discovery/ScalecubeServiceDiscovery.java
@@ -301,6 +301,7 @@ private static class RetryEmitFailureHandler implements EmitFailureHandler {
 
     @Override
     public boolean onEmitFailure(SignalType signalType, EmitResult emitResult) {
+      LOGGER.warn("[onEmitFailure] signalType={}, emitResult={}", signalType, emitResult);
       return emitResult == FAIL_NON_SERIALIZED;
     }
   }

Original file line number	Diff line number	Diff line change
`@@ -301,6 +301,7 @@ private static class RetryEmitFailureHandler implements EmitFailureHandler {`
`301`	`301`
`302`	`302`	`@Override`
`303`	`303`	`public boolean onEmitFailure(SignalType signalType, EmitResult emitResult) {`
	`304`	`+ LOGGER.warn("[onEmitFailure] signalType={}, emitResult={}", signalType, emitResult);`
`304`	`305`	`return emitResult == FAIL_NON_SERIALIZED;`
`305`	`306`	`}`
`306`	`307`	`}`