Simple Broker

내장 simple message broker는 클라이언트로부터의 subscription 요청을 처리하고, 이를 메모리에 저장한 다음, 일치하는 destination을 가진 연결된 클라이언트들에게 message를 broadcast합니다. broker는 path와 유사한 destination을 지원하며, Ant-style destination pattern에 대한 subscription도 포함합니다.

애플리케이션은 slash-separated destination 대신 dot-separated destination도 사용할 수 있습니다. Dots as Separators를 참조하세요.

task scheduler로 구성된 경우, simple broker는 STOMP heartbeats를 지원합니다. scheduler를 구성하려면, 직접 TaskScheduler 빈을 선언하고 이를 MessageBrokerRegistry를 통해 설정할 수 있습니다.

또는, 내장 WebSocket configuration에서 자동으로 선언되는 것을 사용할 수도 있지만, 이 경우 내장 WebSocket configuration과 WebSocketMessageBrokerConfigurer 사이의 cycle을 피하기 위해 @Lazy가 필요합니다. 예:

1@Configuration
2@EnableWebSocketMessageBroker
3public class WebSocketConfiguration implements WebSocketMessageBrokerConfigurer {
4
5	private TaskScheduler messageBrokerTaskScheduler;
6
7	@Autowired
8	public void setMessageBrokerTaskScheduler(@Lazy TaskScheduler taskScheduler) {
9		this.messageBrokerTaskScheduler = taskScheduler;
10	}
11
12	@Override
13	public void configureMessageBroker(MessageBrokerRegistry registry) {
14		registry.enableSimpleBroker("/queue/", "/topic/")
15				.setHeartbeatValue(new long[] {10000, 20000})
16				.setTaskScheduler(this.messageBrokerTaskScheduler);
17
18		// ...
19	}
20}

1@Configuration
2@EnableWebSocketMessageBroker
3class WebSocketConfiguration : WebSocketMessageBrokerConfigurer {
4
5	private lateinit var messageBrokerTaskScheduler: TaskScheduler
6
7	@Autowired
8	fun setMessageBrokerTaskScheduler(@Lazy taskScheduler: TaskScheduler) {
9		this.messageBrokerTaskScheduler = taskScheduler
10	}
11
12	override fun configureMessageBroker(registry: MessageBrokerRegistry) {
13		registry.enableSimpleBroker("/queue/", "/topic/")
14			.setHeartbeatValue(longArrayOf(10000, 20000))
15			.setTaskScheduler(messageBrokerTaskScheduler)
16
17		// ...
18	}
19}