@ApplicationScoped public class PublisherBean extends Object
Constructor and Description |
---|
PublisherBean() |
Modifier and Type | Method and 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() |
public org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<Integer> streamForProcessorOfMessages()
public org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<Integer> streamForProcessorOfPayloads()
public org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<Integer> streamForProcessorBuilderOfMessages()
public org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<Integer> streamForProcessorBuilderOfPayloads()
public void getMessgesFromProcessorOfMessages(String value)
public void getMessgesFromProcessorOfPayloads(String value)
public void getMessgesFromProcessorBuilderOfMessages(String value)
public void getMessgesFromProcessorBuilderOfPayloads(String value)
public org.reactivestreams.Publisher<Message<String>> processorOfMessages(Message<Integer> message)
public org.reactivestreams.Publisher<String> processorOfPayloads(int value)
public org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<Message<String>> processorBuilderOfMessages(Message<Integer> message)
public org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<String> processorBuilderOfPayloads(int value)
Copyright © 2018 – 2022 Eclipse Foundation. All rights reserved.
Use is subject to license terms.