Class PublisherBean


  • @ApplicationScoped
    public class PublisherBean
    extends Object
    • Constructor Detail

      • PublisherBean

        public PublisherBean()
    • 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.Publisher<String> processorOfPayloads​(int value)
      • processorBuilderOfMessages

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

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