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, Chris Bono

Constructor Summary

Constructors

Constructor and Description
WebsocketConsumerConfiguration()

Method Summary

Modifier and Type	Method and Description
void	init()
Consumer<org.springframework.messaging.Message<?>>	websocketConsumer(InMemoryTraceRepository websocketTraceRepository)
WebsocketConsumerTraceEndpoint	websocketTraceEndpoint(InMemoryTraceRepository websocketTraceRepository)

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

websocketTraceEndpoint

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

websocketConsumer

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