Class ProcessorBean


  • @ApplicationScoped
    public class ProcessorBean
    extends Object
    • Constructor Detail

      • ProcessorBean

        public ProcessorBean()
    • 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)
      • processorOfPayloads

        public org.reactivestreams.Processor<Integer,​String> processorOfPayloads()
      • processorBuilderOfMessages

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

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