Examples of addEventToBuffer()

Examples of com.linkedin.databus.core.test.DbusEventAppender.addEventToBuffer()

639
640
641
642
643
644
645
646
647
648
649
    boolean exceptionCaught = false;

    dbusBuf.startEvents();
    try
    {
      eventCount = appender.addEventToBuffer(events.get(0), eventCount);
    }
    catch(DatabusRuntimeException e)
    {
      exceptionCaught = true;
    }
View Full Code Here

Examples of com.linkedin.databus.core.test.DbusEventAppender.addEventToBuffer()

712
713
714
715
716
717
718
719
720
721
722
    generator.generateEvents(1, 20, 500, 10, events);   // event size = 71, can append.

    long cwp1 = reflector.getCurrentWritePosition().getPosition();
    dbusBuf.startEvents();
    int evCount = 0;
    evCount = appender.addEventToBuffer(events.firstElement(), evCount);
    Assert.assertEquals(1, evCount);
    long cwp2 = reflector.getCurrentWritePosition().getPosition();
    Assert.assertTrue("Cwp should differ event write", cwp1 != cwp2);

    // Roll back.
View Full Code Here

Examples of com.linkedin.databus.core.test.DbusEventAppender.addEventToBuffer()

744
745
746
747
748
749
750
751
752
753
754
    dbusBuf.startEvents();
    int evCount = 0;
    for (DbusEvent e : events)
    {
      evCount = appender.addEventToBuffer(e, evCount);
    }
    Assert.assertEquals(events.size(), evCount);

    DbusEventBufferReflector reflector = appender.getDbusEventReflector();
    dbusBuf.rollbackEvents();
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.