CODEWITHSUNDEEP
javamqttpaho
Manish Kumar
Manish Kumar

Reputation: 10512

How to get Object from MQTT message payload

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

Answers (1)

hardillb
hardillb

Reputation: 59866

You need a JSON parser not the Apache Commons Serialization library.

Something like the JSON.org parser

JSONObject obj = new JSONObject(msg.toString());

Upvotes: 4

Related Questions