Class TransformerBean


  • @ApplicationScoped
    public class TransformerBean
    extends Object
    • Constructor Detail

      • TransformerBean

        public TransformerBean()
    • 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​(org.reactivestreams.Publisher<Message<Integer>> stream)
      • processorOfPayloads

        public org.reactivestreams.Publisher<String> processorOfPayloads​(org.reactivestreams.Publisher<Integer> stream)
      • processorBuilderOfMessages

        public org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<Message<String>> processorBuilderOfMessages​(org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<Message<Integer>> stream)
      • processorBuilderOfPayloads

        public org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<String> processorBuilderOfPayloads​(org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<Integer> stream)