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.repository.model.FileVersion;
022
023
026 public abstract class BaseProcessorMessageListener extends BaseMessageListener {
027
028 @Override
029 protected void doReceive(Message message) throws Exception {
030 Object[] array = (Object[])message.getPayload();
031
032 FileVersion sourceFileVersion = (FileVersion)array[0];
033 FileVersion destinationFileVersion = (FileVersion)array[1];
034
035 try {
036 generate(sourceFileVersion, destinationFileVersion);
037 }
038 catch (Exception e) {
039 if (_log.isWarnEnabled()) {
040 _log.warn(
041 "Unable to process file version " +
042 destinationFileVersion.getFileVersionId(),
043 e);
044 }
045 }
046 }
047
048 protected abstract void generate(
049 FileVersion sourceFileVersion, FileVersion destinationFileVersion)
050 throws Exception;
051
052 private static Log _log = LogFactoryUtil.getLog(
053 BaseProcessorMessageListener.class);
054
055 }