001
014
015 package com.liferay.portlet.documentlibrary.messaging;
016
017 import com.liferay.portal.kernel.log.Log;
018 import com.liferay.portal.kernel.log.LogFactoryUtil;
019 import com.liferay.portal.kernel.messaging.BaseMessageListener;
020 import com.liferay.portal.kernel.messaging.Message;
021 import com.liferay.portal.kernel.messaging.MessageBusUtil;
022 import com.liferay.portal.kernel.repository.model.FileVersion;
023 import com.liferay.portal.util.PropsValues;
024 import com.liferay.portlet.documentlibrary.util.VideoProcessorUtil;
025
026
030 public class VideoProcessorMessageListener extends BaseMessageListener {
031
032 @Override
033 protected void doReceive(Message message) throws Exception {
034 FileVersion fileVersion = (FileVersion)message.getPayload();
035
036 try {
037 VideoProcessorUtil.generateVideo(fileVersion);
038 }
039 catch (Exception e) {
040 if (_log.isWarnEnabled()) {
041 _log.warn(
042 "Unable to generate video for file version " +
043 fileVersion.getFileVersionId(),
044 e);
045 }
046 }
047
048 if (PropsValues.DL_FILE_ENTRY_PROCESSORS_TRIGGER_SYNCHRONOUSLY) {
049 MessageBusUtil.sendMessage(
050 message.getResponseDestinationName(), message);
051 }
052 }
053
054 private static Log _log = LogFactoryUtil.getLog(
055 VideoProcessorMessageListener.class);
056
057 }