标签使用和用户漏斗MQ

pcloud-common-core/src/main/java/com/pcloud/common/core/biz/FunnelFlowQueueBizImpl.java

 package com.pcloud.common.core.biz;
 
-import javax.jms.JMSException;
-import javax.jms.ObjectMessage;
-import javax.jms.Session;
-
-import org.apache.activemq.command.ActiveMQQueue;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
+import org.springframework.amqp.core.AmqpTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Qualifier;
-import org.springframework.jms.core.JmsTemplate;
-import org.springframework.jms.core.MessageCreator;
 import org.springframework.stereotype.Component;
 
+import com.pcloud.common.core.aspect.ParamLog;
 import com.pcloud.common.core.constant.FunnelFlowStruct.FlowNode;
 import com.pcloud.common.core.constant.FunnelFlowStruct.TargetRoleType;
 import com.pcloud.common.core.constant.FunnelFlowStruct.TargetType;
+import com.pcloud.common.core.constant.MQQueueConstant;
 import com.pcloud.common.core.dto.FunnelFlowQueueDto;
 import com.pcloud.common.exceptions.BizException;
 
 /**
- * @描述： 发送模板消息队列实现类
- * @作者： shuyh
- * @创建时间： 2018年1月9日
- * @版本：1.0
+ * @描述： 发送模板消息队列实现类 @作者： shuyh @创建时间： 2018年1月9日 @版本：1.0
  */
 @Component("funnelFlowQueueBiz")
-public class FunnelFlowQueueBizImpl implements FunnelFlowQueueBiz{
-
-	/**
-	 * 
-	 */
-	private final static Logger logger=LoggerFactory.getLogger(FunnelFlowQueueBizImpl.class);
-	
-	@Autowired(required=false)
-	@Qualifier("jmsFunnelFlowTemplate")
-	private JmsTemplate jmsFunnelFlowTemplate;
+public class FunnelFlowQueueBizImpl implements FunnelFlowQueueBiz {
 
-	@Autowired(required=false)
-	@Qualifier("funnelFlowQueue")
-	private ActiveMQQueue funnelFlowQueue;
+	@Autowired
+	private AmqpTemplate amqpTemplate;
 
 	/**
-	 * 发送队列
+	 * 用户漏斗QUEUE
 	 */
 	@Override
+	@ParamLog("用户漏斗QUEUE")
 	public void sendMessageQueue(FunnelFlowQueueDto funnelFlowQueueDto) throws BizException {
-		MessageCreator messageCreator = new MessageCreator() {
-			@Override
-			public ObjectMessage createMessage(Session session) throws JMSException {
-				return session.createObjectMessage(funnelFlowQueueDto);
-			}
-		};
-
-		try {
-			jmsFunnelFlowTemplate.send(funnelFlowQueue, messageCreator);
-		} catch (Exception e) {
-			logger.error("发送失败，" + e.getMessage() + "," + funnelFlowQueueDto, e);
-			throw BizException.SEND_QUEUE_FAIL;
-		}
-		logger.info("发送成功，" + funnelFlowQueueDto);
+		amqpTemplate.convertAndSend(MQQueueConstant.FUNNEL_FLOW, funnelFlowQueueDto);
 	}
 
 	/**
 	 * 发送队列
 	 */
 	@Override
-	public void sendMessageQueue(TargetType targetType, TargetRoleType targetRoleType, FlowNode flowNode, String ip, String userAgent) throws BizException {
-		FunnelFlowQueueDto funnelFlowQueueDto = new FunnelFlowQueueDto(targetType, targetRoleType, flowNode, ip, userAgent);
+	public void sendMessageQueue(TargetType targetType, TargetRoleType targetRoleType, FlowNode flowNode, String ip,
+			String userAgent) throws BizException {
+		FunnelFlowQueueDto funnelFlowQueueDto = new FunnelFlowQueueDto(targetType, targetRoleType, flowNode, ip,
+				userAgent);
 		sendMessageQueue(funnelFlowQueueDto);
 	}
 
@@ -75,8 +45,10 @@ public class FunnelFlowQueueBizImpl implements FunnelFlowQueueBiz{
 	 * 发送队列
 	 */
 	@Override
-	public void sendMessageQueue(TargetType targetType, Long targetId, TargetRoleType targetRoleType, Long targetRoleId, FlowNode flowNode) throws BizException {
-		FunnelFlowQueueDto funnelFlowQueueDto = new FunnelFlowQueueDto(targetType, targetId, targetRoleType, targetRoleId, flowNode);
+	public void sendMessageQueue(TargetType targetType, Long targetId, TargetRoleType targetRoleType, Long targetRoleId,
+			FlowNode flowNode) throws BizException {
+		FunnelFlowQueueDto funnelFlowQueueDto = new FunnelFlowQueueDto(targetType, targetId, targetRoleType,
+				targetRoleId, flowNode);
 		sendMessageQueue(funnelFlowQueueDto);
 	}
 
@@ -84,8 +56,10 @@ public class FunnelFlowQueueBizImpl implements FunnelFlowQueueBiz{
 	 * 发送队列
 	 */
 	@Override
-	public void sendMessageQueue(TargetType targetType, Long targetId, String subtypeCode, TargetRoleType targetRoleType, Long targetRoleId, FlowNode flowNode) throws BizException {
-		FunnelFlowQueueDto funnelFlowQueueDto = new FunnelFlowQueueDto(targetType, targetId, subtypeCode, targetRoleType, targetRoleId, flowNode);
+	public void sendMessageQueue(TargetType targetType, Long targetId, String subtypeCode,
+			TargetRoleType targetRoleType, Long targetRoleId, FlowNode flowNode) throws BizException {
+		FunnelFlowQueueDto funnelFlowQueueDto = new FunnelFlowQueueDto(targetType, targetId, subtypeCode,
+				targetRoleType, targetRoleId, flowNode);
 		sendMessageQueue(funnelFlowQueueDto);
 	}
 

pcloud-common-core/src/main/java/com/pcloud/common/core/biz/LabelUsedQueueBizImpl.java

 package com.pcloud.common.core.biz;
 
-import javax.jms.JMSException;
-import javax.jms.ObjectMessage;
-import javax.jms.Session;
-
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
+import org.springframework.amqp.core.AmqpTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Qualifier;
-import org.springframework.jms.core.JmsTemplate;
-import org.springframework.jms.core.MessageCreator;
 import org.springframework.stereotype.Component;
 
+import com.pcloud.common.core.aspect.ParamLog;
+import com.pcloud.common.core.constant.MQQueueConstant;
 import com.pcloud.common.core.dto.LabelUsedMessageDto;
 import com.pcloud.common.exceptions.BizException;
 
 /**
- * @描述： 标签使用队列实现类
- * @作者： shuyh
- * @创建时间： 2017年5月23日
- * @版本：1.0
+ * @描述： 标签使用队列实现类 @作者： shuyh @创建时间： 2017年5月23日 @版本：1.0
  */
 @Component("labelUsedQueueBiz")
-public class LabelUsedQueueBizImpl implements LabelUsedQueueBiz{
-
-	/**
-	 * 
-	 */
-	private final static Logger logger = LoggerFactory.getLogger(LabelUsedQueueBizImpl.class);
+public class LabelUsedQueueBizImpl implements LabelUsedQueueBiz {
 
-	@Autowired(required=false)
-	@Qualifier("jmsLabelUsedTemplate")
-	private JmsTemplate jmsLabelUsedTemplate;
+	@Autowired
+	private AmqpTemplate amqpTemplate;
 
-	/**
-	 * 发送队列
-	 */
 	@Override
+	@ParamLog("标签使用QUEUE")
 	public void sendMessageQueue(LabelUsedMessageDto labelUsedMessageDto) throws BizException {
-		MessageCreator messageCreator = new MessageCreator() {
-			@Override
-			public ObjectMessage createMessage(Session session) throws JMSException {
-				return session.createObjectMessage(labelUsedMessageDto);
-			}
-		};
-
-		try {
-			jmsLabelUsedTemplate.send(messageCreator);
-		} catch (Exception e) {
-			logger.error("发送失败，" + e.getMessage() + "," + labelUsedMessageDto, e);
-			throw BizException.SEND_QUEUE_FAIL;
-		}
-		logger.info("发送成功，" + labelUsedMessageDto);
+		amqpTemplate.convertAndSend(MQQueueConstant.LABEL_USED, labelUsedMessageDto);
 	}
 
 }