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