Package com.aitusoftware.aether.transport

Class CounterSnapshotSubscriber

java.lang.Object

com.aitusoftware.aether.transport.CounterSnapshotSubscriber

All Implemented Interfaces:

io.aeron.logbuffer.FragmentHandler, java.lang.AutoCloseable

public final class CounterSnapshotSubscriber
extends java.lang.Object
implements io.aeron.logbuffer.FragmentHandler, java.lang.AutoCloseable

A listener to data published by a CounterSnapshotPublisher.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CounterSnapshotSubscriber.Context	Configuration context.

Constructor Summary

Constructors

Constructor	Description
CounterSnapshotSubscriber()	Creates a new subscriber using runtime configuration.
CounterSnapshotSubscriber(CounterSnapshotSubscriber.Context context)	Creates a new subscriber from the supplied context.

Method Summary

Modifier and Type	Method	Description
void	close()
int	doWork()	Poll the Aeron Subscription.
void	onFragment(org.agrona.DirectBuffer buffer, int offset, int length, io.aeron.logbuffer.Header header)

Methods inherited from class java.lang.Object

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

Constructor Detail

CounterSnapshotSubscriber

public CounterSnapshotSubscriber()

Creates a new subscriber using runtime configuration.

CounterSnapshotSubscriber

public CounterSnapshotSubscriber(CounterSnapshotSubscriber.Context context)

Creates a new subscriber from the supplied context.

Parameters:

context - configuration context

Method Detail

close

public void close()
           throws java.lang.Exception

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.lang.Exception

onFragment

public void onFragment(org.agrona.DirectBuffer buffer,
                       int offset,
                       int length,
                       io.aeron.logbuffer.Header header)

Specified by:

onFragment in interface io.aeron.logbuffer.FragmentHandler

doWork

public int doWork()

Poll the Aeron Subscription.

Returns:

number of fragments processed