How to handle the exception thrown by ParseFrom() if any non-serialised message or any corrupt data is received in Java?

[neha]

Below is the exception thrown. If ParseFrom() fails to parse the message then what it return? In C++ ParseFromString() return true or false on success or failure. Is this not applicable for ParseFrom() method in java???

15 [pool-4-thread-5] ERROR com.rabbitmq.client.impl.ForgivingExceptionHandler  - Consumer com.rabbitmq.client.impl.recovery.AutorecoveringChannel$2@77af1d36 (amq.ctag-c6ALmMSwQyxqmX6H6LAY8Q) method handleDelivery for channel AMQChannel(amqp://gu...@127.0.0.1:5672/,1) threw an exception for channel AMQChannel(amqp://gu...@127.0.0.1:5672/,1)

com.google.protobuf.InvalidProtocolBufferException: Protocol message end-group tag did not match expected tag.

at com.google.protobuf.InvalidProtocolBufferException.invalidEndTag(InvalidProtocolBufferException.java:106)

at com.google.protobuf.CodedInputStream$ArrayDecoder.checkLastTagWas(CodedInputStream.java:635)

at com.google.protobuf.AbstractParser.parsePartialFrom(AbstractParser.java:160)

at com.google.protobuf.AbstractParser.parseFrom(AbstractParser.java:191)

at com.google.protobuf.AbstractParser.parseFrom(AbstractParser.java:203)

at com.google.protobuf.AbstractParser.parseFrom(AbstractParser.java:208)

at com.google.protobuf.AbstractParser.parseFrom(AbstractParser.java:48)

at com.haud.simulator.HaudRPCProtoMessageClass$HaudRPCProtoMessage.parseFrom(HaudRPCProtoMessageClass.java:1258)

at com.haud.simulator.ReaderEndPoint$1.handle(ReaderEndPoint.java:31)

at com.rabbitmq.client.impl.recovery.AutorecoveringChannel$2.handleDelivery(AutorecoveringChannel.java:577)

at com.rabbitmq.client.impl.ConsumerDispatcher$5.run(ConsumerDispatcher.java:149)

at com.rabbitmq.client.impl.ConsumerWorkService$WorkPoolRunnable.run(ConsumerWorkService.java:104)

at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)

at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)

at java.base/java.lang.Thread.run(Thread.java:834)

Anyone can give a lead on this would be of great help. Thanks