io.aeron.driver

Class SenderProxy

java.lang.Object

io.aeron.driver.SenderProxy

public class SenderProxy
extends java.lang.Object

Proxy for offering into the Sender Thread's command queue.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	addDestination(SendChannelEndpoint channelEndpoint, java.net.InetSocketAddress address)
void	closeSendChannelEndpoint(SendChannelEndpoint channelEndpoint)
void	newNetworkPublication(NetworkPublication publication)
void	registerSendChannelEndpoint(SendChannelEndpoint channelEndpoint)
void	removeDestination(SendChannelEndpoint channelEndpoint, java.net.InetSocketAddress address)
void	removeNetworkPublication(NetworkPublication publication)
void	sender(Sender sender)

Methods inherited from class java.lang.Object

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

Constructor Detail

SenderProxy

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

Method Detail

sender

public void sender(Sender sender)

registerSendChannelEndpoint

public void registerSendChannelEndpoint(SendChannelEndpoint channelEndpoint)

closeSendChannelEndpoint

public void closeSendChannelEndpoint(SendChannelEndpoint channelEndpoint)

removeNetworkPublication

public void removeNetworkPublication(NetworkPublication publication)

newNetworkPublication

public void newNetworkPublication(NetworkPublication publication)

addDestination

public void addDestination(SendChannelEndpoint channelEndpoint,
                           java.net.InetSocketAddress address)

removeDestination

public void removeDestination(SendChannelEndpoint channelEndpoint,
                              java.net.InetSocketAddress address)