Examples of org.apache.activemq.command.ActiveMQStreamMessage.writeObject()

Class org.apache.activemq.command.ActiveMQStreamMessage

Examples of org.apache.activemq.command.ActiveMQStreamMessage.writeObject()

org.apache.activemq.command.ActiveMQStreamMessage.writeObject()
Writes an object to the stream message.

This method works only for the objectified primitive object types (Integer, Double, Long ...), String objects, and byte arrays. @param value the Java object to be written @throws JMSException if the JMS provider fails to write the message dueto some internal error. @throws MessageFormatException if the object is invalid. @throws MessageNotWriteableException if the message is in read-only mode.

                msg.setConnection(connection);
                Object obj = null;


                try {
                    while ((obj = streamMessage.readObject()) != null) {
                        msg.writeObject(obj);
                    }
                } catch (MessageEOFException e) {
                    // if an end of message stream as expected
                } catch (JMSException e) {
                }

View Full Code Here

                msg.setConnection(connection);
                Object obj = null;


                try {
                    while ((obj = streamMessage.readObject()) != null) {
                        msg.writeObject(obj);
                    }
                } catch (MessageEOFException e) {
                    // if an end of message stream as expected
                } catch (JMSException e) {
                }

View Full Code Here

    }


    public void testClearBody() throws JMSException {
        ActiveMQStreamMessage streamMessage = new ActiveMQStreamMessage();
        try {
            streamMessage.writeObject(new Serializable() {
                private static final long serialVersionUID = -5181896809607968727L;
            });
            streamMessage.clearBody();
            assertFalse(streamMessage.isReadOnlyBody());
            streamMessage.writeObject(new Serializable() {

View Full Code Here

            streamMessage.writeObject(new Serializable() {
                private static final long serialVersionUID = -5181896809607968727L;
            });
            streamMessage.clearBody();
            assertFalse(streamMessage.isReadOnlyBody());
            streamMessage.writeObject(new Serializable() {
                private static final long serialVersionUID = 5074177640797561141L;
            });
            streamMessage.readObject();
            fail("should throw exception");
        } catch (MessageNotReadableException mnwe) {

View Full Code Here

            message.writeChar('a');
            message.writeDouble(1.5);
            message.writeFloat((float) 1.5);
            message.writeInt(1);
            message.writeLong(1);
            message.writeObject("stringobj");
            message.writeShort((short) 1);
            message.writeString("string");
        } catch (MessageNotWriteableException mnwe) {
            fail("Should be writeable");
        }

View Full Code Here

            message.writeLong(1);
            fail("Should have thrown exception");
        } catch (MessageNotWriteableException mnwe) {
        }
        try {
            message.writeObject("stringobj");
            fail("Should have thrown exception");
        } catch (MessageNotWriteableException mnwe) {
        }
        try {
            message.writeShort((short) 1);

View Full Code Here

            message.writeChar('a');
            message.writeDouble(1.5);
            message.writeFloat((float) 1.5);
            message.writeInt(1);
            message.writeLong(1);
            message.writeObject("stringobj");
            message.writeShort((short) 1);
            message.writeString("string");
        } catch (MessageNotWriteableException mnwe) {
            fail("Should be writeable");
        }

View Full Code Here

                msg.setConnection(connection);
                Object obj = null;


                try {
                    while ((obj = streamMessage.readObject()) != null) {
                        msg.writeObject(obj);
                    }
                } catch (MessageEOFException e) {
                    // if an end of message stream as expected
                } catch (JMSException e) {
                }

View Full Code Here

                msg.setConnection(connection);
                Object obj = null;


                try {
                    while ((obj = streamMessage.readObject()) != null) {
                        msg.writeObject(obj);
                    }
                } catch (MessageEOFException e) {
                    // if an end of message stream as expected
                } catch (JMSException e) {
                }

View Full Code Here

                msg.setConnection(connection);
                Object obj = null;


                try {
                    while ((obj = streamMessage.readObject()) != null) {
                        msg.writeObject(obj);
                    }
                } catch (MessageEOFException e) {
                    // if an end of message stream as expected
                } catch (JMSException e) {
                }

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.