io.aeron.driver

Class DriverConductorProxy

java.lang.Object

io.aeron.driver.DriverConductorProxy

public class DriverConductorProxy
extends java.lang.Object

Proxy for sending commands to the DriverConductor.

Constructor Summary

Constructors

Constructor and Description
DriverConductorProxy(ThreadingMode threadingMode, java.util.Queue<java.lang.Runnable> commandQueue, org.agrona.concurrent.status.AtomicCounter failCount)

Method Summary

Modifier and Type	Method and Description
void	channelEndpointError(long statusIndicatorId, java.lang.Exception error)
void	createPublicationImage(int sessionId, int streamId, int initialTermId, int activeTermId, int termOffset, int termLength, int mtuLength, int transportIndex, java.net.InetSocketAddress controlAddress, java.net.InetSocketAddress srcAddress, ReceiveChannelEndpoint channelEndpoint)
void	driverConductor(DriverConductor driverConductor)
boolean	notConcurrent()

Methods inherited from class java.lang.Object

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

Constructor Detail

DriverConductorProxy

public DriverConductorProxy(ThreadingMode threadingMode,
                            java.util.Queue<java.lang.Runnable> commandQueue,
                            org.agrona.concurrent.status.AtomicCounter failCount)

Method Detail

driverConductor

public void driverConductor(DriverConductor driverConductor)

createPublicationImage

public void createPublicationImage(int sessionId,
                                   int streamId,
                                   int initialTermId,
                                   int activeTermId,
                                   int termOffset,
                                   int termLength,
                                   int mtuLength,
                                   int transportIndex,
                                   java.net.InetSocketAddress controlAddress,
                                   java.net.InetSocketAddress srcAddress,
                                   ReceiveChannelEndpoint channelEndpoint)

channelEndpointError

public void channelEndpointError(long statusIndicatorId,
                                 java.lang.Exception error)

notConcurrent

public boolean notConcurrent()