Package com.aitusoftware.aether.model

Class PublisherCounterSet

java.lang.Object

com.aitusoftware.aether.model.PublisherCounterSet

All Implemented Interfaces:

SessionKeyed

public final class PublisherCounterSet
extends java.lang.Object
implements SessionKeyed

Models counters associated with a publisher.

Constructor Summary

Constructors

Constructor	Description
PublisherCounterSet()

Method Summary

Modifier and Type	Method	Description
long	backPressureEvents()
void	backPressureEvents(long backPressureEvents)
long	buffered()
java.lang.CharSequence	channel()
PublisherCounterSet	copy()
long	publisherBufferRemaining()
long	publisherLimit()
void	publisherLimit(long publisherLimit)
long	publisherPosition()
void	publisherPosition(long publisherPosition)
void	reset(java.lang.CharSequence channel, int sessionId, int streamId)	Sets the relevant fields on this entity.
long	senderLimit()
void	senderLimit(long senderLimit)
long	senderPosition()
void	senderPosition(long senderPosition)
int	sessionId()
void	sessionId(int sessionId)
int	streamId()

Methods inherited from class java.lang.Object

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

Constructor Detail

PublisherCounterSet

public PublisherCounterSet()

Method Detail

reset

public void reset(java.lang.CharSequence channel,
                  int sessionId,
                  int streamId)

Sets the relevant fields on this entity.

Specified by:

reset in interface SessionKeyed

Parameters:

channel - the channel

sessionId - the sessionId

streamId - the streamId

publisherPosition

public void publisherPosition(long publisherPosition)

backPressureEvents

public void backPressureEvents(long backPressureEvents)

senderPosition

public void senderPosition(long senderPosition)

senderLimit

public void senderLimit(long senderLimit)

publisherLimit

public void publisherLimit(long publisherLimit)

sessionId

public void sessionId(int sessionId)

publisherPosition

public long publisherPosition()

backPressureEvents

public long backPressureEvents()

senderPosition

public long senderPosition()

senderLimit

public long senderLimit()

publisherLimit

public long publisherLimit()

sessionId

public int sessionId()

publisherBufferRemaining

public long publisherBufferRemaining()

buffered

public long buffered()

channel

public java.lang.CharSequence channel()

streamId

public int streamId()

copy

public PublisherCounterSet copy()