Module io.helidon.microprofile.messaging.health

Package io.helidon.microprofile.messaging.health

Class MessagingLivenessCheck

java.lang.Object

io.helidon.microprofile.messaging.health.MessagingLivenessCheck

All Implemented Interfaces:

MessagingChannelProcessor, HealthCheck

@Liveness
@ApplicationScoped
@BuiltInHealthCheck
public class MessagingLivenessCheck
extends Object
implements HealthCheck, MessagingChannelProcessor

MicroProfile Reactive Messaging liveness check. If any of the channels go down, messaging is considered to be down.

Field Summary

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

DEFAULT_PRIORITY

Constructor Summary

Constructors

Constructor	Description
MessagingLivenessCheck()

Method Summary

Modifier and Type	Method	Description
HealthCheckResponse	call()
void	onCancel(String channelName)	Listener for the cancel coming from the downstream.
void	onComplete(String channelName)	Listener for the onComplete signal coming from the upstream.
void	onError(String channelName, Throwable t)	Listener for the onError event coming from the upstream.
void	onInit(String channelName)	Listener for the initial event before actual subscribing.

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, onRequest, onSubscribe

Constructor Details

MessagingLivenessCheck

public MessagingLivenessCheck()

Method Details

call

public HealthCheckResponse call()

Specified by:

call in interface HealthCheck

onError

public void onError(String channelName,
 Throwable t)

Description copied from interface: MessagingChannelProcessor

Listener for the onError event coming from the upstream.

Specified by:

onError in interface MessagingChannelProcessor

Parameters:

channelName - name of the messaging channel

t - error causing the onError signal

onCancel

public void onCancel(String channelName)

Description copied from interface: MessagingChannelProcessor

Listener for the cancel coming from the downstream.

Specified by:

onCancel in interface MessagingChannelProcessor

Parameters:

channelName - name of the messaging channel

onComplete

public void onComplete(String channelName)

Description copied from interface: MessagingChannelProcessor

Listener for the onComplete signal coming from the upstream.

Specified by:

onComplete in interface MessagingChannelProcessor

Parameters:

channelName - name of the messaging channel

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