@ApplicationScoped public class SubscriberBean extends Object
Constructor and Description |
---|
SubscriberBean() |
public org.reactivestreams.Publisher<Message<String>> sourceForSubscriberMessage()
public org.reactivestreams.Publisher<Message<String>> sourceForSubscriberBuilderMessage()
public org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<Message<String>,Void> subscriberBuilderOfMessages()
public org.reactivestreams.Publisher<Message<String>> sourceForSubscribePayload()
public org.reactivestreams.Subscriber<String> subscriberOfPayloads()
public org.reactivestreams.Publisher<Message<String>> sourceForSubscriberBuilderPayload()
public org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<String,Void> subscriberBuilderOfPayloads()
public void consumePayload(String payload)
public org.reactivestreams.Publisher<Message<String>> sourceForCsVoidMessage()
public CompletionStage<Void> consumeMessageAndReturnCompletionStageOfVoid(Message<String> message)
public org.reactivestreams.Publisher<Message<String>> sourceForCsVoidPayload()
public CompletionStage<Void> consumePayloadAndReturnCompletionStageOfVoid(String payload)
Copyright © 2018–2021 Eclipse Foundation. All rights reserved.