@Override
            public void onNext(MeterDataCollection meterDataCollection) {
                final MeterProcessor processor = processService.createProcessor();
                try (HistogramMetrics.Timer ignored = histogram.createTimer()) {
                    meterDataCollection.getMeterDataList().forEach(processor::read);
                    processor.process();
                } catch (Exception e) {
                    errorCounter.inc();
                    log.error(e.getMessage(), e);
                }
            }
Meter protocol receiver, collect and process the meters.
oap-server/server-receiver-plugin/skywalking-meter-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/meter/provider/handler/MeterServiceHandler.java