Reputation: 10512
On receiving mqtt message I am trying to get Object from payload (byte[])
Object ob = SerializationUtils.deserialize(message.getPayload());
I am getting:
org.apache.commons.lang.SerializationException: java.io.StreamCorruptedException: invalid stream header: 7B22736E
at org.apache.commons.lang.SerializationUtils.deserialize(SerializationUtils.java:168)
at org.apache.commons.lang.SerializationUtils.deserialize(SerializationUtils.java:193)
Upvotes: 0
Views: 3878