com.wowza.wms.pushpublish.model

Class PushPublishHTTPAkamaiBase

Object

com.wowza.wms.pushpublish.model.PushPublishBase

com.wowza.wms.pushpublish.model.PushPublishHTTPBase

com.wowza.wms.pushpublish.model.PushPublishHTTPAkamaiBase

All Implemented Interfaces:

IPushPublish

Direct Known Subclasses:

PushPublishHTTPSanJoseAkamaiHandler

public abstract class PushPublishHTTPAkamaiBase
extends PushPublishHTTPBase

Field Summary

Fields

Modifier and Type	Field and Description
static String	AKAMAI_DEFAULT_HOSTID
protected String	akamaiEventName
protected String	akamaiHostId
protected String	akamaiProtocolName
protected String	akamaiStreamId
static Class<PushPublishHTTPAkamaiBase>	CLASS
static String	CLASSNAME
protected int	connectionTimeout
protected boolean	fakePosts
protected String	httpIngressDomainSuffix
protected String	httpPlaybackDomainOverride
protected int	httpWriterLogOptions
protected boolean	isPlaybackSSL
protected boolean	isSendSSL
protected int	maxRetries
protected String	protocol
protected String	queryParams
protected int	readWriteTimeout
protected String	resolvedHostname
protected boolean	reuseSockets
protected boolean	sendToBackupServer
protected String	userAgent

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

httpLogManifests, httpManifestDebug, INDETERMINATE_PLAYLIST_COUNT, MIN_PLAYLIST_COUNT, playlistAcrossSessions, playlistCountFromMap, playlistCountFromPacketizer, playlistCrossName, playlistDurationFromMap, playlistMap, playlistName, playlistTimeout, relativePlaylists

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, 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_RTMP, PUSHPUBLISH_TYPE_RTP, PUSHPUBLISH_TYPE_RTP_BUFFERED, PUSHPUBLISH_TYPE_SANJOSE, PUSHPUBLISH_TYPE_SRT, PUSHPUBLISH_TYPE_UNKNOWN

Constructor Summary

Constructors

Constructor and Description
PushPublishHTTPAkamaiBase()

Method Summary

Methods

Modifier and Type	Method and Description
String	getAkamaiEventName()
String	getAkamaiHostId()
String	getAkamaiStreamId()
int	getConnectionTimeout()
String	getDestinationDomain()
String	getDestinationGroupPath(String groupName)
String	getDestinationGroupURL(String groupName)
String	getDestinationPath()
int	getDestinationPort()
String	getDestinationURL()
String	getGroupPlaybackPath(String groupName)
int	getMaxRetries()
String	getPlaybackDomain()
String	getPlaybackURL()
int	getReadWriteTimeout()
String	getResolvedAkamaiStreamId()
String	getUserAgent()
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	isDeleteSentChunks()
boolean	isFakePosts()
boolean	isInRedundancyPair()
boolean	isReuseSockets()
boolean	isSendToBackupServer()
void	load(java.util.HashMap<String,String> dataMap) Loads map and profile parameters
void	resetConnection()
String	resolveAkamaiStreamId(Boolean sendToBackup)
void	setAkamaiEventName(String akamaiEventName)
void	setAkamaiHostId(String akamaiHostId)
void	setAkamaiStreamId(String akamaiStreamId)
void	setConnectionTimeout(int connectionTimeout)
void	setDeleteSentChunks(boolean deleteSentChunks)
void	setFakePosts(boolean fakePosts)
void	setMaxRetries(int maxRetries)
void	setReadWriteTimeout(int readTimeout)
void	setReuseSockets(boolean reuseSockets)
void	setSendToBackupServer(boolean sendToBackupServer)
void	setUserAgent(String userAgent)

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

getAdaptiveGroupName, getPlaylistCount, getPlaylistMap, getPlaylistTimeout, isInAdaptiveGroup, isLogDebugManifest, isPlaylistAcrossSessions, isRelativePlaylists, logDebugManifest, setAdaptiveGroupName, setPlaylistAcrossSessions, setPlaylistCountFromMap, setPlaylistCountFromPacketizer, setPlaylistTimeout, setRelativePlaylists

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

add, addIOPerformance2, createPushPublishSession, getAppInstance, getBandwidth, getContextStr, getDestinationID, getDestinationName, getDestinationServer, getDstStreamName, getEntryName, getHostname, 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, setAppInstance, setDebugLog, setDestinationName, setDestinationServer, setDestinationServer, setDstStreamName, setEntryName, setExternalRedundancy, setExternalRedundancy, setHost, setHostname, setImplementation, setInetAddr, setPassword, setPort, setPort, setProfile, setReconnectWaitTime, setSrcStream, setSrcStreamName, setStreamName, setUserName, updateUsageTracker

Methods inherited from class Object

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

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

connect, disconnect, getConnectedState, getMessagesAttemptedCount, getMessagesFailedCount, getMessagesRetriedCount

Field Detail

AKAMAI_DEFAULT_HOSTID

public static final String AKAMAI_DEFAULT_HOSTID

See Also:

Constant Field Values

akamaiEventName

protected String akamaiEventName

akamaiHostId

protected String akamaiHostId

akamaiProtocolName

protected String akamaiProtocolName

akamaiStreamId

protected String akamaiStreamId

CLASS

public static final Class<PushPublishHTTPAkamaiBase> CLASS

CLASSNAME

public static final String CLASSNAME

See Also:

Constant Field Values

connectionTimeout

protected int connectionTimeout

fakePosts

protected boolean fakePosts

httpIngressDomainSuffix

protected String httpIngressDomainSuffix

httpPlaybackDomainOverride

protected String httpPlaybackDomainOverride

httpWriterLogOptions

protected int httpWriterLogOptions

isPlaybackSSL

protected boolean isPlaybackSSL

isSendSSL

protected boolean isSendSSL

maxRetries

protected int maxRetries

protocol

protected String protocol

queryParams

protected String queryParams

readWriteTimeout

protected int readWriteTimeout

resolvedHostname

protected String resolvedHostname

reuseSockets

protected boolean reuseSockets

sendToBackupServer

protected boolean sendToBackupServer

userAgent

protected String userAgent

Constructor Detail

PushPublishHTTPAkamaiBase

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

Throws:

com.wowza.wms.server.LicensingException

Method Detail

getAkamaiEventName

public String getAkamaiEventName()

getAkamaiHostId

public String getAkamaiHostId()

getAkamaiStreamId

public String getAkamaiStreamId()

getConnectionTimeout

public int getConnectionTimeout()

getDestinationDomain

public String getDestinationDomain()

getDestinationGroupPath

public String getDestinationGroupPath(String groupName)

getDestinationGroupURL

public String getDestinationGroupURL(String groupName)

getDestinationPath

public String getDestinationPath()

getDestinationPort

public int getDestinationPort()

getDestinationURL

public String getDestinationURL()

getGroupPlaybackPath

public String getGroupPlaybackPath(String groupName)

getMaxRetries

public int getMaxRetries()

getPlaybackDomain

public String getPlaybackDomain()

getPlaybackURL

public String getPlaybackURL()

getReadWriteTimeout

public int getReadWriteTimeout()

getResolvedAkamaiStreamId

public String getResolvedAkamaiStreamId()

getUserAgent

public String getUserAgent()

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 streamDebug)

Description copied from class: PushPublishHTTPBase

Inits the instance.

Specified by:

init in interface IPushPublish

Overrides:

init in class PushPublishHTTPBase

Parameters:

appInstance - the app instance

streamName - the source stream name

profileData - the profile params

maps - the map entry params

streamDebug - stream debug flag

isDeleteSentChunks

public boolean isDeleteSentChunks()

isFakePosts

public boolean isFakePosts()

isInRedundancyPair

public boolean isInRedundancyPair()

isReuseSockets

public boolean isReuseSockets()

isSendToBackupServer

public boolean isSendToBackupServer()

load

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

Description copied from class: PushPublishHTTPBase

Loads map and profile parameters

Overrides:

load in class PushPublishHTTPBase

Parameters:

dataMap - the data map

resetConnection

public void resetConnection()

resolveAkamaiStreamId

public String resolveAkamaiStreamId(Boolean sendToBackup)

setAkamaiEventName

public void setAkamaiEventName(String akamaiEventName)

setAkamaiHostId

public void setAkamaiHostId(String akamaiHostId)

setAkamaiStreamId

public void setAkamaiStreamId(String akamaiStreamId)

setConnectionTimeout

public void setConnectionTimeout(int connectionTimeout)

setDeleteSentChunks

public void setDeleteSentChunks(boolean deleteSentChunks)

setFakePosts

public void setFakePosts(boolean fakePosts)

setMaxRetries

public void setMaxRetries(int maxRetries)

setReadWriteTimeout

public void setReadWriteTimeout(int readTimeout)

setReuseSockets

public void setReuseSockets(boolean reuseSockets)

setSendToBackupServer

public void setSendToBackupServer(boolean sendToBackupServer)

setUserAgent

public void setUserAgent(String userAgent)