Module io.helidon.microprofile.messaging.metrics

Package io.helidon.microprofile.messaging.metrics

Class MessagingCounter

java.lang.Object

io.helidon.microprofile.messaging.metrics.MessagingCounter

All Implemented Interfaces:

MessagingChannelProcessor

@ApplicationScoped
public class MessagingCounter
extends Object
implements MessagingChannelProcessor

Messaging counter for reactive messaging channels.

Field Summary

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

DEFAULT_PRIORITY

Method Summary

Modifier and Type	Method	Description
Message<?>	map(String channelName, Message<?> message)	Map messages going through the onNext signal in the messaging channel.

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, onCancel, onComplete, onError, onInit, onRequest, onSubscribe

Method Details

map

public Message<?> map(String channelName,
 Message<?> message)

Description copied from interface: MessagingChannelProcessor

Map messages going through the onNext signal in the messaging channel.

Specified by:

map in interface MessagingChannelProcessor

Parameters:

channelName - name of the messaging channel

message - message coming from the upstream

Returns:

mapped message to be delivered to the downstream