@ApplicationScoped public class MetricsTestBean extends Object
Modifier and Type | Field and Description |
---|---|
static String |
CHANNEL_APP_A |
static String |
CHANNEL_APP_B |
static String |
CONNECTOR_IN |
static String |
CONNECTOR_OUT |
static String |
CONNECTOR_PROCESS |
Constructor and Description |
---|
MetricsTestBean() |
Modifier and Type | Method and Description |
---|---|
int |
getInAppMessagesReceived() |
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<String> |
produce() |
void |
receive(String input) |
String |
simpleMapping(String a) |
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<Message<String>> |
split(Message<String> a) |
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<String> |
split(String input) |
public static final String CONNECTOR_IN
public static final String CONNECTOR_PROCESS
public static final String CONNECTOR_OUT
public static final String CHANNEL_APP_A
public static final String CHANNEL_APP_B
public org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<Message<String>> split(Message<String> a)
public org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<String> produce()
public org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<String> split(String input)
public void receive(String input)
public int getInAppMessagesReceived()
Copyright © 2018 – 2022 Eclipse Foundation. All rights reserved.
Use is subject to license terms.