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
private Channel	audio	Audio channel
private int	chunkSize	Chunk size.
private AtomicBoolean	chunkSizeSent	Whether or not the chunk size has been sent.
private RTMPConnection	conn	Connection object
private Channel	data	Data channel
static final String	KEY	Connection consumer class name
private static final org.slf4j.Logger	log
private Channel	video	Video channel

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
private void	closeChannels()	Close all the channels
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
private void	sendChunkSize()	Send the chunk size

Methods inherited from class java.lang.Object

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

Field Details

log

private static final org.slf4j.Logger log

KEY

public static final String KEY

Connection consumer class name

conn

private RTMPConnection conn

Connection object

video

private Channel video

Video channel

audio

private Channel audio

Audio channel

data

private Channel data

Data channel

chunkSize

private int chunkSize

Chunk size. Packets are sent chunk-by-chunk.

chunkSizeSent

private AtomicBoolean chunkSizeSent

Whether or not the chunk size has been sent. This seems to be required for h264.

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

sendChunkSize

private void sendChunkSize()

Send the chunk size

closeChannels

private void closeChannels()

Close all the channels