Class DirectProcessorBean
- java.lang.Object
-
- org.eclipse.microprofile.reactive.messaging.tck.signatures.processors.DirectProcessorBean
-
@ApplicationScoped public class DirectProcessorBean extends Object
-
-
Constructor Summary
Constructors Constructor Description DirectProcessorBean()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
getMessgesFromProcessorBuilderOfMessages(String value)
void
getMessgesFromProcessorBuilderOfPayloads(String value)
void
getMessgesFromProcessorOfMessages(String value)
void
getMessgesFromProcessorOfPayloads(String value)
CompletionStage<Message<String>>
messageAsynchronous(Message<Integer> message)
Message<String>
messageSynchronous(Message<Integer> message)
CompletionStage<String>
payloadAsynchronous(int value)
String
payloadSynchronous(int value)
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<Integer>
streamForProcessorBuilderOfMessages()
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<Integer>
streamForProcessorBuilderOfPayloads()
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<Integer>
streamForProcessorOfMessages()
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<Integer>
streamForProcessorOfPayloads()
-
-
-
Method Detail
-
streamForProcessorOfMessages
public org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<Integer> streamForProcessorOfMessages()
-
streamForProcessorOfPayloads
public org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<Integer> streamForProcessorOfPayloads()
-
streamForProcessorBuilderOfMessages
public org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<Integer> streamForProcessorBuilderOfMessages()
-
streamForProcessorBuilderOfPayloads
public org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<Integer> streamForProcessorBuilderOfPayloads()
-
getMessgesFromProcessorOfMessages
public void getMessgesFromProcessorOfMessages(String value)
-
getMessgesFromProcessorOfPayloads
public void getMessgesFromProcessorOfPayloads(String value)
-
getMessgesFromProcessorBuilderOfMessages
public void getMessgesFromProcessorBuilderOfMessages(String value)
-
getMessgesFromProcessorBuilderOfPayloads
public void getMessgesFromProcessorBuilderOfPayloads(String value)
-
payloadSynchronous
public String payloadSynchronous(int value)
-
messageAsynchronous
public CompletionStage<Message<String>> messageAsynchronous(Message<Integer> message)
-
payloadAsynchronous
public CompletionStage<String> payloadAsynchronous(int value)
-
-