private void receiveMessages(final FetchContext request,
            final TopicProcessor topicProcessor) {
        if (request != null && request.getMessageList() != null) {
            MessageListener msgListener = topicProcessor.getMessageListener();
            try {
                msgListener.receiveMessages(new PeerInfo(request.getPartition(),
                        request.getCurrOffset(), request.getMaxOffset()), request.getMessageList());
            } catch (InterruptedException e) {
                logger.info(
                        "Call listener to process received messages throw Interrupted Exception!");
            }
        }
    }
Process the selected partition result.

@param partSelectResult partition select result
@param sBuilder         a string builder
inlong-tubemq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/consumer/SimplePushMessageConsumer.java