@ApplicationScoped public class TestConnector extends Object implements IncomingConnectorFactory, OutgoingConnectorFactory
Modifier and Type | Field and Description |
---|---|
static String |
ID |
CHANNEL_NAME_ATTRIBUTE, CONNECTOR_ATTRIBUTE, CONNECTOR_PREFIX, INCOMING_PREFIX, OUTGOING_PREFIX
Constructor and Description |
---|
TestConnector() |
Modifier and Type | Method and Description |
---|---|
Message<String> |
get(String channel) |
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<String>> |
getPublisherBuilder(org.eclipse.microprofile.config.Config config) |
org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<String>,Void> |
getSubscriberBuilder(org.eclipse.microprofile.config.Config config) |
void |
send(String channel,
Message<String> message) |
public static final String ID
public org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<String>,Void> getSubscriberBuilder(org.eclipse.microprofile.config.Config config)
getSubscriberBuilder
in interface OutgoingConnectorFactory
public org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<String>> getPublisherBuilder(org.eclipse.microprofile.config.Config config)
getPublisherBuilder
in interface IncomingConnectorFactory
Copyright © 2018 – 2022 Eclipse Foundation. All rights reserved.
Use is subject to license terms.