Module io.helidon.microprofile.messaging

Package io.helidon.microprofile.messaging

Class MessagingCdiExtension

java.lang.Object

io.helidon.microprofile.messaging.MessagingCdiExtension

All Implemented Interfaces:

Extension

public class MessagingCdiExtension
extends Object
implements Extension

MicroProfile Reactive Messaging CDI Extension.

Constructor Summary

Constructors

Constructor	Description
MessagingCdiExtension()	Initialize messaging CDI extension.

Method Summary

Modifier and Type	Method	Description
Map<String,Boolean>	channelsLiveness()	Deprecated, for removal: This API element is subject to removal in a future version. Implement MessagingChannelProcessor as a bean instead, which can peak to any messaging channel.
Map<String,Boolean>	channelsReadiness()	Deprecated, for removal: This API element is subject to removal in a future version. Implement MessagingChannelProcessor as a bean instead, which can peak to any messaging channel.

Methods inherited from class java.lang.Object

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

Constructor Details

MessagingCdiExtension

public MessagingCdiExtension()

Initialize messaging CDI extension.

Method Details

channelsLiveness

@Deprecated(since="3.0.0",
            forRemoval=true)
public Map<String,Boolean> channelsLiveness()

Deprecated, for removal: This API element is subject to removal in a future version.

Implement MessagingChannelProcessor as a bean instead, which can peak to any messaging channel.

Get names of all channels accompanied by boolean if cancel or onError signal has been intercepted in it.

Returns:

map of channels

channelsReadiness

@Deprecated(since="3.0.0",
            forRemoval=true)
public Map<String,Boolean> channelsReadiness()

Deprecated, for removal: This API element is subject to removal in a future version.

Implement MessagingChannelProcessor as a bean instead, which can peak to any messaging channel.

Get names of all channels accompanied by boolean if onSubscribe signal has been intercepted in it.

Returns:

map of channels