public class PushPublishRTP extends PushPublishBase
| Modifier and Type | Field and 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 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.
|
appInstance, className, DESTINATION_BAK, DESTINATION_PRI, DESTINATION_RED, destinationName, destinationServer, dstStreamName, entryName, hostname, inetAddr, isAdaptiveStreaming, isExternalRedundancy, logger, mImplementation, myMap, password, port, profile, properties, pushPublishSession, pushPublishStreamDebug, pushPublishType, reconnectWaitTime, sendingPerformance, srcStream, srcStreamName, totalIOPerformance2Last, totalIOPerformanceLast, userNameCONNECTED_STATE_CONNECTED, CONNECTED_STATE_CONNECTING, CONNECTED_STATE_NOT_CONNECTED, CONNECTED_STATE_WAITING, PUSHPUBLISH_TYPE_CUPERTINO, PUSHPUBLISH_TYPE_MPEGDASH, PUSHPUBLISH_TYPE_RTMP, PUSHPUBLISH_TYPE_RTP, PUSHPUBLISH_TYPE_RTP_BUFFERED, PUSHPUBLISH_TYPE_SANJOSE, PUSHPUBLISH_TYPE_SRT, PUSHPUBLISH_TYPE_UNKNOWN| Constructor and Description |
|---|
PushPublishRTP() |
| Modifier and Type | Method and 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() |
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 |
isRTPWrapped()
Checks if is rTP wrapped.
|
boolean |
isSingleStreamAV()
Checks if is stream is packatized.
|
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 |
setPort(int port)
Set destination server port.
|
void |
setPort(String portIn)
Set destination server port.
|
void |
setRTPPushPublishSession(RTPPushPublishSession rtpPushPublishSession)
Sets the rTP push publish session.
|
void |
setRtpStreamWaitTimeout(long rtpStreamWaitTimeout) |
void |
setRtpStreamWaitTimeout(String rtpStreamWaitTimeout) |
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(String videoPort)
Sets the video port.
|
getBandwidth, getDestinationID, getDestinationName, getDestinationServer, getDstStreamName, getEntryName, getImplementation, getInetAddr, getMap, getMessagesOutBytes, getMessagesOutCount, getPassword, getPort, getProfile, getProperties, getPushPublishType, getReconnectWaitTime, getSrcStream, getSrcStreamName, getUserName, getWowzaStreamingEngineVersionStr, handleParentStreamDisconnect, incrementMessagesOut, isAdaptiveStreaming, isDebugLog, isExternalRedundancy, isParent, isTargetedStream, logDebug, logError, logError, logError, logInfo, logWarn, setAdaptiveStreaming, setAdaptiveStreaming, setDebugLog, setDestinationName, setDestinationServer, setDestinationServer, setDstStreamName, setEntryName, setExternalRedundancy, setExternalRedundancy, setHost, setImplementation, setInetAddr, setPassword, setProfile, setReconnectWaitTime, setSrcStream, setSrcStreamName, setStreamName, setUserName, updateUsageTrackerprotected String audioHost
protected int audioPort
public static final Class<PushPublishRTP> CLASS
public static final String CLASSNAME
protected boolean isRTPWrapped
protected Object lock
protected RTPDestination mRtpDestination
protected boolean removeSDPFiles
protected RTPPushPublishSession rtpPushPublishSession
public static final String SDPFILEEXTENSION
protected boolean singleStreamAV
protected String videoHost
protected int videoPort
protected boolean writeSDPFiles
public PushPublishRTP()
throws com.wowza.wms.server.LicensingException
com.wowza.wms.server.LicensingExceptionpublic void add(IOPerformanceCounter totalValue)
add in class PushPublishBasepublic void addIOPerformance2(IOPerformanceCounter totalIOPerformanceResult)
addIOPerformance2 in class PushPublishBasepublic void connect()
public IPushPublishSession createPushPublishSession()
createPushPublishSession in interface IPushPublishcreatePushPublishSession in class PushPublishBasepublic void disconnect()
public void disconnect(boolean hard)
public IApplicationInstance getAppInstance()
PushPublishBasegetAppInstance in class PushPublishBasepublic String getAudioHost()
public int getAudioPort()
public int getConnectedState()
public String getContextStr()
getContextStr in interface IPushPublishgetContextStr in class PushPublishBasepublic String getHostname()
PushPublishBasegetHostname in interface IPushPublishgetHostname in class PushPublishBasepublic String getHostType()
public long getMessagesAttemptedCount()
public long getMessagesFailedCount()
public long getMessagesRetriedCount()
public RTPDestination getmRtpDestination()
public RTPPushPublishSession getRTPPushPublishSession()
public long getRtpStreamWaitTimeout()
public int getTimeToLive()
public String getVideoHost()
public int getVideoPort()
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)
PushPublishBaseinit in interface IPushPublishinit in class PushPublishBaseappInstance - the app instancestreamName - the source stream nameprofileData - the profile paramsmaps - the map entry paramsdebug - stream debug flagpublic boolean isRTPWrapped()
public boolean isSingleStreamAV()
public void load(java.util.HashMap<String,String> dataMap)
PushPublishBaseload in class PushPublishBasedataMap - the data mappublic void resetConnection()
public void resetConnection(int delay)
public void setAppInstance(IApplicationInstance appInstance)
PushPublishBasesetAppInstance in class PushPublishBaseappInstance - appInstance interfacepublic void setAudioHost(String audioHost)
audioHost - the new audio hostpublic void setAudioPort(int audioPort)
audioPort - the new audio portpublic void setAudioPort(String audioPort)
audioPort - the new audio portpublic void setConnectionStatus(Boolean connected)
public void setHostname(String hostname)
setHostname in interface IPushPublishsetHostname in class PushPublishBasepublic void setHostType(String hostType)
hostType - the new host typepublic void setPort(int port)
setPort in interface IPushPublishsetPort in class PushPublishBaseport - destination server portpublic void setPort(String portIn)
PushPublishBasesetPort in interface IPushPublishsetPort in class PushPublishBaseportIn - destination server portpublic void setRTPPushPublishSession(RTPPushPublishSession rtpPushPublishSession)
rtpPushPublishSession - the new rTP push publish sessionpublic void setRtpStreamWaitTimeout(long rtpStreamWaitTimeout)
public void setRtpStreamWaitTimeout(String rtpStreamWaitTimeout)
public void setRTPWrapped(String string)
string - the new rTP wrappedpublic void setSingleStreamAV(boolean inSingleStreamAV)
inSingleStreamAV - whether stream is packatizedpublic void setSingleStreamAV(String inSingleStreamAV)
public void setTimeToLive(String ttl)
ttl - the new time to livepublic void setVideoHost(String videoHost)
videoHost - the new video hostpublic void setVideoPort(String videoPort)
videoPort - the new video port