Package com.aitusoftware.aether.event

Class CounterEventHandler

java.lang.Object

com.aitusoftware.aether.event.CounterEventHandler

All Implemented Interfaces:

CounterValueListener

public final class CounterEventHandler
extends java.lang.Object
implements CounterValueListener

Constructor Summary

Constructors

Constructor	Description
CounterEventHandler(CounterRepository<PublisherCounterSet> publisherCounterRepository, CounterRepository<SubscriberCounterSet> subscriberCounterRepository, CounterSnapshotListener counterSnapshotListener, org.agrona.concurrent.EpochClock epochClock)

Method Summary

Modifier and Type	Method	Description
void	onCounterEvent(int counterId, int counterTypeId, java.lang.CharSequence channel, int sessionId, int streamId, long registrationId, long value)
void	onEndOfBatch(java.lang.String label)

Methods inherited from class java.lang.Object

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

Constructor Detail

CounterEventHandler

public CounterEventHandler(CounterRepository<PublisherCounterSet> publisherCounterRepository,
                           CounterRepository<SubscriberCounterSet> subscriberCounterRepository,
                           CounterSnapshotListener counterSnapshotListener,
                           org.agrona.concurrent.EpochClock epochClock)

Method Detail

onCounterEvent

public void onCounterEvent(int counterId,
                           int counterTypeId,
                           java.lang.CharSequence channel,
                           int sessionId,
                           int streamId,
                           long registrationId,
                           long value)

Specified by:

onCounterEvent in interface CounterValueListener

onEndOfBatch

public void onEndOfBatch(java.lang.String label)

Specified by:

onEndOfBatch in interface CounterValueListener