Description
If compares against StreamMessage.CURRENT_VERSION but prints MessagingService.current_version. The error message is confusing tho.
if (version != StreamMessage.CURRENT_VERSION) throw new IOException(String.format("Received stream using protocol version %d (my version %d). Terminating connection", version, MessagingService.current_version));
EDIT: That message is only printed at debug log level