Hello,
We are trying to avoid the serialization overhead when using the vm://
embedded broker. We set the setObjectMessageSerializationDefered(true)
and setCopyMessageOnSend(false) options on the connection
factory. ActiveMQ still serializes in the
The following code in ActionMQConnection shows the problem:
ActiveMQDispatcher dispatcher = dispatchers.get(md.getConsumerId());
if (dispatcher != null) {
// Copy in case a embedded broker is dispatching
via
// vm://
// md.getMessage() == null to signal end of
queue
// browse.
Message msg = md.getMessage();
if (msg != null) {
msg = msg.copy(); <============ A blind
copy without checking the copy flag.
msg.setReadOnlyBody(true);
msg.setReadOnlyProperties(true);
msg.setRedeliveryCounter(md.getRedeliveryCounter());
msg.setConnection(ActiveMQConnection.this);
md.setMessage(msg);
}
dispatcher.dispatch(md);
}
We are using 4.1.1. Looked at svn and 5.x has the same issue. Any help will
be greatly appreciated.
Tarek Hammoud
Enfusion Systems.
--
View this message in context:
http://www.nabble.com/ActiveMQ-4.1.1-Always-Serializes-Object-Messages-tp14896461s2354p14896461.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
