001
014
015 package com.liferay.portal.messaging.async;
016
017 import com.liferay.portal.kernel.log.Log;
018 import com.liferay.portal.kernel.log.LogFactoryUtil;
019 import com.liferay.portal.kernel.messaging.Message;
020 import com.liferay.portal.kernel.messaging.MessageListener;
021
022
026 public class AsyncMessageListener implements MessageListener {
027
028 public void receive(Message message) {
029 try {
030 doReceive(message);
031 }
032 catch (Exception e) {
033 _log.error("Unable to process message " + message, e);
034 }
035 }
036
037 protected void doReceive(Message message) throws Exception {
038 Runnable runnable = (Runnable)message.getPayload();
039
040 runnable.run();
041 }
042
043 private static Log _log = LogFactoryUtil.getLog(AsyncMessageListener.class);
044
045 }