对比新文件 |
| | |
| | | package org.dromara.common.sse.config; |
| | | |
| | | import org.dromara.common.sse.controller.SseController; |
| | | import org.dromara.common.sse.core.SseEmitterManager; |
| | | import org.dromara.common.sse.listener.SseTopicListener; |
| | | import org.springframework.boot.autoconfigure.AutoConfiguration; |
| | | import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; |
| | | import org.springframework.boot.context.properties.EnableConfigurationProperties; |
| | | import org.springframework.context.annotation.Bean; |
| | | |
| | | /** |
| | | * SSE 鑷姩瑁呴厤 |
| | | * |
| | | * @author Lion Li |
| | | */ |
| | | @AutoConfiguration |
| | | @ConditionalOnProperty(value = "sse.enabled", havingValue = "true") |
| | | @EnableConfigurationProperties(SseProperties.class) |
| | | public class SseAutoConfiguration { |
| | | |
| | | @Bean |
| | | public SseEmitterManager sseEmitterManager() { |
| | | return new SseEmitterManager(); |
| | | } |
| | | |
| | | @Bean |
| | | public SseTopicListener sseTopicListener() { |
| | | return new SseTopicListener(); |
| | | } |
| | | |
| | | @Bean |
| | | public SseController sseController(SseEmitterManager sseEmitterManager) { |
| | | return new SseController(sseEmitterManager); |
| | | } |
| | | |
| | | } |