@ApplicationScoped public class DirectProcessorBean extends Object
Constructor and Description |
---|
DirectProcessorBean() |
Modifier and Type | Method and 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() |
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 String payloadSynchronous(int value)
public CompletionStage<Message<String>> messageAsynchronous(Message<Integer> message)
public CompletionStage<String> payloadAsynchronous(int value)
Copyright © 2018–2021 Eclipse Foundation. All rights reserved.