Class ProcessorBean
- java.lang.Object
-
- org.eclipse.microprofile.reactive.messaging.tck.signatures.processors.ProcessorBean
-
@ApplicationScoped public class ProcessorBean extends Object
-
-
Constructor Summary
Constructors Constructor Description ProcessorBean()
-
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)
org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<Message<Integer>,Message<String>>
processorBuilderOfMessages()
org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<Integer,String>
processorBuilderOfPayloads()
org.reactivestreams.Processor<Message<Integer>,Message<String>>
processorOfMessages()
org.reactivestreams.Processor<Integer,String>
processorOfPayloads()
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)
-
processorOfMessages
public org.reactivestreams.Processor<Message<Integer>,Message<String>> processorOfMessages()
-
processorBuilderOfMessages
public org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<Message<Integer>,Message<String>> processorBuilderOfMessages()
-
-