io.aeron.driver

Class ClientProxy

java.lang.Object

io.aeron.driver.ClientProxy

public class ClientProxy
extends java.lang.Object

Proxy for communicating from the driver to the client conductor.

Constructor Summary

Constructors

Constructor and Description
ClientProxy(org.agrona.concurrent.broadcast.BroadcastTransmitter transmitter)

Method Summary

Modifier and Type	Method and Description
void	onAvailableImage(long correlationId, int streamId, int sessionId, long subscriptionRegistrationId, int positionCounterId, java.lang.String logFileName, java.lang.String sourceIdentity)
void	onClientTimeout(long clientId)
void	onCounterReady(long correlationId, int counterId)
void	onError(long correlationId, ErrorCode errorCode, java.lang.String errorMessage)
void	onPublicationReady(long correlationId, long registrationId, int streamId, int sessionId, java.lang.String logFileName, int positionCounterId, int channelStatusCounterId, boolean isExclusive)
void	onSubscriptionReady(long correlationId, int channelStatusCounterId)
void	onUnavailableCounter(long registrationId, int counterId)
void	onUnavailableImage(long correlationId, long subscriptionRegistrationId, int streamId, java.lang.String channel)
void	operationSucceeded(long correlationId)

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientProxy

public ClientProxy(org.agrona.concurrent.broadcast.BroadcastTransmitter transmitter)

Method Detail

onError

public void onError(long correlationId,
                    ErrorCode errorCode,
                    java.lang.String errorMessage)

onAvailableImage

public void onAvailableImage(long correlationId,
                             int streamId,
                             int sessionId,
                             long subscriptionRegistrationId,
                             int positionCounterId,
                             java.lang.String logFileName,
                             java.lang.String sourceIdentity)

onPublicationReady

public void onPublicationReady(long correlationId,
                               long registrationId,
                               int streamId,
                               int sessionId,
                               java.lang.String logFileName,
                               int positionCounterId,
                               int channelStatusCounterId,
                               boolean isExclusive)

onSubscriptionReady

public void onSubscriptionReady(long correlationId,
                                int channelStatusCounterId)

operationSucceeded

public void operationSucceeded(long correlationId)

onUnavailableImage

public void onUnavailableImage(long correlationId,
                               long subscriptionRegistrationId,
                               int streamId,
                               java.lang.String channel)

onCounterReady

public void onCounterReady(long correlationId,
                           int counterId)

onUnavailableCounter

public void onUnavailableCounter(long registrationId,
                                 int counterId)

onClientTimeout

public void onClientTimeout(long clientId)