@Override
            public void run() {
                while (!isStopped()) {
                    try {
                        statisticDltBrokerStatus();
                    } catch (Throwable e) {
                        //
                    }
                    ThreadUtils.sleep(1000);
                }
            }
Initial a broker receive status statistics ojbect

@param rpcServiceFactory  the session factory
@param producerConfig     the producer configure
inlong-tubemq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/producer/qltystats/DefaultBrokerRcvQltyStats.java