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 import com.liferay.portlet.documentlibrary.util.RawMetadataProcessorUtil;
023
024
027 public class RawMetadataProcessorMessageListener extends BaseMessageListener {
028
029 @Override
030 protected void doReceive(Message message) throws Exception {
031 FileVersion fileVersion = (FileVersion)message.getPayload();
032
033 try {
034 RawMetadataProcessorUtil.saveMetadata(fileVersion);
035 }
036 catch (Exception e) {
037 if (_log.isWarnEnabled()) {
038 _log.warn(
039 "Unable to save metadata for file version " +
040 fileVersion.getFileVersionId(),
041 e);
042 }
043 }
044 }
045
046 private static Log _log = LogFactoryUtil.getLog(
047 RawMetadataProcessorMessageListener.class);
048
049 }