Description
streamMessage.writeObject(new Long("1")) is silently ignored, nothing is written to the message body. The ActiveMQStreamMessage is missing one 'if' clause for the Long datatype.
ConnectionFactory cf = new ActiveMQConnectionFactory("vm://localhost?broker.persistent=false&broker.useJmx=false"); Session session = cf.createConnection().createSession(false, Session.AUTO_ACKNOWLEDGE); StreamMessage sm = session.createStreamMessage(); sm.writeObject(new Long("1")); // reset so it's readable now sm.reset(); assertEquals(new Long("1"), sm.readObject());
Attachments
There are no Sub-Tasks for this issue.