A consumer that allows you to send messages using websocket.
You can import WebsocketConsumerConfiguration
in the application and then inject the following bean.
Consumer<Message<?>> websocketConsumer
You can use websocketConsumer
as a qualifier when injecting.
All configuration properties are prefixed with websocket.consumer
.
For more information on the various options available, please see WebsocketConsumerProperties.
See this test suite for the various ways, this consumer is used.
See this README where this consumer is used to create a Spring Cloud Stream application where it makes a TCP sink.