@ApplicationScoped public class TransformerBean extends Object
Constructor and Description |
---|
TransformerBean() |
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(org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<Message<Integer>> stream) |
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<String> |
processorBuilderOfPayloads(org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<Integer> stream) |
org.reactivestreams.Publisher<Message<String>> |
processorOfMessages(org.reactivestreams.Publisher<Message<Integer>> stream) |
org.reactivestreams.Publisher<String> |
processorOfPayloads(org.reactivestreams.Publisher<Integer> stream) |
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(org.reactivestreams.Publisher<Message<Integer>> stream)
public org.reactivestreams.Publisher<String> processorOfPayloads(org.reactivestreams.Publisher<Integer> stream)
public org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<Message<String>> processorBuilderOfMessages(org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<Message<Integer>> stream)
Copyright © 2018–2021 Eclipse Foundation. All rights reserved.