@Override
    public Message receive() {
        MessageExt rmqMsg = localMessageCache.poll();
        return rmqMsg == null ? null : OMSUtil.msgConvert(rmqMsg);
    }
@Test
    public void testPoll_WithTimeout() {
        //There is a default timeout value, @see ClientConfig#omsOperationTimeout.
        Message message = consumer.receive();
        assertThat(message).isNull();

        message = consumer.receive(OMS.newKeyValue().put(Message.BuiltinKeys.TIMEOUT, 100));
        assertThat(message).isNull();
    }