public class ReceiverProxy
extends java.lang.Object
Receiver
Thread's command queue.Constructor and Description |
---|
ReceiverProxy(ThreadingMode threadingMode,
java.util.Queue<java.lang.Runnable> commandQueue,
org.agrona.concurrent.status.AtomicCounter failCount) |
Modifier and Type | Method and Description |
---|---|
void |
addDestination(ReceiveChannelEndpoint channelEndpoint,
ReceiveDestinationUdpTransport transport) |
void |
addSubscription(ReceiveChannelEndpoint mediaEndpoint,
int streamId) |
void |
addSubscription(ReceiveChannelEndpoint mediaEndpoint,
int streamId,
int sessionId) |
void |
closeReceiveChannelEndpoint(ReceiveChannelEndpoint channelEndpoint) |
void |
newPublicationImage(ReceiveChannelEndpoint channelEndpoint,
PublicationImage image) |
Receiver |
receiver() |
void |
receiver(Receiver receiver) |
void |
registerReceiveChannelEndpoint(ReceiveChannelEndpoint channelEndpoint) |
void |
removeCoolDown(ReceiveChannelEndpoint channelEndpoint,
int sessionId,
int streamId) |
void |
removeDestination(ReceiveChannelEndpoint channelEndpoint,
UdpChannel udpChannel) |
void |
removeSubscription(ReceiveChannelEndpoint mediaEndpoint,
int streamId) |
void |
removeSubscription(ReceiveChannelEndpoint mediaEndpoint,
int streamId,
int sessionId) |
public ReceiverProxy(ThreadingMode threadingMode, java.util.Queue<java.lang.Runnable> commandQueue, org.agrona.concurrent.status.AtomicCounter failCount)
public void receiver(Receiver receiver)
public Receiver receiver()
public void addSubscription(ReceiveChannelEndpoint mediaEndpoint, int streamId)
public void addSubscription(ReceiveChannelEndpoint mediaEndpoint, int streamId, int sessionId)
public void removeSubscription(ReceiveChannelEndpoint mediaEndpoint, int streamId)
public void removeSubscription(ReceiveChannelEndpoint mediaEndpoint, int streamId, int sessionId)
public void newPublicationImage(ReceiveChannelEndpoint channelEndpoint, PublicationImage image)
public void registerReceiveChannelEndpoint(ReceiveChannelEndpoint channelEndpoint)
public void closeReceiveChannelEndpoint(ReceiveChannelEndpoint channelEndpoint)
public void removeCoolDown(ReceiveChannelEndpoint channelEndpoint, int sessionId, int streamId)
public void addDestination(ReceiveChannelEndpoint channelEndpoint, ReceiveDestinationUdpTransport transport)
public void removeDestination(ReceiveChannelEndpoint channelEndpoint, UdpChannel udpChannel)
Copyright © 2014-2018 Real Logic Ltd. All Rights Reserved.