public abstract long observeWm(int queueIndex, long wmValue);
@Test
    public void when_i1_active_i2_idle_then_wmForwardedImmediately() {
        assertEquals(Long.MIN_VALUE, wc.observeWm(0, 100));
        assertEquals(100, wc.observeWm(1, IDLE_MESSAGE.timestamp()));
    }