@ApplicationScoped public class ProcessorBean extends Object
Constructor and Description |
---|
ProcessorBean() |
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.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() |
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.Processor<Message<Integer>,Message<String>> processorOfMessages()
public org.eclipse.microprofile.reactive.streams.operators.ProcessorBuilder<Message<Integer>,Message<String>> processorBuilderOfMessages()
Copyright © 2018 – 2022 Eclipse Foundation. All rights reserved.
Use is subject to license terms.