Package javax.jms

Examples of javax.jms.BytesMessage.writeByte()

482
483
484
485
486
487
488
489
490
491
492
      {
         // OK
      }
      try
      {
         m2.writeByte(myByte);
         fail();
      }
      catch (javax.jms.MessageNotWriteableException e)
      {
         // OK
View Full Code Here
158
159
160
161
162
163
164
165
166
167
168
      log.trace("String is length:" + myString.length());
      char myChar = 'q';
      byte[] myBytes = new byte[] {-23, 114, -126, -12, 74, 87};

      m.writeBoolean(myBool);
      m.writeByte(myByte);
      m.writeShort(myShort);
      m.writeChar(myChar);
      m.writeInt(myInt);
      m.writeLong(myLong);
      m.writeFloat(myFloat);
View Full Code Here
71
72
73
74
75
76
77
78
79
80
81
      super.prepareMessage(m);

      BytesMessage bm = (BytesMessage)m;

      bm.writeBoolean(true);
      bm.writeByte((byte)3);
      bm.writeBytes(new byte[] {(byte)4, (byte)5, (byte)6});
      bm.writeChar((char)7);
      bm.writeDouble(8.0);
      bm.writeFloat(9.0f);
      bm.writeInt(10);
View Full Code Here
1125
1126
1127
1128
1129
1130
1131
1132
1133
1134
1135
   public void testCopyOnForeignBytesMessage() throws JMSException
   {
      BytesMessage foreignBytesMessage = new SimpleJMSBytesMessage();
      for(int i = 0; i < 20; i++)
      {
         foreignBytesMessage.writeByte((byte)i);
      }

      JBossBytesMessage copy = new JBossBytesMessage(foreignBytesMessage, 0);

      foreignBytesMessage.reset();
View Full Code Here
834
835
836
837
838
839
840
841
842
843
844
      ClientSession session = new FakeSession(clientMessage);

      BytesMessage foreignBytesMessage = new SimpleJMSBytesMessage();
      for (int i = 0; i < 20; i++)
      {
         foreignBytesMessage.writeByte((byte)i);
      }

      HornetQBytesMessage copy = new HornetQBytesMessage(foreignBytesMessage, session);

      foreignBytesMessage.reset();
View Full Code Here
1862
1863
1864
1865
1866
1867
1868
1869
1870
1871
1872
        assertEquals(-1,msg.readBytes(data2));
       
        // Make sure message is read-only
        try
        {
          msg.writeByte((byte)12);
          fail("Should have failed");
        }
        catch (MessageNotWriteableException e)
        {
          // Ignore
View Full Code Here
1872
1873
1874
1875
1876
1877
1878
1879
1880
1881
1882
          // Ignore
        }
       
        msg.clearBody();
       
        msg.writeByte((byte)12);
       
        // Make sure message is write-only
        try
        {
          msg.readByte();
View Full Code Here
1890
1891
1892
1893
1894
1895
1896
1897
1898
1899
1900
        msg.reset();
       
        // Make sure message is read-only
        try
        {
          msg.writeByte((byte)12);
          fail("Should have failed");
        }
        catch (MessageNotWriteableException e)
        {
          // Ignore
View Full Code Here
53
54
55
56
57
58
59
60
61
62
63
        jmsTemplate.setPubSubDomain(false);
        jmsTemplate.send("test.bytes", new MessageCreator() {
            public Message createMessage(Session session) throws JMSException {
                BytesMessage bytesMessage = session.createBytesMessage();
                bytesMessage.writeByte((byte) 1);
                bytesMessage.writeByte((byte) 2);
                bytesMessage.writeByte((byte) 3);
                return bytesMessage;
            }
        });
View Full Code Here
54
55
56
57
58
59
60
61
62
63
64
        jmsTemplate.setPubSubDomain(false);
        jmsTemplate.send("test.bytes", new MessageCreator() {
            public Message createMessage(Session session) throws JMSException {
                BytesMessage bytesMessage = session.createBytesMessage();
                bytesMessage.writeByte((byte) 1);
                bytesMessage.writeByte((byte) 2);
                bytesMessage.writeByte((byte) 3);
                return bytesMessage;
            }
        });
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.