Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Date: Tue, 15 Mar 2016 22:38:54 -0700 (PDT)
From: xabhi <xabhi91@gmail.com>
To: users@activemq.apache.org
Message-ID: <1458106734803-4709447.post@n4.nabble.com>
Subject: ActiveMQ Object Message to json transformation not working
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit

Hi,

I am having trouble sending a custom Object Message to a STOMP consumer with
ActiveMQ v5.11.1

In Jconsole, I can see messages being dequeued by STOMP consumer but the
subscription callback is never called.

However note that if I send a simple string as object message it gets
processed by STOMP consumer and I receive a JSON formatted message in this
format:
{"string":"hello"}

I create the message as follows:
myMessage = mySession.createObjectMessage("hello");
myProducers.get(destName).send(myMessage);

I am not sure what am i doing wrong here. Could anyone tell what is wrong
with this code?


Object Message class:
    public static class SampleObjectMessage implements Serializable
    {
        private static final long serialVersionUID = 1L;
        public String data;
        public long sendTimeMs;
        public SampleObjectMessage(String data, long sendTimeMs) {
            this.data = data;
            this.sendTimeMs = sendTimeMs;
        }
        public String getData() {
            return data;
        }
        public void setData(String data) {
            this.data = data;
        }
        public long getSendTimeMs() {
            return sendTimeMs;
        }
        public void setSendTimeMs(long sendTimeMs) {
            this.sendTimeMs = sendTimeMs;
        }
    }


Code for sending ObjectMessage:
myMessage = mySession.createObjectMessage(
                     new SampleObjectMessage(getMessageText(ourMessageSize),
                                             System.currentTimeMillis()));

myProducers.get(destName).send(myMessage);


STOMP consumer has following headers for subscription:

var subscriptionHeaders = {
  'ack'         : 'auto',
  'transformation' : 'jms-object-json'
};


--
View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-Object-Message-to-json-transformation-not-working-tp4709447.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.