001
014
015 package com.liferay.portal.scheduler.messaging;
016
017 import com.liferay.portal.kernel.messaging.BaseMessageListener;
018 import com.liferay.portal.kernel.messaging.Message;
019 import com.liferay.portal.kernel.scheduler.SchedulerEngine;
020 import com.liferay.portal.kernel.scripting.ScriptingUtil;
021 import com.liferay.portal.kernel.util.StringPool;
022
023 import java.util.HashMap;
024 import java.util.Map;
025
026
029 public class ScriptingMessageListener extends BaseMessageListener {
030
031 @Override
032 public void doReceive(Message message) throws Exception {
033 Map<String, Object> inputObjects = new HashMap<String, Object>();
034
035 String language = (String)message.get(SchedulerEngine.LANGUAGE);
036 String script = (String)message.get(SchedulerEngine.SCRIPT);
037
038 ScriptingUtil.exec(
039 null, inputObjects, language, script, StringPool.EMPTY_ARRAY);
040 }
041
042 }