瀏覽代碼

修改hos-arbiter和hos-broker依赖关系

Airhead 8 年之前
父節點
當前提交
65b6b8898e
共有 1 個文件被更改,包括 8 次插入5 次删除
  1. 8 5
      src/main/java/com/yihu/hos/services/ServiceFlowEventService.java

+ 8 - 5
src/main/java/com/yihu/hos/services/ServiceFlowEventService.java

@ -4,18 +4,21 @@ import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.node.ObjectNode;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.stereotype.Component;
import javax.jms.Queue;
/**
 * @created Airhead 2016/8/2.
 */
@Component
public class ServiceFlowEventService {
//    @Autowired
//    private JmsMessagingTemplate jmsMessagingTemplate;
    @Autowired
    private JmsMessagingTemplate jmsMessagingTemplate;
//    @Autowired
//    private Queue queue;
    @Autowired
    private Queue queue;
    @Autowired
    private ObjectMapper objectMapper;
@ -73,7 +76,7 @@ public class ServiceFlowEventService {
        objectNode.put("path", path);
        try {
            String msg = objectMapper.writeValueAsString(objectNode);
//            this.jmsMessagingTemplate.convertAndSend(this.queue, msg);
            this.jmsMessagingTemplate.convertAndSend(this.queue, msg);
        } catch (JsonProcessingException e) {
            e.printStackTrace();
        }