stream-applications

Files

Chris Bono 1c50531c13 GH-271: Remove duplication from pom.xml files

This proposal fixes many build warnings and is a general cleanup of the pom.xml files.

* Remove duplicate `dependency` entries  from pom.xml files
* Remove duplicate `repository` entries from pom.xml files
* Replace deprecated use of `receive(long)` in `HttpSourceTests`
* Reduce logging for Twitter integration tests

Fixes #271

2022-05-26 13:57:44 -04:00

src

Re-enable and fix tests for Boot 2.6 upgrade

2022-01-26 11:32:24 -05:00

pom.xml

GH-271: Remove duplication from pom.xml files

2022-05-26 13:57:44 -04:00

README.adoc

Websocket supplier/consumer - source/sink

2020-06-16 15:37:38 -04:00

README.adoc

# Websocket Consumer

A consumer that allows you to send messages using websocket.

## Beans for injection

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.

## Configuration Options

All configuration properties are prefixed with `websocket.consumer`.

For more information on the various options available, please see link:src/main/java/org/springframework/cloud/fn/consumer/websocket/WebsocketConsumerProperties.java[WebsocketConsumerProperties].

## Tests

See this link:src/test/java/org/springframework/cloud/fn/consumer/websocket[test suite] for the various ways, this consumer is used.

## Other usage

See this https://github.com/spring-cloud/stream-applications/blob/master/applications/sink/websocket-sink/README.adoc[README] where this consumer is used to create a Spring Cloud Stream application where it makes a TCP sink.