org.springframework.cloud.fn.supplier.websocket

Class WebsocketSupplierConfiguration

java.lang.Object

org.springframework.cloud.fn.supplier.websocket.WebsocketSupplierConfiguration

@Configuration
 @EnableConfigurationProperties(value=WebsocketSupplierProperties.class)
public class WebsocketSupplierConfiguration
extends Object

A supplier that receives data over WebSocket.

Author:

Krishnaprasad A S, Artem Bilan

Constructor Summary

Constructors

Constructor and Description
WebsocketSupplierConfiguration()

Method Summary

Modifier and Type	Method and Description
org.springframework.integration.websocket.IntegrationWebSocketContainer	serverWebSocketContainer(org.springframework.beans.factory.ObjectProvider<org.springframework.integration.websocket.ServerWebSocketContainer.SockJsServiceOptions> sockJsServiceOptions)
org.springframework.integration.websocket.ServerWebSocketContainer.SockJsServiceOptions	sockJsServiceOptions()
org.reactivestreams.Publisher<org.springframework.messaging.Message<byte[]>>	websocketPublisher(org.springframework.integration.websocket.IntegrationWebSocketContainer serverWebSocketContainer)
Supplier<reactor.core.publisher.Flux<org.springframework.messaging.Message<?>>>	websocketSupplier(org.reactivestreams.Publisher<org.springframework.messaging.Message<?>> websocketPublisher, org.springframework.integration.websocket.inbound.WebSocketInboundChannelAdapter webSocketInboundChannelAdapter)

Methods inherited from class java.lang.Object

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

Constructor Detail

WebsocketSupplierConfiguration

public WebsocketSupplierConfiguration()

Method Detail

websocketSupplier

@Bean
public Supplier<reactor.core.publisher.Flux<org.springframework.messaging.Message<?>>> websocketSupplier(org.reactivestreams.Publisher<org.springframework.messaging.Message<?>> websocketPublisher,
                                                                                                               org.springframework.integration.websocket.inbound.WebSocketInboundChannelAdapter webSocketInboundChannelAdapter)

websocketPublisher

@Bean
public org.reactivestreams.Publisher<org.springframework.messaging.Message<byte[]>> websocketPublisher(org.springframework.integration.websocket.IntegrationWebSocketContainer serverWebSocketContainer)

sockJsServiceOptions

@Bean
 @ConditionalOnMissingBean
 @ConditionalOnProperty(prefix="websocket.sockJs",
                       name="enable",
                       havingValue="true")
public org.springframework.integration.websocket.ServerWebSocketContainer.SockJsServiceOptions sockJsServiceOptions()

serverWebSocketContainer

@Bean
public org.springframework.integration.websocket.IntegrationWebSocketContainer serverWebSocketContainer(org.springframework.beans.factory.ObjectProvider<org.springframework.integration.websocket.ServerWebSocketContainer.SockJsServiceOptions> sockJsServiceOptions)