| | |
| | | /* |
| | | |
| | | package com.moral.api.exception.consumer; |
| | | |
| | |
| | | import com.moral.constant.KafkaConstants; |
| | | |
| | | |
| | | /* |
| | | * 走航车数据消费者 |
| | | * |
| | | */ |
| | | /* * 走航车数据消费者 |
| | | **//* |
| | | |
| | | |
| | | |
| | |
| | | } |
| | | } |
| | | |
| | | */ |
| | |
| | | /* |
| | | |
| | | package com.moral.api.exception.consumer; |
| | | |
| | |
| | | import java.util.concurrent.CopyOnWriteArraySet; |
| | | |
| | | |
| | | */ |
| | | /* |
| | | * |
| | | /** |
| | | * @ClassName SecondsDataConsumer1 |
| | | * @Description TODO |
| | | * @Author 陈凯裕 |
| | | * @Date 2021/6/15 14:49 |
| | | * @Version TODO |
| | | * |
| | | *//* |
| | | **/ |
| | | |
| | | |
| | | |
| | | |
| | |
| | | } |
| | | |
| | | |
| | | */ |
| | |
| | | /* |
| | | package com.moral.api.websocket; |
| | | |
| | | import com.moral.api.entity.Device; |
| | |
| | | import java.util.Map; |
| | | import java.util.concurrent.CopyOnWriteArraySet; |
| | | |
| | | */ |
| | | /** |
| | | * @ClassName SingleDeviceServer |
| | | * @Description TODO |
| | | * @Author 陈凯裕 |
| | | * @Date 2021/6/15 13:56 |
| | | * @Version TODO |
| | | **//* |
| | | **/ |
| | | |
| | | @ServerEndpoint("/singleDevice/{mac}") |
| | | @Component |
| | |
| | | } |
| | | |
| | | } |
| | | */ |