Package net.timewalker.ffmq3.common.message

Examples of net.timewalker.ffmq3.common.message.StreamMessageImpl.markAsReadOnly()

348
349
350
351
352
353
354
355
356
357
358
    assertEquals(123,msg.readInt());
   
    // Int
    msg = new StreamMessageImpl();
    msg.writeInt(123);
    msg.markAsReadOnly();
    assertEquals(123,msg.readInt());
   
    // Long
    msg = new StreamMessageImpl();
    msg.writeInt(123);
View Full Code Here
354
355
356
357
358
359
360
361
362
363
364
    assertEquals(123,msg.readInt());
   
    // Long
    msg = new StreamMessageImpl();
    msg.writeInt(123);
    msg.markAsReadOnly();
    assertEquals(123,msg.readLong());
   
    // Float
    msg = new StreamMessageImpl();
    msg.writeInt(123);
View Full Code Here
360
361
362
363
364
365
366
367
368
369
370
    assertEquals(123,msg.readLong());
   
    // Float
    msg = new StreamMessageImpl();
    msg.writeInt(123);
    msg.markAsReadOnly();
    try { msg.readFloat(); fail("Should have failed"); } catch (MessageFormatException e) { /* OK */ }
    assertEquals(123,msg.readInt());
   
    // Double
    msg = new StreamMessageImpl();
View Full Code Here
367
368
369
370
371
372
373
374
375
376
377
    assertEquals(123,msg.readInt());
   
    // Double
    msg = new StreamMessageImpl();
    msg.writeInt(123);
    msg.markAsReadOnly();
    try { msg.readDouble(); fail("Should have failed"); } catch (MessageFormatException e) { /* OK */ }
    assertEquals(123,msg.readInt());
   
    // String
    msg = new StreamMessageImpl();
View Full Code Here
374
375
376
377
378
379
380
381
382
383
384
    assertEquals(123,msg.readInt());
   
    // String
    msg = new StreamMessageImpl();
    msg.writeInt(123);
    msg.markAsReadOnly();
    assertEquals("123",msg.readString());
   
    // Bytes
    msg = new StreamMessageImpl();
    msg.writeInt(123);
View Full Code Here
380
381
382
383
384
385
386
387
388
389
390
    assertEquals("123",msg.readString());
   
    // Bytes
    msg = new StreamMessageImpl();
    msg.writeInt(123);
    msg.markAsReadOnly();
    try { msg.readBytes(new byte[1]); fail("Should have failed"); } catch (MessageFormatException e) { /* OK */  }
    assertEquals(123,msg.readInt());
  }
 
  public void testLongConversion() throws Exception
View Full Code Here
651
652
653
654
655
656
657
658
659
660
661
    assertEquals("foobar",msg.readString());
   
    // Float
    msg = new StreamMessageImpl();
    msg.writeString("foobar");
    msg.markAsReadOnly();
    try { msg.readFloat(); fail("Should have failed"); } catch (NumberFormatException e) { /* OK */ }
    assertEquals("foobar",msg.readString());
   
    // Double
    msg = new StreamMessageImpl();
View Full Code Here
658
659
660
661
662
663
664
665
666
667
668
    assertEquals("foobar",msg.readString());
   
    // Double
    msg = new StreamMessageImpl();
    msg.writeString("foobar");
    msg.markAsReadOnly();
    try { msg.readDouble(); fail("Should have failed"); } catch (NumberFormatException e) { /* OK */ }
    assertEquals("foobar",msg.readString());
   
    // String
    msg = new StreamMessageImpl();
View Full Code Here
665
666
667
668
669
670
671
672
673
674
675
    assertEquals("foobar",msg.readString());
   
    // String
    msg = new StreamMessageImpl();
    msg.writeString("foobar");
    msg.markAsReadOnly();
    assertEquals("foobar",msg.readString());
   
    // Bytes
    msg = new StreamMessageImpl();
    msg.writeString("foobar");
View Full Code Here
671
672
673
674
675
676
677
678
679
680
681
    assertEquals("foobar",msg.readString());
   
    // Bytes
    msg = new StreamMessageImpl();
    msg.writeString("foobar");
    msg.markAsReadOnly();
    try { msg.readBytes(new byte[1]); fail("Should have failed"); } catch (MessageFormatException e) { /* OK */  }
    assertEquals("foobar",msg.readString());
  }
 
  public void testNumericStringConversion() throws Exception
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.