@Configuration @EnableConfigurationProperties(value=WebsocketSinkProperties.class) @EnableBinding(value=org.springframework.cloud.stream.messaging.Sink.class) public class WebsocketSinkConfiguration extends Object
Constructor and Description |
---|
WebsocketSinkConfiguration() |
Modifier and Type | Method and Description |
---|---|
void |
init() |
WebsocketSinkServerInitializer |
initializer() |
WebsocketSinkServer |
server() |
void |
websocketSink(org.springframework.messaging.Message<?> message) |
WebsocketSinkTraceEndpoint |
websocketTraceEndpoint() |
@PostConstruct public void init() throws InterruptedException, CertificateException, SSLException
@Bean public WebsocketSinkServer server()
@Bean public WebsocketSinkServerInitializer initializer()
@Bean @ConditionalOnProperty(value="endpoints.websocketsinktrace.enabled", havingValue="true") public WebsocketSinkTraceEndpoint websocketTraceEndpoint()
@ServiceActivator(inputChannel="input") public void websocketSink(org.springframework.messaging.Message<?> message)
Copyright © 2016 Pivotal Software, Inc.. All rights reserved.