Examples of org.codehaus.activemq.message.ActiveMQStreamMessage.writeString()

Class org.codehaus.activemq.message.ActiveMQStreamMessage

Examples of org.codehaus.activemq.message.ActiveMQStreamMessage.writeString()

org.codehaus.activemq.message.ActiveMQStreamMessage.writeString()
Writes a String to the stream message. @param value the String value to be written @throws JMSException if the JMS provider fails to write the messagedue to some internal error. @throws MessageNotWriteableException if the message is in read-onlymode.

  public void testReadString()
  {
    ActiveMQStreamMessage msg = new ActiveMQStreamMessage();
    try {
      byte testByte = (byte)2;
      msg.writeString(new Byte(testByte).toString());
      msg.reset();
      assertTrue(msg.readByte()==testByte);
      msg.clearBody();
      short testShort = 3;
      msg.writeString(new Short(testShort).toString());

View Full Code Here

      msg.writeString(new Byte(testByte).toString());
      msg.reset();
      assertTrue(msg.readByte()==testByte);
      msg.clearBody();
      short testShort = 3;
      msg.writeString(new Short(testShort).toString());
      msg.reset();
      assertTrue(msg.readShort()==testShort);
      msg.clearBody();
      int testInt = 4;
      msg.writeString(new Integer(testInt).toString());

View Full Code Here

      msg.writeString(new Short(testShort).toString());
      msg.reset();
      assertTrue(msg.readShort()==testShort);
      msg.clearBody();
      int testInt = 4;
      msg.writeString(new Integer(testInt).toString());
      msg.reset();
      assertTrue(msg.readInt()==testInt);
      msg.clearBody();
      long testLong = 6l;
      msg.writeString(new Long(testLong).toString());

View Full Code Here

      msg.writeString(new Integer(testInt).toString());
      msg.reset();
      assertTrue(msg.readInt()==testInt);
      msg.clearBody();
      long testLong = 6l;
      msg.writeString(new Long(testLong).toString());
      msg.reset();
      assertTrue(msg.readLong()==testLong);
      msg.clearBody();
      float testFloat = 6.6f;
      msg.writeString(new Float(testFloat).toString());

View Full Code Here

      msg.writeString(new Long(testLong).toString());
      msg.reset();
      assertTrue(msg.readLong()==testLong);
      msg.clearBody();
      float testFloat = 6.6f;
      msg.writeString(new Float(testFloat).toString());
      msg.reset();
      assertTrue(msg.readFloat()==testFloat);
      msg.clearBody();
      double testDouble = 7.7d;
      msg.writeString(new Double(testDouble).toString());

View Full Code Here

      msg.writeString(new Float(testFloat).toString());
      msg.reset();
      assertTrue(msg.readFloat()==testFloat);
      msg.clearBody();
      double testDouble = 7.7d;
      msg.writeString(new Double(testDouble).toString());
      msg.reset();
      assertTrue(msg.readDouble()==testDouble);
      msg.clearBody();
      msg.writeString("true");
      msg.reset();

View Full Code Here

      double testDouble = 7.7d;
      msg.writeString(new Double(testDouble).toString());
      msg.reset();
      assertTrue(msg.readDouble()==testDouble);
      msg.clearBody();
      msg.writeString("true");
      msg.reset();
      assertTrue(msg.readBoolean());
      
      
    }catch(JMSException jmsEx){

View Full Code Here

  public void testReadString()
  {
    ActiveMQStreamMessage msg = new ActiveMQStreamMessage();
    try {
      byte testByte = (byte)2;
      msg.writeString(new Byte(testByte).toString());
      msg.reset();
      assertTrue(msg.readByte()==testByte);
      msg.clearBody();
      short testShort = 3;
      msg.writeString(new Short(testShort).toString());

View Full Code Here

      msg.writeString(new Byte(testByte).toString());
      msg.reset();
      assertTrue(msg.readByte()==testByte);
      msg.clearBody();
      short testShort = 3;
      msg.writeString(new Short(testShort).toString());
      msg.reset();
      assertTrue(msg.readShort()==testShort);
      msg.clearBody();
      int testInt = 4;
      msg.writeString(new Integer(testInt).toString());

View Full Code Here

      msg.writeString(new Short(testShort).toString());
      msg.reset();
      assertTrue(msg.readShort()==testShort);
      msg.clearBody();
      int testInt = 4;
      msg.writeString(new Integer(testInt).toString());
      msg.reset();
      assertTrue(msg.readInt()==testInt);
      msg.clearBody();
      long testLong = 6l;
      msg.writeString(new Long(testLong).toString());

View Full Code Here

0 1

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.