void updatePullOffset(MessageQueue remoteQueue, long nextPullOffset) {
        pullOffsetTable.put(remoteQueue, nextPullOffset);
    }
@Test
    public void testUpdatePullOffset() throws Exception {
        MessageQueue messageQueue = new MessageQueue();
        localMessageCache.updatePullOffset(messageQueue, 124L);
        assertThat(localMessageCache.nextPullOffset(messageQueue)).isEqualTo(124L);
    }