Package org.red5.server.stream.consumer

Class ConnectionConsumer

java.lang.Object

org.red5.server.stream.consumer.ConnectionConsumer

All Implemented Interfaces:

IConsumer, IMessageComponent, IPipeConnectionListener, IPushableConsumer

public class ConnectionConsumer
extends Object
implements IPushableConsumer, IPipeConnectionListener

RTMP connection consumer.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	KEY	Connection consumer class name

Constructor Summary

Constructors

Constructor	Description
ConnectionConsumer(Channel videoChannel, Channel audioChannel, Channel dataChannel)	Create connection consumer without an RTMP connection.
ConnectionConsumer(RTMPConnection conn, Channel videoChannel, Channel audioChannel, Channel dataChannel)	Create RTMP connection consumer for given connection and channels.

Method Summary

Modifier and Type	Method	Description
void	onOOBControlMessage(IMessageComponent source, IPipe pipe, OOBControlMessage oobCtrlMsg)
void	onPipeConnectionEvent(PipeConnectionEvent event)	Pipe connection event handler
void	pushMessage(IPipe pipe, IMessage message)	Pushes message through pipe

Methods inherited from class java.lang.Object

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

Field Details

KEY

public static final String KEY

Connection consumer class name

Constructor Details

ConnectionConsumer

public ConnectionConsumer(RTMPConnection conn,
 Channel videoChannel,
 Channel audioChannel,
 Channel dataChannel)

Create RTMP connection consumer for given connection and channels.

Parameters:

conn - RTMP connection

videoChannel - Video channel

audioChannel - Audio channel

dataChannel - Data channel

ConnectionConsumer

public ConnectionConsumer(Channel videoChannel,
 Channel audioChannel,
 Channel dataChannel)

Create connection consumer without an RTMP connection.

Parameters:

videoChannel - video channel

audioChannel - audio channel

dataChannel - data channel

Method Details

pushMessage

public void pushMessage(IPipe pipe,
 IMessage message)

Pushes message through pipe

Specified by:

pushMessage in interface IPushableConsumer

Parameters:

pipe - Pipe

message - Message

onPipeConnectionEvent

public void onPipeConnectionEvent(PipeConnectionEvent event)

Pipe connection event handler

Specified by:

onPipeConnectionEvent in interface IPipeConnectionListener

Parameters:

event - Pipe connection event

onOOBControlMessage

public void onOOBControlMessage(IMessageComponent source,
 IPipe pipe,
 OOBControlMessage oobCtrlMsg)

Specified by:

onOOBControlMessage in interface IMessageComponent

Parameters:

source - Message component source

pipe - Connection pipe

oobCtrlMsg - Out-of-band control message