CounterSnapshotSubscriber (aether 0.2.2 API)

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

All Methods Instance Methods Concrete Methods
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