001
014
015 package com.liferay.portlet.documentlibrary.messaging;
016
017 import com.liferay.portal.kernel.messaging.BaseMessageListener;
018 import com.liferay.portal.kernel.messaging.Message;
019 import com.liferay.portal.kernel.messaging.MessageBusUtil;
020 import com.liferay.portal.kernel.repository.model.FileVersion;
021 import com.liferay.portal.util.PropsValues;
022 import com.liferay.portlet.documentlibrary.util.ImageProcessor;
023
024
027 public class ImageProcessorMessageListener extends BaseMessageListener {
028
029 @Override
030 protected void doReceive(Message message) throws Exception {
031 FileVersion fileVersion = (FileVersion)message.getPayload();
032
033 ImageProcessor.generateImages(fileVersion);
034
035 if (PropsValues.DL_FILE_ENTRY_PROCESSORS_TRIGGER_SYNCHRONOUSLY) {
036 MessageBusUtil.sendMessage(
037 message.getResponseDestinationName(), message);
038 }
039 }
040
041 }