Examples of org.codehaus.activemq.message.ActiveMQTextMessage

org.codehaus.activemq.message.ActiveMQTextMessage
A TextMessage object is used to send a message containing a java.lang.String. It inherits from the Message interface and adds a text message body.

This message type can be used to transport text-based messages, including those with XML content.

When a client receives a TextMessage, 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#createTextMessage() @see javax.jms.Session#createTextMessage(String) @see javax.jms.BytesMessage @see javax.jms.MapMessage @see javax.jms.Message @see javax.jms.ObjectMessage @see javax.jms.StreamMessage @see java.lang.String

        container.addMessage(message);
        messageIdenties[i] = message.getJMSMessageIdentity();
    }


    protected void readMessage(int i) throws JMSException {
        ActiveMQTextMessage message = (ActiveMQTextMessage) container.getMessage(messageIdenties[i]);
        assertTrue("Message should not be null", message != null);


        String text = message.getText();
        assertEquals("Message text should be equal", messageTexts[i], text);
        assertEquals(messageIds[i], message.getJMSMessageID());
    }

View Full Code Here

        ActiveMQMessage message = container.getMessage(messageIdenties[i]);
        assertTrue("Message should be null", message == null);
    }


    protected ActiveMQMessage createMessage(int i) throws JMSException {
        ActiveMQTextMessage answer = new ActiveMQTextMessage();
        String text = "Message: " + i;
        messageTexts[i] = text;
        answer.setText(text);
        return answer;
    }

View Full Code Here

  public ActiveMQTextMessageReaderTest(String arg0) {
    super(arg0);
  }


  public void testGetPacketType() {
    ActiveMQTextMessage msg = new ActiveMQTextMessage();
    assertTrue(msg.getPacketType() == Packet.ACTIVEMQ_TEXT_MESSAGE);
  }

View Full Code Here

  }


  public void testReadPacket() {
    ActiveMQTextMessageReader reader = new ActiveMQTextMessageReader();
    ActiveMQTextMessageWriter writer = new ActiveMQTextMessageWriter();
    ActiveMQTextMessage msg1 = new ActiveMQTextMessage();
    try {
      msg1.setText(this.testStr);
      super.initializeMessage(msg1);
      byte[] data = writer.writePacketToByteArray(msg1);
      ActiveMQTextMessage msg2 = (ActiveMQTextMessage) reader.readPacketFromByteArray(data);
      super.testEquals(msg1, msg2);
      assertTrue(msg1.getText().equals(msg2.getText()));
    }
    catch (IOException e) {
      e.printStackTrace();
      assertTrue(false);
    }

View Full Code Here

  
  public void testTime(){


    ActiveMQTextMessageReader reader = new ActiveMQTextMessageReader();
    ActiveMQTextMessageWriter writer = new ActiveMQTextMessageWriter();
    ActiveMQTextMessage msg1 = new ActiveMQTextMessage();
    
    ActiveMQTextMessage msg2 = null;
    try {
      int count = 10000;
      long startTime = System.currentTimeMillis();
      //msg1.setText(this.testStr);
      msg1.setText("this is a test str");

View Full Code Here

        message.setJMSMessageID(id);
        messageIdenties[i] = container.addMessage(message);
    }


    protected void readMessage(int i) throws JMSException {
        ActiveMQTextMessage message = (ActiveMQTextMessage) container.getMessage(messageIdenties[i]);
        assertTrue("Message should not be null", message != null);


        String text = message.getText();
        assertEquals("Message text should be equal", messageTexts[i], text);
    }

View Full Code Here

        ActiveMQMessage message = container.getMessage(messageIdenties[i]);
        assertTrue("Message should be null", message == null);
    }


    protected ActiveMQMessage createMessage(int i) throws JMSException {
        ActiveMQTextMessage answer = new ActiveMQTextMessage();
        String text = "Message: " + i;
        messageTexts[i] = text;
        answer.setText(text);
        return answer;
    }

View Full Code Here

 */
public class JabberWireFormatTest extends TestCase {
    protected WireFormat format = new JabberWireFormat();


    public void testWrite() throws Exception {
        ActiveMQTextMessage message = new ActiveMQTextMessage();
        message.setJMSType("id");
        message.setJMSReplyTo(new ActiveMQTopic("my.source"));
        message.setJMSDestination(new ActiveMQTopic("my.target"));
        message.setJMSCorrelationID("abc123");
        message.setText("<body>hello there </body>");


        ByteArrayOutputStream buffer = new ByteArrayOutputStream();
        DataOutputStream out = new DataOutputStream(buffer);
        format.writePacket(message, out);
        out.close();

View Full Code Here

        answer.addPostCommitTask(new SendMessageTransactionTask(null, createMessage()));
        return answer;
    }


    protected ActiveMQMessage createMessage() throws JMSException {
        ActiveMQTextMessage answer = new ActiveMQTextMessage();
        answer.setJMSMessageID("abc:123");
        answer.setText("I'm a test message!");
        return answer;
    }

View Full Code Here

        }
        return messages[i];
    }


    protected ActiveMQMessage createMessage(int i) throws JMSException {
        ActiveMQTextMessage answer = new ActiveMQTextMessage();
        answer.setJMSMessageID(idGenerator.generateId());
        answer.setJMSClientID(getClientID());
        answer.setJMSDestination(destination);
        answer.setText("message index: " + i);
        return answer;
    }

View Full Code Here

0 1 2 3 4

TOP

Related Classes of org.codehaus.activemq.message.ActiveMQTextMessage

org.codehaus.activemq.ActiveMQSession

org.codehaus.activemq.io.impl.ActiveMQTextMessageReader

org.codehaus.activemq.io.impl.ActiveMQTextMessageReaderTest

org.codehaus.activemq.message.ActiveMQTextMessageReaderTest

org.codehaus.activemq.service.impl.XATransactionTest

org.codehaus.activemq.service.MessageContainerTestSupport

org.codehaus.activemq.service.MessageStoreTestSupport

org.codehaus.activemq.test.MessageContainerTestSupport

org.codehaus.activemq.test.MessageStoreTestSupport

org.codehaus.activemq.test.WireFormatTestSupport

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.