Class SubscriberBean
- java.lang.Object
-
- org.eclipse.microprofile.reactive.messaging.tck.signatures.subscribers.SubscriberBean
-
@ApplicationScoped public class SubscriberBean extends Object
-
-
Constructor Summary
Constructors Constructor Description SubscriberBean()
-
Method Summary
-
-
-
Method Detail
-
sourceForSubscriberMessage
public org.reactivestreams.Publisher<Message<String>> sourceForSubscriberMessage()
-
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()
-
consumePayload
public void consumePayload(String payload)
-
sourceForCsVoidMessage
public org.reactivestreams.Publisher<Message<String>> sourceForCsVoidMessage()
-
consumeMessageAndReturnCompletionStageOfVoid
public CompletionStage<Void> consumeMessageAndReturnCompletionStageOfVoid(Message<String> message)
-
sourceForCsVoidPayload
public org.reactivestreams.Publisher<Message<String>> sourceForCsVoidPayload()
-
consumePayloadAndReturnCompletionStageOfVoid
public CompletionStage<Void> consumePayloadAndReturnCompletionStageOfVoid(String payload)
-
-