mq.rar springcloud整合rabbit java工程

package com.yuesuan.document.mq; import com.yuesuan.common.entity.PDFConvertInfo; import com.yuesuan.document.doc.vo.FlowLogVO; import lombok.AllArgsConstructor; import org.springframework.messaging.support.MessageBuilder; import org.springframework.stereotype.Component; import java.util.List; @Component @AllArgsConstructor public class MQSend { private final MQProcessor mqProcessor; /** * 发送需要转换pdf的资料url */ public void sendToPDFConvert(PDFConvertInfo pdfConvertInfo) { /*//如果是包含域名，先取出路径，再转换为适合的全路径； if (pdfConvertInfo.getFileUrl().contains("http")) { String path = URLUtil.decode(aliOss.getPathFromLink(pdfConvertInfo.getFileUrl())); pdfConvertInfo.setFileUrl(aliOss.getInternalLink(path)); } else { // 如果只是路径，转换成合适的全路径 pdfConvertInfo.setFileUrl(aliOss.getInternalLink(URLUtil.decode(pdfConvertInfo.getFileUrl()))); }*/ mqProcessor.documentUrlOutput().send(MessageBuilder.withPayload(pdfConvertInfo).build()); System.out.println("发送了消息" + pdfConvertInfo); } /** * 根据节点发送需要保存流转日志 */ public void sendFlowLog(Long projectId, Integer node, Integer status, String message, String eMessage) { FlowLogVO flowLog = new FlowLogVO(); flowLog.setProjectId(projectId); flowLog.setNode(node); flowLog.setStatus(status); flowLog.setMessage(message); flowLog.setEMessage(eMessage); mqProcessor.flowLogOutput().send(MessageBuilder.withPayload(flowLog).build()); System.out.println("发送了消息" + flowLog); } /** * 根据节点集合发送需要保存流转日志 */ public void sendFlowLogByNodes(Long projectId, List<Integer> nodes, Integer status, String message, String eMessage) { FlowLogVO flowLog = new FlowLogVO(); flowLog.setProjectId(projectId); flowLog.setNodes(nodes); flowLog.setStatus(status); flowLog.setMessage(message); flowLog.setEMessage(eMessage); mqProcessor.flowLogOutput().send(MessageBuilder.withPayload(flowLog).build()); System.out.println("发送了消息" + flowLog); } }