Class SubscriberBean


  • @ApplicationScoped
    public class SubscriberBean
    extends Object
    • Constructor Detail

      • SubscriberBean

        public SubscriberBean()
    • Method Detail

      • sourceForSubscriberMessage

        public org.reactivestreams.Publisher<Message<String>> sourceForSubscriberMessage()
      • subscriberOfMessages

        public org.reactivestreams.Subscriber<Message<String>> subscriberOfMessages()
      • sourceForSubscriberBuilderMessage

        public org.reactivestreams.Publisher<Message<String>> sourceForSubscriberBuilderMessage()
      • subscriberBuilderOfMessages

        public org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<Message<String>,​Void> subscriberBuilderOfMessages()
      • sourceForSubscribePayload

        public org.reactivestreams.Publisher<Message<String>> sourceForSubscribePayload()
      • subscriberOfPayloads

        public org.reactivestreams.Subscriber<String> subscriberOfPayloads()
      • sourceForSubscriberBuilderPayload

        public org.reactivestreams.Publisher<Message<String>> sourceForSubscriberBuilderPayload()
      • subscriberBuilderOfPayloads

        public org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<String,​Void> subscriberBuilderOfPayloads()
      • sourceForVoidPayload

        public org.reactivestreams.Publisher<Message<String>> sourceForVoidPayload()
      • consumePayload

        public void consumePayload​(String payload)
      • sourceForCsVoidMessage

        public org.reactivestreams.Publisher<Message<String>> sourceForCsVoidMessage()
      • sourceForCsVoidPayload

        public org.reactivestreams.Publisher<Message<String>> sourceForCsVoidPayload()
      • consumePayloadAndReturnCompletionStageOfVoid

        public CompletionStage<Void> consumePayloadAndReturnCompletionStageOfVoid​(String payload)