io.aeron.driver

Class SubscriberPosition

java.lang.Object

io.aeron.driver.SubscriberPosition

public final class SubscriberPosition
extends java.lang.Object

Consumption position a subscriber has got to within a SubscriptionLink.

Constructor Summary

Constructors

Constructor and Description
SubscriberPosition(SubscriptionLink subscriptionLink, Subscribable subscribable, org.agrona.concurrent.status.Position position)

Method Summary

Modifier and Type	Method and Description
void	addLink(PublicationImage image)
org.agrona.concurrent.status.Position	position()
int	positionCounterId()
Subscribable	subscribable()
SubscriptionLink	subscription()

Methods inherited from class java.lang.Object

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

Constructor Detail

SubscriberPosition

public SubscriberPosition(SubscriptionLink subscriptionLink,
                          Subscribable subscribable,
                          org.agrona.concurrent.status.Position position)

Method Detail

position

public org.agrona.concurrent.status.Position position()

positionCounterId

public int positionCounterId()

subscription

public SubscriptionLink subscription()

subscribable

public Subscribable subscribable()

addLink

public void addLink(PublicationImage image)