Examples of org.activemq.message.ActiveMQObjectMessage

org.activemq.message.ActiveMQObjectMessage

An ObjectMessage object is used to send a message that contains a serializable object in the Java programming language ("Java object"). It inherits from the Message interface and adds a body containing a single reference to an object. Only Serializable Java objects can be used.

If a collection of Java objects must be sent, one of the Collection classes provided since JDK 1.2 can be used.

When a client receives an ObjectMessage, it is in read-only mode. If a client attempts to write to the message at this point, a MessageNotWriteableException is thrown. If clearBody is called, the message can now be both read from and written to. @see javax.jms.Session#createObjectMessage() @see javax.jms.Session#createObjectMessage(Serializable) @see javax.jms.BytesMessage @see javax.jms.MapMessage @see javax.jms.Message @see javax.jms.StreamMessage @see javax.jms.TextMessage

        Packet actual = writeThenReadPacket(expected);
        assertTextMessage(expected, (ActiveMQTextMessage) actual);
    }


    public void testObjectMessage() throws Exception {
        ActiveMQObjectMessage expected = createObjectMessage();
        Packet actual = writeThenReadPacket(expected);
        assertObjectMessage(expected, (ActiveMQObjectMessage) actual);
    }

        assertMessage(expected, actual);
        assertEquals("object", expected.getObject(), actual.getObject());
    }


    protected ActiveMQObjectMessage createObjectMessage() throws JMSException {
        ActiveMQObjectMessage answer = new ActiveMQObjectMessage();
        answer.setObject("This is some text");
        configureMessage(answer);
        return answer;
    }

Examples of org.activemq.message.ActiveMQObjectMessage

Related Classes of org.activemq.message.ActiveMQObjectMessage