org.springframework.cloud.fn.consumer.websocket

Class WebsocketConsumerConfiguration

java.lang.Object

org.springframework.cloud.fn.consumer.websocket.WebsocketConsumerConfiguration

@Configuration
 @EnableConfigurationProperties(value=WebsocketConsumerProperties.class)
public class WebsocketConsumerConfiguration
extends Object

Author:

Oliver Moser, Gary Russell, Artem Bilan

Constructor Summary

Constructors

Constructor and Description
WebsocketConsumerConfiguration()

Method Summary

Modifier and Type	Method and Description
void	init()
WebsocketConsumerServerInitializer	initializer()
WebsocketConsumerServer	server()
Consumer<org.springframework.messaging.Message<?>>	websocketConsumer()
WebsocketConsumerTraceEndpoint	websocketTraceEndpoint()

Methods inherited from class java.lang.Object

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

Constructor Detail

WebsocketConsumerConfiguration

public WebsocketConsumerConfiguration()

Method Detail

init

@PostConstruct
public void init()
                         throws InterruptedException

Throws:

InterruptedException

server

@Bean
public WebsocketConsumerServer server()

initializer

@Bean
public WebsocketConsumerServerInitializer initializer()

websocketTraceEndpoint

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

websocketConsumer

@Bean
public Consumer<org.springframework.messaging.Message<?>> websocketConsumer()