Module io.helidon.microprofile.messaging.health

Package io.helidon.microprofile.messaging.health

Class MessagingReadinessCheck

java.lang.Object

io.helidon.microprofile.messaging.health.MessagingReadinessCheck

All Implemented Interfaces:

MessagingChannelProcessor, HealthCheck

@Readiness
@ApplicationScoped
@BuiltInHealthCheck
public class MessagingReadinessCheck
extends Object
implements HealthCheck, MessagingChannelProcessor

MicroProfile Reactive Messaging readiness check. Until all channels is up, messaging is considered to be down.

Field Summary

Fields inherited from interface io.helidon.microprofile.messaging.MessagingChannelProcessor

DEFAULT_PRIORITY

Constructor Summary

Constructors

Constructor	Description
MessagingReadinessCheck()

Method Summary

Modifier and Type	Method	Description
HealthCheckResponse	call()
void	onInit(String channelName)	Listener for the initial event before actual subscribing.
void	onSubscribe(String channelName, Subscriber<Message<?>> subscriber, Subscription subscription)	Listener for the onSubscribe signal coming from the upstream.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.helidon.microprofile.messaging.MessagingChannelProcessor

channelName, map, onCancel, onComplete, onError, onRequest

Constructor Details

MessagingReadinessCheck

public MessagingReadinessCheck()

Method Details

call

public HealthCheckResponse call()

Specified by:

call in interface HealthCheck

onSubscribe

public void onSubscribe(String channelName,
 Subscriber<Message<?>> subscriber,
 Subscription subscription)

Description copied from interface: MessagingChannelProcessor

Listener for the onSubscribe signal coming from the upstream.

Specified by:

onSubscribe in interface MessagingChannelProcessor

Parameters:

channelName - name of the messaging channel

subscriber - subscriber causing this onSubscribe signal

subscription - assigned subscription

onInit

public void onInit(String channelName)

Description copied from interface: MessagingChannelProcessor

Listener for the initial event before actual subscribing.

Specified by:

onInit in interface MessagingChannelProcessor

Parameters:

channelName - name of the messaging channel