diff --git a/src/docs/asciidoc/web/websocket.adoc b/src/docs/asciidoc/web/websocket.adoc index 2db3226fd5..9afab81b35 100644 --- a/src/docs/asciidoc/web/websocket.adoc +++ b/src/docs/asciidoc/web/websocket.adoc @@ -1397,6 +1397,37 @@ Applications can also use dot-separated destinations (vs slash). See <>. ==== +If configured with a task scheduler, the simple broker supports +https://stomp.github.io/stomp-specification-1.2.html#Heart-beating[STOMP heartbeats]. +For that you can declare your own scheduler, or use the one that's automatically +declared and used internally: + +[source,java,indent=0] +[subs="verbatim,quotes"] +---- +@Configuration +@EnableWebSocketMessageBroker +public class WebSocketConfig implements WebSocketMessageBrokerConfigurer { + + private TaskScheduler messageBrokerTaskScheduler; + + @Autowired + public void setMessageBrokerTaskScheduler(TaskScheduler taskScheduler) { + this.messageBrokerTaskScheduler = taskScheduler; + } + + @Override + public void configureMessageBroker(MessageBrokerRegistry registry) { + + registry.enableSimpleBroker("/queue/", "/topic/") + .setHeartbeatValue(new long[] {10000, 20000}) + .setTaskScheduler(this.messageBrokerTaskScheduler); + + // ... + } +} +---- + [[websocket-stomp-handle-broker-relay]]