I use version Hornetq 2.2.5.Final.

I want to make message client side:

(1) Received message from the HornetQ server, converts to byte array.

(2) Restore the message from byte array, and send message to the HornetQ server.

I have tried to use "org.hornetq.core.message.impl.MessageImpl#encode, decode".

but miss to restore messages, message body is null. I wrote to following code.

Is my way wrong?

who knows how to do the other?

--------------------------------------------------------------------------------------------------------

        // convert to byte array

        Message message = consumer.receiveNoWait();

        HornetQMessage hornetQMessage = (HornetQMessage) message;

        ClientMessage clientMessage = hornetQMessage.getCoreMessage();

        MessageImpl messageImpl = (MessageImpl) clientMessage;

        int encodeSize = messageImpl.getEncodeSize();

        byte[] array = new byte[encodeSize];

        ByteBuffer byteBuffer = ByteBuffer.wrap(array);

        HornetQBuffer buffer = HornetQBuffers.wrappedBuffer(byteBuffer);

        messageImpl.encode(buffer);

        // output byte array to file....

        // input byte array from file....

        //restore message from byte array

        ClientSession coreSession = ((HornetQSession) session).getCoreSession();

        ClientMessage clientMessage = coreSession.createMessage(true);

        MessageImpl messageImpl = (MessageImpl) clientMessage;

        HornetQBuffer buff = HornetQBuffers.dynamicBuffer(array);

        messageImpl.decode(buff);

        HornetQMessage hornetQMessage = HornetQMessage.createMessage((ClientMessage) messageImpl, coreSession);

        producer.send(hornetQMessage);

--------------------------------------------------------------------------------------------------------