import static java.util.concurrent.TimeUnit.MILLISECONDS;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.fail;
+
+import com.google.common.testing.FakeTicker;
import java.util.List;
import org.junit.Assert;
import org.junit.Before;
// Intentionally empty
}
- private final static Logger LOG = LoggerFactory.getLogger(MessageTrackerTest.class);
+ private static final Logger LOG = LoggerFactory.getLogger(MessageTrackerTest.class);
- private TestTicker ticker;
+ private FakeTicker ticker;
private MessageTracker messageTracker;
@Before
public void setup() {
- ticker = new TestTicker();
+ ticker = new FakeTicker();
messageTracker = new MessageTracker(Foo.class, 10, ticker);
}
MessageTracker.Context context1 = messageTracker.received(new Foo());
context1.close();
- ticker.increment(MILLISECONDS.toNanos(20));
+ ticker.advance(20, MILLISECONDS);
MessageTracker.Context context2 = messageTracker.received(new Foo());
context2.close();
}
MessageTracker.Context context1 = messageTracker.received(new Foo());
context1.close();
- ticker.increment(MILLISECONDS.toNanos(20));
+ ticker.advance(20, MILLISECONDS);
MessageTracker.Context context2 = messageTracker.received(new Foo());
Assert.assertEquals(true, context2.error().isPresent());
messageTracker.received("A").close();
messageTracker.received(10L).close();
- MessageTracker.Context c = messageTracker.received(100);
+ MessageTracker.Context context = messageTracker.received(100);
- ticker.increment(MILLISECONDS.toNanos(20));
+ ticker.advance(20, MILLISECONDS);
- c.close();
+ context.close();
MessageTracker.Context context2 = messageTracker.received(new Foo());
LOG.error("An error occurred : {}" , error);
}
-
@Test
public void testMetExpectationOnTracking() {
messageTracker.begin();
MessageTracker.Context context1 = messageTracker.received(new Foo());
context1.close();
- ticker.increment(MILLISECONDS.toNanos(1));
+ ticker.advance(1, MILLISECONDS);
MessageTracker.Context context2 = messageTracker.received(new Foo());
Assert.assertEquals(false, context2.error().isPresent());
try {
messageTracker.received(new Foo());
fail("Expected an IllegalStateException");
- } catch (IllegalStateException e){
-
+ } catch (IllegalStateException e) {
+ // expected
}
}
}
@Test
- public void testDelayInFirstExpectedMessageArrival(){
+ public void testDelayInFirstExpectedMessageArrival() {
messageTracker.begin();
- ticker.increment(MILLISECONDS.toNanos(20));
+ ticker.advance(20, MILLISECONDS);
MessageTracker.Context context = messageTracker.received(new Foo());
public void testCallingBeginDoesNotResetWatch() {
messageTracker.begin();
- ticker.increment(MILLISECONDS.toNanos(20));
+ ticker.advance(20, MILLISECONDS);
messageTracker.begin();
}
-}
\ No newline at end of file
+}