1
14
15 package com.liferay.portal.convert.messaging;
16
17 import com.liferay.portal.convert.ConvertProcess;
18 import com.liferay.portal.kernel.log.Log;
19 import com.liferay.portal.kernel.log.LogFactoryUtil;
20 import com.liferay.portal.kernel.messaging.Message;
21 import com.liferay.portal.kernel.messaging.MessageListener;
22 import com.liferay.portal.kernel.util.InstancePool;
23 import com.liferay.portal.util.ShutdownUtil;
24
25
31 public class ConvertProcessMessageListener implements MessageListener {
32
33 public void receive(Message message) {
34 try {
35 doReceive(message);
36 }
37 catch (Exception e) {
38 _log.fatal("Unable to process message " + message, e);
39
40 ShutdownUtil.shutdown(0);
41 }
42 }
43
44 protected void doReceive(Message message) throws Exception {
45 String className = (String)message.getPayload();
46
47 ConvertProcess convertProcess = (ConvertProcess)InstancePool.get(
48 className);
49
50 convertProcess.convert();
51 }
52
53 private static Log _log = LogFactoryUtil.getLog(
54 ConvertProcessMessageListener.class);
55
56 }