fix communication problem

This commit is contained in:
Mike Rosseel 2017-02-20 15:12:42 +01:00
parent 7db8b8ece3
commit 1017502035

View file

@ -749,11 +749,11 @@ public class Connection implements MessageListener {
// Reading the protobuffer message from the inputstream
Messages.Envelope envelope = null;
try {
if (protoInputStream.available() > 0) {
// if (protoInputStream.available() > 0) {
envelope = Messages.Envelope.parseDelimitedFrom(protoInputStream);
} else {
return;
}
// } else {
// return;
// }
if (envelope == null) {
log.debug("Envelope is null, available={}", protoInputStream.available());