We never see this exception in the logs even though it's pretty severe. All we might see is an exception about a transport message not having been read fully from the logic that follows this code. Technically we should probably bubble up the exception but that's a bigger change and needs some carefully reasoning, this change for the time being at least simplifies tracking down deserialization issues in responses.
This commit is contained in:
parent
98f525f8a7
commit
ffbc64bd10
|
@ -219,8 +219,10 @@ public class InboundHandler {
|
||||||
response = handler.read(stream);
|
response = handler.read(stream);
|
||||||
response.remoteAddress(new TransportAddress(remoteAddress));
|
response.remoteAddress(new TransportAddress(remoteAddress));
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
handleException(handler, new TransportSerializationException(
|
final Exception serializationException = new TransportSerializationException(
|
||||||
"Failed to deserialize response from handler [" + handler + "]", e));
|
"Failed to deserialize response from handler [" + handler + "]", e);
|
||||||
|
logger.warn(new ParameterizedMessage("Failed to deserialize response from [{}]", remoteAddress), serializationException);
|
||||||
|
handleException(handler, serializationException);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
final String executor = handler.executor();
|
final String executor = handler.executor();
|
||||||
|
|
Loading…
Reference in New Issue