public abstract class PushPublishBase extends Object implements IPushPublish
| Modifier and Type | Field and Description |
|---|---|
protected IApplicationInstance |
appInstance
The app instance within-which the module is running.
|
protected String |
className |
static int |
DESTINATION_BAK |
static int |
DESTINATION_PRI |
static int |
DESTINATION_RED |
protected String |
destinationName
Name of the target destination; e.g.
|
protected int |
destinationServer
Destination server for Stream Target destinations; can be primary, backup, or redundant.
|
protected String |
dstStreamName
The destination stream name.
|
protected String |
entryName
The map file entry name.
|
protected String |
hostname
The destination host.
|
protected java.net.InetAddress |
inetAddr
The destination inet address.
|
protected boolean |
isAdaptiveStreaming
The is adaptive streaming.
|
protected boolean |
isExternalRedundancy
Stream Target has a redundant stream being pushed by another WSE instance
|
protected WMSLogger |
logger |
protected String |
mImplementation
The profile implementation.
|
protected java.util.Map<String,String> |
myMap |
protected String |
password
The password.
|
protected int |
port
The destination port.
|
protected String |
profile
The map file entry profile.
|
protected WMSProperties |
properties
The properties.
|
protected IPushPublishSession |
pushPublishSession |
protected boolean |
pushPublishStreamDebug
Enables stream debug.
|
protected int |
pushPublishType
The type of stream to be published.
|
protected int |
reconnectWaitTime
The time between reconnect attempts (only applies to some profiles).
|
protected IOPerformanceCounter |
sendingPerformance |
protected IMediaStream |
srcStream |
protected String |
srcStreamName
The src stream name.
|
protected IOPerformanceCounter |
totalIOPerformance2Last |
protected IOPerformanceCounter |
totalIOPerformanceLast |
protected String |
userName
The user name.
|
CONNECTED_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 |
|---|
PushPublishBase()
Instantiates a new push publisher base.
|
| Modifier and Type | Method and Description |
|---|---|
void |
add(IOPerformanceCounter totalValue) |
void |
addIOPerformance2(IOPerformanceCounter totalIOPerformanceResult) |
IPushPublishSession |
createPushPublishSession() |
IApplicationInstance |
getAppInstance()
Get appInstance interface.
|
double |
getBandwidth() |
abstract String |
getContextStr() |
int |
getDestinationID()
Get destination ID.
|
String |
getDestinationName()
Get destination name.
|
int |
getDestinationServer()
Get destination server.
|
String |
getDstStreamName()
Get destination stream name.
|
String |
getEntryName()
Get map file entry name.
|
String |
getHostname()
Get destination server host name.
|
String |
getImplementation()
Gets the implementation.
|
java.net.InetAddress |
getInetAddr() |
java.util.Map<String,String> |
getMap() |
long |
getMessagesOutBytes() |
long |
getMessagesOutCount() |
String |
getPassword()
Get password.
|
int |
getPort()
Get destination server port.
|
String |
getProfile()
Get entry profile.
|
WMSProperties |
getProperties()
Get properties.
|
int |
getPushPublishType() |
int |
getReconnectWaitTime()
Get the reconnect wait time (milliseconds).
|
IMediaStream |
getSrcStream()
Get source IMediaStream.
|
String |
getSrcStreamName()
Get source stream name.
|
String |
getUserName()
Gets the user name.
|
static String |
getWowzaStreamingEngineVersionStr()
Gets the server version str.
|
boolean |
handleParentStreamDisconnect(IPushPublishSession pushPublishSession,
boolean isReset) |
void |
incrementMessagesOut(long bytes) |
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 streamDebug)
Inits the instance.
|
boolean |
isAdaptiveStreaming()
Checks if is adaptive streaming.
|
boolean |
isDebugLog() |
boolean |
isExternalRedundancy()
Is there an redundant stream being pushed by an external WSE instance?
return true or false
|
boolean |
isParent() |
boolean |
isTargetedStream(String streamName) |
void |
load(java.util.HashMap<String,String> dataMap)
Loads map and profile parameters
|
void |
logDebug(String methodName,
String log) |
void |
logError(String methodName,
String log) |
void |
logError(String methodName,
String log,
Throwable e) |
void |
logError(String methodName,
Throwable e) |
void |
logInfo(String methodName,
String log) |
void |
logWarn(String methodName,
String log) |
void |
setAdaptiveStreaming(boolean isAdaptiveStreaming)
Sets the adaptive streaming.
|
void |
setAdaptiveStreaming(String adaptiveStreamingStr) |
void |
setAppInstance(IApplicationInstance appInstance)
Set appInstance interface.
|
void |
setDebugLog(boolean debugLog)
Set debug logging.
|
void |
setDestinationName(String destinationName)
Set destination name.
|
void |
setDestinationServer(int destinationServer)
Set destination server.
|
void |
setDestinationServer(String destinationServer)
Set destination server.
|
void |
setDstStreamName(String dstStreamName)
Set destination stream name.
|
void |
setEntryName(String entryName)
Set map file entry name.
|
void |
setExternalRedundancy(boolean isExternalRedundancy)
Set whether there is an external redundant stream.
|
void |
setExternalRedundancy(String externalRedundancy) |
void |
setHost(String hostname)
Set destination server host name.
|
void |
setHostname(String hostname) |
void |
setImplementation(String implementation)
Sets the implementation.
|
void |
setInetAddr(java.net.InetAddress inetAddr) |
void |
setPassword(String password)
Set password.
|
void |
setPort(int port)
Set destination server port.
|
void |
setPort(String port)
Set destination server port.
|
void |
setProfile(String profile)
Set map file entry profile.
|
void |
setReconnectWaitTime(int reconnectWaitTime)
Set the reconnect wait time (milliseconds).
|
void |
setSrcStream(IMediaStream srcStream)
Sets the source IMediaStream.
|
void |
setSrcStreamName(String srcStreamName)
Set source stream name.
|
void |
setStreamName(String streamName)
Sets the stream name.
|
void |
setUserName(String userName)
Set user name.
|
void |
updateUsageTracker() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitconnect, disconnect, getConnectedState, getMessagesAttemptedCount, getMessagesFailedCount, getMessagesRetriedCount, resetConnectionprotected IApplicationInstance appInstance
protected String className
public static final int DESTINATION_BAK
public static final int DESTINATION_PRI
public static final int DESTINATION_RED
protected String destinationName
protected int destinationServer
protected String dstStreamName
protected String entryName
protected String hostname
protected java.net.InetAddress inetAddr
protected boolean isAdaptiveStreaming
protected boolean isExternalRedundancy
protected WMSLogger logger
protected String mImplementation
protected java.util.Map<String,String> myMap
protected String password
protected int port
protected String profile
protected WMSProperties properties
protected IPushPublishSession pushPublishSession
protected boolean pushPublishStreamDebug
protected int pushPublishType
protected int reconnectWaitTime
protected IOPerformanceCounter sendingPerformance
protected IMediaStream srcStream
protected String srcStreamName
protected IOPerformanceCounter totalIOPerformance2Last
protected IOPerformanceCounter totalIOPerformanceLast
protected String userName
public PushPublishBase()
throws com.wowza.wms.server.LicensingException
com.wowza.wms.server.LicensingExceptionpublic void add(IOPerformanceCounter totalValue)
public void addIOPerformance2(IOPerformanceCounter totalIOPerformanceResult)
public IPushPublishSession createPushPublishSession()
createPushPublishSession in interface IPushPublishpublic IApplicationInstance getAppInstance()
public double getBandwidth()
public abstract String getContextStr()
getContextStr in interface IPushPublishpublic int getDestinationID()
getDestinationID in interface IPushPublishpublic String getDestinationName()
getDestinationName in interface IPushPublishpublic int getDestinationServer()
public String getDstStreamName()
getDstStreamName in interface IPushPublishpublic String getEntryName()
getEntryName in interface IPushPublishpublic String getHostname()
getHostname in interface IPushPublishpublic String getImplementation()
public java.net.InetAddress getInetAddr()
public java.util.Map<String,String> getMap()
getMap in interface IPushPublishpublic long getMessagesOutBytes()
public long getMessagesOutCount()
public String getPassword()
public int getPort()
getPort in interface IPushPublishpublic String getProfile()
getProfile in interface IPushPublishpublic WMSProperties getProperties()
getProperties in interface IPushPublishpublic int getPushPublishType()
getPushPublishType in interface IPushPublishpublic int getReconnectWaitTime()
getReconnectWaitTime in interface IPushPublishpublic IMediaStream getSrcStream()
getSrcStream in interface IPushPublishpublic String getSrcStreamName()
getSrcStreamName in interface IPushPublishpublic String getUserName()
public static String getWowzaStreamingEngineVersionStr()
public boolean handleParentStreamDisconnect(IPushPublishSession pushPublishSession, boolean isReset)
handleParentStreamDisconnect in interface IPushPublishpublic void incrementMessagesOut(long bytes)
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 streamDebug)
init in interface IPushPublishappInstance - the app instancestreamName - the source stream namemaps - the map entry paramsprofileData - the profile paramsstreamDebug - stream debug flagpublic boolean isAdaptiveStreaming()
public boolean isDebugLog()
public boolean isExternalRedundancy()
public boolean isParent()
isParent in interface IPushPublishpublic boolean isTargetedStream(String streamName)
isTargetedStream in interface IPushPublishpublic void load(java.util.HashMap<String,String> dataMap)
dataMap - the data mappublic void logDebug(String methodName,
String log)
public void logError(String methodName,
String log)
public void logError(String methodName,
String log,
Throwable e)
public void logError(String methodName,
Throwable e)
public void logInfo(String methodName,
String log)
public void logWarn(String methodName,
String log)
public void setAdaptiveStreaming(boolean isAdaptiveStreaming)
isAdaptiveStreaming - the new adaptive streamingpublic void setAdaptiveStreaming(String adaptiveStreamingStr)
public void setAppInstance(IApplicationInstance appInstance)
appInstance - appInstance interfacepublic void setDebugLog(boolean debugLog)
setDebugLog in interface IPushPublishdebugLog - debug loggingpublic void setDestinationName(String destinationName)
setDestinationName in interface IPushPublishdestinationName - destination namepublic void setDestinationServer(int destinationServer)
destinationServer - destination serverpublic void setDestinationServer(String destinationServer)
destinationServer - destination serverpublic void setDstStreamName(String dstStreamName)
setDstStreamName in interface IPushPublishdstStreamName - destination stream namepublic void setEntryName(String entryName)
setEntryName in interface IPushPublishentryName - map file entry namepublic void setExternalRedundancy(boolean isExternalRedundancy)
isExternalRedundancy - public void setExternalRedundancy(String externalRedundancy)
public void setHost(String hostname)
setHost in interface IPushPublishhostname - destination server host namepublic void setHostname(String hostname)
setHostname in interface IPushPublishpublic void setImplementation(String implementation)
implementation - the new implementationpublic void setInetAddr(java.net.InetAddress inetAddr)
inetAddr - the inetAddr to setpublic void setPassword(String password)
password - passwordpublic void setPort(int port)
setPort in interface IPushPublishport - destination server portpublic void setPort(String port)
setPort in interface IPushPublishport - destination server portpublic void setProfile(String profile)
setProfile in interface IPushPublishprofile - map entry profilepublic void setReconnectWaitTime(int reconnectWaitTime)
setReconnectWaitTime in interface IPushPublishreconnectWaitTime - reconnect wait time (milliseconds)public void setSrcStream(IMediaStream srcStream)
setSrcStream in interface IPushPublishsrcStream - the source IMediaStreampublic void setSrcStreamName(String srcStreamName)
setSrcStreamName in interface IPushPublishsrcStreamName - source stream namepublic void setStreamName(String streamName)
setStreamName in interface IPushPublishstreamName - the new stream namepublic void setUserName(String userName)
userName - user namepublic void updateUsageTracker()
updateUsageTracker in interface IPushPublish