If I add XStreamMessageTransformer, during transformation UserID field
simply lost in
org.apache.activemq.ActiveMQMessageTransformation.copyProperties method

Can we check Message for instance of org.apache.activemq.command.Message
and not javax.jms.Message

Now I finished with workaround:

            connectionFactory.setTransformer(new
XStreamMessageTransformer() {
                @Override
                public Message consumerTransform(Session session,
MessageConsumer consumer, Message message) throws JMSException {
                    ActiveMQObjectMessage m = (ActiveMQObjectMessage)
super.consumerTransform(session, consumer, message);
                    m.setUserID(((ActiveMQTextMessage)
message).getUserID());
                    return m;
                }
            });

-- 
With Best Regards,
Constantine

Reply via email to