From 25fae4a8608a91c5aae1db876a13cffd6418f573 Mon Sep 17 00:00:00 2001 From: kaiyu <404897439@qq.com> Date: Mon, 30 Nov 2020 16:02:38 +0800 Subject: [PATCH] 删除测试代码 --- src/main/java/com/moral/config/WebSocketConfig.java | 26 ++++++++++++++++++++++++-- 1 files changed, 24 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..df8b756 100644 --- a/src/main/java/com/moral/config/WebSocketConfig.java +++ b/src/main/java/com/moral/config/WebSocketConfig.java @@ -1,7 +1,15 @@ package com.moral.config; +import com.moral.service.DeviceService; +import com.moral.service.SensorService; +import com.moral.webSocketServer.BSAQIWebSocketServer; +import com.moral.webSocketServer.BSWebsocketServer; +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 +17,28 @@ @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; + BSWebsocketServer.deviceService=deviceService; + BSAQIWebSocketServer.deviceService=deviceService; + } + @Autowired + public void setSensorService( SensorService sensorService){ + BSWebsocketServer.sensorService=sensorService; + BSAQIWebSocketServer.sensorService=sensorService; + } + } -- Gitblit v1.8.0