Sending custom objects with HornetQ Core

[d.smelanskij]

Hi,

I have to send a complex object via Hornet queue.

following examples my code looks like:

Message receiver:

messageConsumer.setMessageHandler(new MessageHandler() {

public void onMessage(ClientMessage message) {

System.out.println("Message size: " + message.getBodyBuffer().capacity());
byte[] bMessage = new byte[message.getBodySize()];

message.getBodyBuffer().getBytes(0, bMessage);

MyMessageType myMessage = (MyMessageType) toObject(bMessage);

}
});

Message sender:

ClientMessage cMessage = session.createMessage(false);
MyMessageType myMessage = getMyMessage();

cMessage.getBodyBuffer().writeBytes(toByteArray(myMessage));
System.out.println("Message size: " + cMessage.getBodyBuffer().capacity());
producer.send(cMessage);

The size of BodyBuffer for sending is different from received BodyBuffer.

1500 send, 849 received.

Do I something wrong?

Is there another way to send custom objects using HornetQ Core?

[clebert.suconic]

I have now idea what you're doing on getMyMessage();

Why don't you just send a Message with a specific body.

You're probably doing something inside MyMessageType. I would just use the regular message type if I were you.

[d.smelanskij]

sorry,

may be my question was wrong.

I try to redefine it.

I have a HornetQ core client and HornetQ core server. Connection configured by using NettyAcceptorFactory

as a Message to send is MyMessageType<?>

When I am using JBoss Netty,  I send messages using ChannelBuffer, with channelBuffer.writeBytes(myMessageType.toBytes());

When I am using JBoss ESB , I send messages using esbMessage.getBody().add(myMessage);

How do I send and receive complex custom messages using HornetQ, I have not found any example.

[d.smelanskij]

After reading the API, found right solution:

Sender:

ClientMessage cMessage = session.createMessage(false);
TestMessage testMessage = getTestMessage();
cMessage.getBodyBuffer().writeBytes(toByteArray(testMessage));
producer.send(cMessage);

Receiver:

public void onMessage(ClientMessage message) {

     byte[] bMessage = new byte[message.getBodySize()]

     message.getBodyBuffer().readBytes(bMessage);
     TestMessage<?> testMessage = (TestMessage<?>) toObject(bMessage);

}

[jendo]

Is this the only way to send custom objects?

[clebert.suconic]

That's actually what happens when you send ObjectMessage.

In Messaging terms actually there is no such thing as sending objects, we always send byte arrays. (That will be the same with any messaging system). The JMS spec however requires us to have these "utilities" messages, but underneath everything sent is always a message byte array.