001
014
015 package com.liferay.portal.monitoring.messaging;
016
017 import com.liferay.portal.kernel.messaging.BaseMessageListener;
018 import com.liferay.portal.kernel.messaging.Message;
019 import com.liferay.portal.kernel.monitoring.statistics.DataSample;
020 import com.liferay.portal.kernel.monitoring.statistics.DataSampleProcessor;
021
022
026 public class MonitoringMessageListener extends BaseMessageListener {
027
028 public void setDataSampleProcessor(
029 DataSampleProcessor<DataSample> dataSampleProcessor) {
030
031 _dataSampleProcessor = dataSampleProcessor;
032 }
033
034 @Override
035 protected void doReceive(Message message) throws Exception {
036 DataSample dataSample = (DataSample)message.getPayload();
037
038 if (dataSample != null) {
039 _dataSampleProcessor.processDataSample(dataSample);
040 }
041 }
042
043 private DataSampleProcessor<DataSample> _dataSampleProcessor;
044
045 }