Package org.springframework.cloud.fn.consumer.websocket

Class WebsocketConsumerConfiguration

java.lang.Object

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

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

Author:

Oliver Moser, Gary Russell, Artem Bilan, Chris Bono

Constructor Summary

Constructors

Constructor	Description
WebsocketConsumerConfiguration()

Method Summary

Modifier and Type	Method	Description
void	init()
Consumer<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 Details

WebsocketConsumerConfiguration

public WebsocketConsumerConfiguration()

Method Details

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<Message<?>> websocketConsumer(InMemoryTraceRepository websocketTraceRepository)