io.aeron.driver

Interface Subscribable

All Known Implementing Classes:

IpcPublication, NetworkPublication, PublicationImage

public interface Subscribable

Stream source that can be observed by subscribers which identify themselves the position they have read up to.

Method Summary

Modifier and Type	Method and Description
void	addSubscriber(org.agrona.concurrent.status.ReadablePosition subscriberPosition) Add a subscriber identified by its position.
void	removeSubscriber(org.agrona.concurrent.status.ReadablePosition subscriberPosition) Remove a subscriber identified by its position.

Method Detail

addSubscriber

void addSubscriber(org.agrona.concurrent.status.ReadablePosition subscriberPosition)

Add a subscriber identified by its position.

Parameters:

subscriberPosition - for tracking and identifying the subscriber.

removeSubscriber

void removeSubscriber(org.agrona.concurrent.status.ReadablePosition subscriberPosition)

Remove a subscriber identified by its position.

Note: The Subscribable is responsible for calling ReadablePosition.close() on removed positions.

Parameters:

subscriberPosition - to be identified by.