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