org.springframework.cloud.stream.app.websocket.sink

Class WebsocketSinkConfiguration

java.lang.Object

org.springframework.cloud.stream.app.websocket.sink.WebsocketSinkConfiguration

@Configuration
 @EnableConfigurationProperties(value=WebsocketSinkProperties.class)
 @EnableBinding(value=org.springframework.cloud.stream.messaging.Sink.class)
public class WebsocketSinkConfiguration
extends Object

Author:

Oliver Moser, Gary Russell, Artem Bilan

Constructor Summary

Constructors

Constructor and Description
WebsocketSinkConfiguration()

Method Summary

Modifier and Type	Method and Description
void	init()
WebsocketSinkServerInitializer	initializer()
WebsocketSinkServer	server()
void	websocketSink(org.springframework.messaging.Message<?> message)
WebsocketSinkTraceEndpoint	websocketTraceEndpoint()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WebsocketSinkConfiguration

public WebsocketSinkConfiguration()

Method Detail

init

@PostConstruct
public void init()
                         throws InterruptedException

Throws:

InterruptedException

server

@Bean
public WebsocketSinkServer server()

initializer

@Bean
public WebsocketSinkServerInitializer initializer()

websocketTraceEndpoint

@Bean
 @ConditionalOnProperty(value="endpoints.websocketsinktrace.enabled",
                       havingValue="true")
public WebsocketSinkTraceEndpoint websocketTraceEndpoint()

websocketSink

@StreamListener(value="input")
public void websocketSink(org.springframework.messaging.Message<?> message)