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 import java.util.List;
023
024
028 public class MonitoringMessageListener extends BaseMessageListener {
029
030 public void setDataSampleProcessor(
031 DataSampleProcessor<DataSample> dataSampleProcessor) {
032
033 _dataSampleProcessor = dataSampleProcessor;
034 }
035
036 @Override
037 protected void doReceive(Message message) throws Exception {
038 List<DataSample> dataSamples = (List<DataSample>)message.getPayload();
039
040 if ((dataSamples != null) && !dataSamples.isEmpty()) {
041 for (DataSample dataSample : dataSamples) {
042 _dataSampleProcessor.processDataSample(dataSample);
043 }
044 }
045 }
046
047 private DataSampleProcessor<DataSample> _dataSampleProcessor;
048
049 }