Skip to content

Instantly share code, notes, and snippets.



Created Mar 20, 2020
What would you like to do?
public class ExampleConnector implements IncomingConnectorFactory, OutgoingConnectorFactory {
public PublisherBuilder<? extends Message<?>> getPublisherBuilder(Config config) {
return ReactiveStreams.of("foo", "bar")
public SubscriberBuilder<? extends Message<?>, Void> getSubscriberBuilder(Config config) {
return ReactiveStreams.<Message<?>>builder()
.forEach(o -> System.out.println("Connector says: " + o));
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment