Class MetricsTestBean
- java.lang.Object
-
- org.eclipse.microprofile.reactive.messaging.tck.metrics.MetricsTestBean
-
@ApplicationScoped public class MetricsTestBean extends Object
-
-
Field Summary
Fields Modifier and Type Field Description static String
CHANNEL_APP_A
static String
CHANNEL_APP_B
static String
CONNECTOR_IN
static String
CONNECTOR_OUT
static String
CONNECTOR_PROCESS
-
Constructor Summary
Constructors Constructor Description MetricsTestBean()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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<String>
split(String input)
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<Message<String>>
split(Message<String> a)
-
-
-
Field Detail
-
CONNECTOR_IN
public static final String CONNECTOR_IN
- See Also:
- Constant Field Values
-
CONNECTOR_PROCESS
public static final String CONNECTOR_PROCESS
- See Also:
- Constant Field Values
-
CONNECTOR_OUT
public static final String CONNECTOR_OUT
- See Also:
- Constant Field Values
-
CHANNEL_APP_A
public static final String CHANNEL_APP_A
- See Also:
- Constant Field Values
-
CHANNEL_APP_B
public static final String CHANNEL_APP_B
- See Also:
- Constant Field Values
-
-
Method Detail
-
split
public org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<Message<String>> split(Message<String> a)
-
produce
public org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<String> produce()
-
split
public org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<String> split(String input)
-
receive
public void receive(String input)
-
getInAppMessagesReceived
public int getInAppMessagesReceived()
-
-