private boolean notifyListener(final FetchContext request,
            final TopicProcessor topicProcessor,
            final StringBuilder sBuilder) throws Exception {
        final MessageListener listener = topicProcessor.getMessageListener();
        if (listener.getExecutor() != null) {
            try {
                listener.getExecutor().execute(new Runnable() {

                    @Override
                    public void run() {
                        receiveMessages(request, topicProcessor);
                    }
                });
            } catch (final RejectedExecutionException e) {
                logger.error(new StringBuilder(512)
                        .append("MessageListener thread poll is busy, topic=")
                        .append(request.getPartition().getTopic())
                        .append(",partition=").append(request.getPartition()).toString(), e);
                throw e;
            }
        } else {
            this.receiveMessages(request, topicProcessor);
        }
        baseConsumer.clientStatsInfo.bookReturnDuration(request.getPartitionKey(),
                System.currentTimeMillis() - request.getUsedToken());
        return true;
    }
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