From adde1ed1a99622c80a95dea83e294711d295c55c Mon Sep 17 00:00:00 2001 From: jinpengyong <jpy123456> Date: Tue, 08 Sep 2020 14:46:43 +0800 Subject: [PATCH] 微型站5分钟与半小时数据 --- src/main/java/com/moral/config/WebSocketConfig.java | 15 +++++++++++++-- 1 files changed, 13 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/moral/config/WebSocketConfig.java b/src/main/java/com/moral/config/WebSocketConfig.java index dc2b9eb..5e8a3b3 100644 --- a/src/main/java/com/moral/config/WebSocketConfig.java +++ b/src/main/java/com/moral/config/WebSocketConfig.java @@ -1,7 +1,12 @@ package com.moral.config; +import com.moral.service.DeviceService; +import com.moral.webSocketServer.WebSocketServer; + +import com.moral.webSocketServer.WebSocketServerNew; import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter; import org.springframework.amqp.support.converter.MessageConverter; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.web.socket.server.standard.ServerEndpointExporter; @@ -9,14 +14,20 @@ @Configuration public class WebSocketConfig { - @Bean +/* @Bean public ServerEndpointExporter serverEndpointExporter() { return new ServerEndpointExporter(); - } + }*/ @Bean public MessageConverter jsonMessageConverter() { return new Jackson2JsonMessageConverter(); } + @Autowired + public void setMessageService(DeviceService deviceService){ + WebSocketServer.deviceService=deviceService; + WebSocketServerNew.deviceService=deviceService; + } + } -- Gitblit v1.8.0