時間觸發程式：
package com.progria; import java.util.Properties; import org.easyrules.core.AnnotatedRulesEngine; import org.quartz.Job; import org.quartz.JobDataMap; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; import org.quartz.JobKey; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import com.rabbitmq.client.ConnectionFactory; import com.rabbitmq.client.Connection; import com.rabbitmq.client.Channel; import com.rabbitmq.client.QueueingConsumer; public class BizRuleSet implements Job { private final Logger myLog = LoggerFactory.getLogger(getClass()); private final long WAIT_FOR_MSG = 30 * 1000L; public BizRuleSet() { } public boolean CheckRules(Properties actionResult) { boolean OK = false; if (!actionResult.isEmpty()) { OK = (actionResult.getProperty("FriendshipRule") == "1" && actionResult .getProperty("AgeRule") == "2"); } return OK; } public void receiveMessages(String hostName, String queueName, JobKey jobKey) { ConnectionFactory factory = new ConnectionFactory(); factory.setHost(hostName); Connection mqConnection; try { mqConnection = factory.newConnection(); Channel mqChannel = mqConnection.createChannel(); mqChannel.queueDeclare(queueName, true, false, false, null); QueueingConsumer mqConsumer = new QueueingConsumer(mqChannel); mqChannel.basicConsume(queueName, true, mqConsumer); QueueingConsumer.Delivery mqDelivery = null; while ((mqDelivery = mqConsumer.nextDelivery(WAIT_FOR_MSG)) != null) { String mqMessage = new String(mqDelivery.getBody()); String jobParams[] = mqMessage.split("\\|"); String friendshipString = jobParams[0]; String ageString = jobParams[1]; Properties actionResult = new Properties(); AnnotatedRulesEngine rulesEngine = new AnnotatedRulesEngine(); FriendshipRule myFriendshipRule = new FriendshipRule( actionResult); AgeRule myAgeRule = new AgeRule(actionResult); myFriendshipRule.setInput(friendshipString.trim()); myAgeRule.setInput(ageString.trim()); rulesEngine.registerRule(myFriendshipRule); rulesEngine.registerRule(myAgeRule); rulesEngine.fireRules(); String anser = "X"; if (this.CheckRules(actionResult)) { anser = "O"; } this.myLog.warn(String.format("%s:[%s=%s]", jobKey.toString(), mqMessage, anser)); } mqChannel.close(); mqConnection.close(); } catch (Exception e) { this.myLog.error("MQ:" + e.getMessage()); } } @Override public void execute(JobExecutionContext jobContext) throws JobExecutionException { JobKey jobKey = jobContext.getJobDetail().getKey(); JobDataMap dataMap = jobContext.getJobDetail().getJobDataMap(); String jobParamList = dataMap.getString("jobParam"); String jobParams[] = jobParamList.split("\\|"); if (jobParams.length == 2) { String hostName = jobParams[0]; String queueName = jobParams[1]; this.myLog.warn(String.format("%s:[%s:%s]", jobKey.toString(), hostName, queueName)); this.receiveMessages(hostName, queueName, jobKey); } else { this.myLog.warn(String.format("%s:[%s]", jobKey.toString(), jobParamList)); } } }