Examples of runWithTimeout()


Examples of com.linkedin.databus.core.test.DbusEventBufferConsumer.runWithTimeout()

    _log.info("Verifying the events");
    Vector<DbusEvent> destEvents1 = new Vector<DbusEvent>(_srcEvents.size());
    DbusEventBufferConsumer consumer =
        new DbusEventBufferConsumer(_destBuf, _srcEvents.size(), 0, destEvents1);
    final long timeout = _debuggingMode ? 100000000 : 1000;
    boolean consumerDone = consumer.runWithTimeout(timeout);
    Assert.assertTrue(consumerDone);
    TestDbusEventBuffer.checkEvents(_srcEvents, destEvents1, _srcEvents.size());
    _log.info("Verified events: " + _srcEvents.size());
  }
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.