class PullConsumerImpl implements PullConsumer {

    @Override
    public Message poll() {
        MessageExt rmqMsg = localMessageCache.poll();
        return rmqMsg == null ? null : OMSUtil.msgConvert(rmqMsg);
    }

    public  PullConsumerImpl(final String queueName, final KeyValue properties);

}