Class DirectProcessorBean


  • @ApplicationScoped
    public class DirectProcessorBean
    extends Object
    • Constructor Detail

      • DirectProcessorBean

        public DirectProcessorBean()
    • 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)
      • payloadSynchronous

        public String payloadSynchronous​(int value)