src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java [273:281]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                                UtilAll.getQueueDescription(messageQueue),
                                e);
                        throw new RuntimeException(e);
                    }
                },
                commonExecutorService);
    }

    @Override
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/org/apache/flink/connector/rocketmq/source/InnerConsumerImpl.java [295:303]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                                UtilAll.getQueueDescription(messageQueue),
                                e);
                        throw new RuntimeException(e);
                    }
                },
                commonExecutorService);
    }

    @Override
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -