io.aeron.driver

Class Receiver

java.lang.Object

io.aeron.driver.Receiver

All Implemented Interfaces:

org.agrona.concurrent.Agent

public class Receiver
extends java.lang.Object
implements org.agrona.concurrent.Agent

Receiver agent for JVM based media driver, uses an event loop with command buffer

Constructor Summary

Constructors

Constructor and Description
Receiver(MediaDriver.Context ctx)

Method Summary

Modifier and Type	Method and Description
void	addPendingSetupMessage(int sessionId, int streamId, int transportIndex, ReceiveChannelEndpoint channelEndpoint, boolean periodic, java.net.InetSocketAddress controlAddress)
int	doWork()
void	onAddDestination(ReceiveChannelEndpoint channelEndpoint, ReceiveDestinationUdpTransport transport)
void	onAddSubscription(ReceiveChannelEndpoint channelEndpoint, int streamId)
void	onAddSubscription(ReceiveChannelEndpoint channelEndpoint, int streamId, int sessionId)
void	onClose()
void	onCloseReceiveChannelEndpoint(ReceiveChannelEndpoint channelEndpoint)
void	onNewPublicationImage(ReceiveChannelEndpoint channelEndpoint, PublicationImage image)
void	onRegisterReceiveChannelEndpoint(ReceiveChannelEndpoint channelEndpoint)
void	onRemoveCoolDown(ReceiveChannelEndpoint channelEndpoint, int sessionId, int streamId)
void	onRemoveDestination(ReceiveChannelEndpoint channelEndpoint, UdpChannel udpChannel)
void	onRemoveSubscription(ReceiveChannelEndpoint channelEndpoint, int streamId)
void	onRemoveSubscription(ReceiveChannelEndpoint channelEndpoint, int streamId, int sessionId)
java.lang.String	roleName()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.agrona.concurrent.Agent

onStart

Constructor Detail

Receiver

public Receiver(MediaDriver.Context ctx)

Method Detail

onClose

public void onClose()

Specified by:

onClose in interface org.agrona.concurrent.Agent

roleName

public java.lang.String roleName()

Specified by:

roleName in interface org.agrona.concurrent.Agent

doWork

public int doWork()

Specified by:

doWork in interface org.agrona.concurrent.Agent

addPendingSetupMessage

public void addPendingSetupMessage(int sessionId,
                                   int streamId,
                                   int transportIndex,
                                   ReceiveChannelEndpoint channelEndpoint,
                                   boolean periodic,
                                   java.net.InetSocketAddress controlAddress)

onAddSubscription

public void onAddSubscription(ReceiveChannelEndpoint channelEndpoint,
                              int streamId)

onAddSubscription

public void onAddSubscription(ReceiveChannelEndpoint channelEndpoint,
                              int streamId,
                              int sessionId)

onRemoveSubscription

public void onRemoveSubscription(ReceiveChannelEndpoint channelEndpoint,
                                 int streamId)

onRemoveSubscription

public void onRemoveSubscription(ReceiveChannelEndpoint channelEndpoint,
                                 int streamId,
                                 int sessionId)

onNewPublicationImage

public void onNewPublicationImage(ReceiveChannelEndpoint channelEndpoint,
                                  PublicationImage image)

onRegisterReceiveChannelEndpoint

public void onRegisterReceiveChannelEndpoint(ReceiveChannelEndpoint channelEndpoint)

onCloseReceiveChannelEndpoint

public void onCloseReceiveChannelEndpoint(ReceiveChannelEndpoint channelEndpoint)

onRemoveCoolDown

public void onRemoveCoolDown(ReceiveChannelEndpoint channelEndpoint,
                             int sessionId,
                             int streamId)

onAddDestination

public void onAddDestination(ReceiveChannelEndpoint channelEndpoint,
                             ReceiveDestinationUdpTransport transport)

onRemoveDestination

public void onRemoveDestination(ReceiveChannelEndpoint channelEndpoint,
                                UdpChannel udpChannel)