Package com.wowza.wms.pushpublish.protocol.rtmp

Class PushPublishRTMPNetConnectionPublisher

Object

com.wowza.wms.pushpublish.protocol.rtmp.PushPublishRTMPNetConnectionPublisher

All Implemented Interfaces:

INetConnectionPublisher

public class PushPublishRTMPNetConnectionPublisher
extends Object
implements INetConnectionPublisher

Field Summary

Fields

Modifier and Type	Field	Description
protected int	chunkSize
static final Class<PushPublishRTMPNetConnectionPublisher>	CLASS
static final String	CLASSNAME
protected boolean	isFirstAudioSend
protected boolean	isFirstVideoSend
long	lastOnGoLiveSend
protected long	lastSeq
protected PushPublishRTMPNetConnectionSession	pushPublisherSession
protected PushPublishRTMP	pushPublishRTMP
protected boolean	sendDataStart
protected long	timecodeOffset
protected int	totalPacketsZeroTimecode
protected boolean	waitForKeyFrame
protected byte[]	workBuffer

Constructor Summary

Constructors

Constructor	Description
PushPublishRTMPNetConnectionPublisher(PushPublishRTMP pushPublishRTMP, PushPublishRTMPNetConnectionSession pushPublisherSession)

Method Summary

Modifier and Type	Method	Description
protected void	checkWorkBuffer(int chunkSize)
ResponseFunction	getDataStart(IMediaStream stream, long timecode)
protected long	getPlayPacketDuration(List<AMFPacket> packets)
int	play(INetConnection netConnection, OutputStream out, long[] playSizes)
protected int	sendPacket(OutputStream out, long adjTimecode, AMFPacket packet, AMFObj amfObj, IMediaStream publishStream)
protected int	sendPackets(INetConnection netConnection, OutputStream out, IMediaStream publishStream, long[] playSizes)

Methods inherited from class java.lang.Object

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

Field Details

CLASS

public static final Class<PushPublishRTMPNetConnectionPublisher> CLASS

CLASSNAME

public static final String CLASSNAME

See Also:

• Constant Field Values

pushPublishRTMP

protected PushPublishRTMP pushPublishRTMP

pushPublisherSession

protected PushPublishRTMPNetConnectionSession pushPublisherSession

timecodeOffset

protected long timecodeOffset

waitForKeyFrame

protected boolean waitForKeyFrame

lastSeq

protected long lastSeq

isFirstVideoSend

protected boolean isFirstVideoSend

isFirstAudioSend

protected boolean isFirstAudioSend

workBuffer

protected byte[] workBuffer

chunkSize

protected int chunkSize

sendDataStart

protected boolean sendDataStart

totalPacketsZeroTimecode

protected int totalPacketsZeroTimecode

lastOnGoLiveSend

public long lastOnGoLiveSend

Constructor Details

PushPublishRTMPNetConnectionPublisher

public PushPublishRTMPNetConnectionPublisher(PushPublishRTMP pushPublishRTMP,
 PushPublishRTMPNetConnectionSession pushPublisherSession)

Method Details

checkWorkBuffer

protected void checkWorkBuffer(int chunkSize)

sendPacket

protected int sendPacket(OutputStream out,
 long adjTimecode,
 AMFPacket packet,
 AMFObj amfObj,
 IMediaStream publishStream)

getPlayPacketDuration

protected long getPlayPacketDuration(List<AMFPacket> packets)

sendPackets

protected int sendPackets(INetConnection netConnection,
 OutputStream out,
 IMediaStream publishStream,
 long[] playSizes)

getDataStart

public ResponseFunction getDataStart(IMediaStream stream,
 long timecode)

play

public int play(INetConnection netConnection,
 OutputStream out,
 long[] playSizes)

Specified by:

play in interface INetConnectionPublisher