Package com.wowza.wms.pushpublish.protocol.rtp

Class PushPublishRTP

Object

com.wowza.wms.pushpublish.model.PushPublishBase

com.wowza.wms.pushpublish.protocol.rtp.PushPublishRTP

All Implemented Interfaces:

IPushPublish

public class PushPublishRTP
extends PushPublishBase

The Class PushPublishRTP.

Field Summary

Fields

Modifier and Type	Field	Description
protected String	audioHost	The audio host.
protected int	audioPort	The audio port.
static Class<PushPublishRTP>	CLASS
static String	CLASSNAME
protected boolean	isRTPWrapped	The is rtp wrapped.
protected Object	lock
protected RTPDestination	mRtpDestination	The m rtp destination.
protected String	multicastInterfaceAddress
protected boolean	removeSDPFiles	The remove sdp files
protected RTPPushPublishSession	rtpPushPublishSession	The rtp push publish session.
static String	SDPFILEEXTENSION	The Constant SDPFILEEXTENSION.
protected boolean	singleStreamAV	The stream packetizer.
protected String	videoHost	The video host.
protected int	videoPort	The video port.
protected boolean	writeSDPFiles	The write sdp files.

Fields inherited from class com.wowza.wms.pushpublish.model.PushPublishBase

appInstance, className, DESTINATION_BAK, DESTINATION_PRI, DESTINATION_RED, destinationName, destinationServer, dstStreamName, entryName, hostname, inetAddr, isAdaptiveStreaming, isExternalRedundancy, logger, mImplementation, myMap, password, playbackHostname, port, profile, properties, pushPublishSession, pushPublishStreamDebug, pushPublishType, reconnectWaitTime, sendingPerformance, srcStream, srcStreamName, totalIOPerformance2Last, totalIOPerformanceLast, userName

Fields inherited from interface com.wowza.wms.pushpublish.model.IPushPublish

CONNECTED_STATE_CONNECTED, CONNECTED_STATE_CONNECTING, CONNECTED_STATE_NOT_CONNECTED, CONNECTED_STATE_WAITING, PUSHPUBLISH_TYPE_CUPERTINO, PUSHPUBLISH_TYPE_MPEGDASH, PUSHPUBLISH_TYPE_NOTIFY_PACKET, PUSHPUBLISH_TYPE_RTMP, PUSHPUBLISH_TYPE_RTP, PUSHPUBLISH_TYPE_RTP_BUFFERED, PUSHPUBLISH_TYPE_SANJOSE, PUSHPUBLISH_TYPE_SRT, PUSHPUBLISH_TYPE_UNKNOWN

Constructor Summary

Constructors

Constructor	Description
PushPublishRTP()

Method Summary

Modifier and Type	Method	Description
void	add(IOPerformanceCounter totalValue)
void	addIOPerformance2(IOPerformanceCounter totalIOPerformanceResult)
void	connect()
IPushPublishSession	createPushPublishSession()
void	disconnect()
void	disconnect(boolean hard)
IApplicationInstance	getAppInstance()	Get appInstance interface.
String	getAudioHost()	Gets the audio host.
int	getAudioPort()	Gets the audio port.
int	getConnectedState()
String	getContextStr()
String	getHostname()	Get destination server host name.
String	getHostType()	Gets the host type.
long	getMessagesAttemptedCount()
long	getMessagesFailedCount()
long	getMessagesRetriedCount()
RTPDestination	getmRtpDestination()
String	getMulticastInterfaceAddress()
RTPPushPublishSession	getRTPPushPublishSession()	Gets the rTP push publish session.
long	getRtpStreamWaitTimeout()
int	getTimeToLive()	Gets the time to live.
String	getVideoHost()	Gets the video host.
int	getVideoPort()	Gets the video port.
void	init(IApplicationInstance appInstance, String streamName, IMediaStream stream, java.util.Map<String,String> profileData, java.util.Map<String,String> maps, com.wowza.wms.pushpublish.manager.IPushPublisher pushPublisher, boolean debug)	Inits the instance.
boolean	isRemoveSDPFiles()
boolean	isRTPWrapped()	Checks if is rTP wrapped.
boolean	isSingleStreamAV()	Checks if is stream is packatized.
boolean	isWriteSDPFiles()
void	load(java.util.HashMap<String,String> dataMap)	Loads map and profile parameters
void	resetConnection()
void	resetConnection(int delay)
void	setAppInstance(IApplicationInstance appInstance)	Set appInstance interface.
void	setAudioHost(String audioHost)	Sets the audio host.
void	setAudioPort(int audioPort)	Sets the audio port.
void	setAudioPort(String audioPort)	Sets the audio port.
void	setConnectionStatus(Boolean connected)
void	setHostname(String hostname)
void	setHostType(String hostType)	Sets the host type.
void	setMulticastInterfaceAddress(String multicastInterfaceAddress)
void	setPort(int port)	Set destination server port.
void	setPort(String portIn)	Set destination server port.
void	setRemoveSDPFiles(boolean removeSDPFiles)
void	setRTPPushPublishSession(RTPPushPublishSession rtpPushPublishSession)	Sets the rTP push publish session.
void	setRtpStreamWaitTimeout(long rtpStreamWaitTimeout)
void	setRtpStreamWaitTimeout(String rtpStreamWaitTimeout)
void	setRTPWrapped(boolean isRTPWrapped)
void	setRTPWrapped(String string)	Sets the rTP wrapped.
void	setSingleStreamAV(boolean inSingleStreamAV)	Sets the stream packetizer.
void	setSingleStreamAV(String inSingleStreamAV)
void	setTimeToLive(String ttl)	Sets the time to live.
void	setVideoHost(String videoHost)	Sets the video host.
void	setVideoPort(int videoPort)
void	setVideoPort(String videoPort)	Sets the video port.
void	setWriteSDPFiles(boolean writeSDPFiles)

Methods inherited from class com.wowza.wms.pushpublish.model.PushPublishBase

clearLoggingValues, getBandwidth, getBaseParams, getDestinationID, getDestinationName, getDestinationServer, getDstStreamName, getEntryName, getImplementation, getInetAddr, getMap, getMessagesOutBytes, getMessagesOutCount, getPassword, getPlaybackHostname, getPort, getProfile, getProperties, getPushPublishType, getReconnectWaitTime, getSrcStream, getSrcStreamName, getUserName, getWowzaStreamingEngineVersionStr, incrementMessagesOut, isAdaptiveStreaming, isDebugLog, isExternalRedundancy, logDebug, logError, logError, logError, logInfo, logWarn, resolveHostName, setAdaptiveStreaming, setAdaptiveStreaming, setDebugLog, setDestinationName, setDestinationServer, setDestinationServer, setDstStreamName, setEntryName, setExternalRedundancy, setExternalRedundancy, setHost, setImplementation, setInetAddr, setPassword, setPlaybackHostname, setProfile, setReconnectWaitTime, setSrcStream, setSrcStreamName, setStreamName, setUserName, updateLoggingValues, updateUsageTracker

Methods inherited from class java.lang.Object

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

Field Detail

CLASS

public static final Class<PushPublishRTP> CLASS

CLASSNAME

public static final String CLASSNAME

See Also:

Constant Field Values

SDPFILEEXTENSION

public static final String SDPFILEEXTENSION

The Constant SDPFILEEXTENSION.

See Also:

Constant Field Values

rtpPushPublishSession

protected RTPPushPublishSession rtpPushPublishSession

The rtp push publish session.

singleStreamAV

protected boolean singleStreamAV

The stream packetizer.

audioPort

protected int audioPort

The audio port.

videoPort

protected int videoPort

The video port.

audioHost

protected String audioHost

The audio host.

videoHost

protected String videoHost

The video host.

isRTPWrapped

protected boolean isRTPWrapped

The is rtp wrapped.

writeSDPFiles

protected boolean writeSDPFiles

The write sdp files.

removeSDPFiles

protected boolean removeSDPFiles

The remove sdp files

multicastInterfaceAddress

protected String multicastInterfaceAddress

mRtpDestination

protected RTPDestination mRtpDestination

The m rtp destination.

lock

protected Object lock

Constructor Detail

PushPublishRTP

public PushPublishRTP()
               throws com.wowza.wms.server.LicensingException

Throws:

com.wowza.wms.server.LicensingException

Method Detail

init

public void init(IApplicationInstance appInstance,
                 String streamName,
                 IMediaStream stream,
                 java.util.Map<String,String> profileData,
                 java.util.Map<String,String> maps,
                 com.wowza.wms.pushpublish.manager.IPushPublisher pushPublisher,
                 boolean debug)

Description copied from class: PushPublishBase

Inits the instance.

Specified by:

init in interface IPushPublish

Overrides:

init in class PushPublishBase

Parameters:

appInstance - the app instance

streamName - the source stream name

profileData - the profile params

maps - the map entry params

debug - stream debug flag

connect

public void connect()

disconnect

public void disconnect()

disconnect

public void disconnect(boolean hard)

resetConnection

public void resetConnection()

resetConnection

public void resetConnection(int delay)

getRTPPushPublishSession

public RTPPushPublishSession getRTPPushPublishSession()

Gets the rTP push publish session.

Returns:

the rTP push publish session

setRTPPushPublishSession

public void setRTPPushPublishSession(RTPPushPublishSession rtpPushPublishSession)

Sets the rTP push publish session.

Parameters:

rtpPushPublishSession - the new rTP push publish session

getAppInstance

public IApplicationInstance getAppInstance()

Description copied from class: PushPublishBase

Get appInstance interface.

Overrides:

getAppInstance in class PushPublishBase

Returns:

appInstance interface

setAppInstance

public void setAppInstance(IApplicationInstance appInstance)

Description copied from class: PushPublishBase

Set appInstance interface.

Overrides:

setAppInstance in class PushPublishBase

Parameters:

appInstance - appInstance interface

isSingleStreamAV

public boolean isSingleStreamAV()

Checks if is stream is packatized.

Returns:

true, if is stream packetizer

setSingleStreamAV

public void setSingleStreamAV(boolean inSingleStreamAV)

Sets the stream packetizer.

Parameters:

inSingleStreamAV - whether stream is packatized

setSingleStreamAV

public void setSingleStreamAV(String inSingleStreamAV)

getHostname

public String getHostname()

Description copied from class: PushPublishBase

Get destination server host name.

Specified by:

getHostname in interface IPushPublish

Overrides:

getHostname in class PushPublishBase

Returns:

destination server host name

setHostname

public void setHostname(String hostname)

Specified by:

setHostname in interface IPushPublish

Overrides:

setHostname in class PushPublishBase

setPort

public void setPort(int port)

Set destination server port.

Specified by:

setPort in interface IPushPublish

Overrides:

setPort in class PushPublishBase

Parameters:

port - destination server port

setPort

public void setPort(String portIn)

Description copied from class: PushPublishBase

Set destination server port.

Specified by:

setPort in interface IPushPublish

Overrides:

setPort in class PushPublishBase

Parameters:

portIn - destination server port

getAudioPort

public int getAudioPort()

Gets the audio port.

Returns:

the audio port

setAudioPort

public void setAudioPort(int audioPort)

Sets the audio port.

Parameters:

audioPort - the new audio port

setVideoPort

public void setVideoPort(int videoPort)

getAudioHost

public String getAudioHost()

Gets the audio host.

Returns:

the audio host

setAudioHost

public void setAudioHost(String audioHost)

Sets the audio host.

Parameters:

audioHost - the new audio host

getVideoHost

public String getVideoHost()

Gets the video host.

Returns:

the video host

setVideoHost

public void setVideoHost(String videoHost)

Sets the video host.

Parameters:

videoHost - the new video host

setAudioPort

public void setAudioPort(String audioPort)

Sets the audio port.

Parameters:

audioPort - the new audio port

getVideoPort

public int getVideoPort()

Gets the video port.

Returns:

the video port

setVideoPort

public void setVideoPort(String videoPort)

Sets the video port.

Parameters:

videoPort - the new video port

isRTPWrapped

public boolean isRTPWrapped()

Checks if is rTP wrapped.

Returns:

true, if is rTP wrapped

setRTPWrapped

public void setRTPWrapped(String string)

Sets the rTP wrapped.

Parameters:

string - the new rTP wrapped

getHostType

public String getHostType()

Gets the host type.

Returns:

the host type

setHostType

public void setHostType(String hostType)

Sets the host type.

Parameters:

hostType - the new host type

setTimeToLive

public void setTimeToLive(String ttl)

Sets the time to live.

Parameters:

ttl - the new time to live

getTimeToLive

public int getTimeToLive()

Gets the time to live.

Returns:

the time to live

load

public void load(java.util.HashMap<String,String> dataMap)

Description copied from class: PushPublishBase

Loads map and profile parameters

Overrides:

load in class PushPublishBase

Parameters:

dataMap - the data map

getRtpStreamWaitTimeout

public long getRtpStreamWaitTimeout()

setRtpStreamWaitTimeout

public void setRtpStreamWaitTimeout(String rtpStreamWaitTimeout)

setRtpStreamWaitTimeout

public void setRtpStreamWaitTimeout(long rtpStreamWaitTimeout)

createPushPublishSession

public IPushPublishSession createPushPublishSession()

Specified by:

createPushPublishSession in interface IPushPublish

Overrides:

createPushPublishSession in class PushPublishBase

getContextStr

public String getContextStr()

Specified by:

getContextStr in interface IPushPublish

Specified by:

getContextStr in class PushPublishBase

getmRtpDestination

public RTPDestination getmRtpDestination()

getConnectedState

public int getConnectedState()

setConnectionStatus

public void setConnectionStatus(Boolean connected)

getMessagesAttemptedCount

public long getMessagesAttemptedCount()

getMessagesRetriedCount

public long getMessagesRetriedCount()

getMessagesFailedCount

public long getMessagesFailedCount()

add

public void add(IOPerformanceCounter totalValue)

Overrides:

add in class PushPublishBase

addIOPerformance2

public void addIOPerformance2(IOPerformanceCounter totalIOPerformanceResult)

Overrides:

addIOPerformance2 in class PushPublishBase

isWriteSDPFiles

public boolean isWriteSDPFiles()

setWriteSDPFiles

public void setWriteSDPFiles(boolean writeSDPFiles)

isRemoveSDPFiles

public boolean isRemoveSDPFiles()

setRemoveSDPFiles

public void setRemoveSDPFiles(boolean removeSDPFiles)

setRTPWrapped

public void setRTPWrapped(boolean isRTPWrapped)

getMulticastInterfaceAddress

public String getMulticastInterfaceAddress()

setMulticastInterfaceAddress

public void setMulticastInterfaceAddress(String multicastInterfaceAddress)