com.wowza.wms.pushpublish.protocol.cupertino

Class PushPublishHTTPCupertinoAkamaiHandler

Object

com.wowza.wms.pushpublish.model.PushPublishBase

com.wowza.wms.pushpublish.model.PushPublishHTTPBase

com.wowza.wms.pushpublish.protocol.cupertino.PushPublishHTTPCupertino

com.wowza.wms.pushpublish.protocol.cupertino.PushPublishHTTPCupertinoAkamaiHandler

All Implemented Interfaces:

IPushPublish, IPushPublishHTTPGroupMember, IPushPublishHTTPOutputBuilder, IPushPublishHTTPCupertino

public class PushPublishHTTPCupertinoAkamaiHandler
extends PushPublishHTTPCupertino

Field Summary

Fields

Modifier and Type	Field and Description
protected String	resolvedHostname

Fields inherited from class com.wowza.wms.pushpublish.protocol.cupertino.PushPublishHTTPCupertino

addEndListOnDisconnect, CHUNKLISTNAME_AUDIOONLY, CHUNKLISTNAME_AUDIOVIDEO, CHUNKLISTNAME_KEYFRAMEONLY, CHUNKLISTNAME_VIDEOONLY, CHUNKLISTNAMES, keepMediaSegmentDataAfterSending, LIVESTREAMPACKETIZER_NAME, PLAYLISTNAME, RENDITION_AUDIOONLY, RENDITION_AUDIOVIDEO, RENDITION_KEYFRAMEONLY, RENDITION_VIDEOONLY, RENDITIONINDEX_AUDIOONLY, RENDITIONINDEX_AUDIOVIDEO, RENDITIONINDEX_COUNT, RENDITIONINDEX_KEYFRAMEONLY, RENDITIONINDEX_VIDEOONLY

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.IPushPublishHTTPOutputBuilder

PUSHER_ERROR_LIVEPACKETIZER_NOT_CONFIGURED, PUSHER_ERROR_RENDITIONS_MISCONFIGURED

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
PushPublishHTTPCupertinoAkamaiHandler()

Method Summary

Methods

Modifier and Type	Method and Description
void	connect()
HTTPByteWriter	createByteWriter(java.net.URI uri, int port)
int	deleteMediaSegment(MediaSegmentModel mediaSegment) Deletes the media (chunk) at the destination URI.
boolean	destroyByteWriter()
int	getChunkDurationTarget(ILiveStreamPacketizer liveStreamPacketizer)
String	getDestionationLogData() Get a JSON formatted string of data that represents the destination to include with the connect/disconnect logging
WMSProperties	getPlaylistProperties()
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	isSendToBackupServer() Is this implementation sending to a backup server
void	load(java.util.HashMap<String,String> dataMap) Loads map and profile parameters
boolean	outputClose() Close the destination (if needed).
boolean	outputOpen() Open the destination (if needed) in preparation of having one or more items (playlists/media segments) pushed to it
void	resetConnection()
int	sendGroupMasterPlaylist(String groupName, PlaylistModel playlist) Sends a group master playlist to the destination.
int	sendMasterPlaylist(PlaylistModel playlist) Sends the master playlist to the destination.
int	sendMediaPlaylist(PlaylistModel playlist) Sends the media playlist to the destination.
int	sendMediaSegment(MediaSegmentModel mediaSegment) Sends the media (chunk) to the destination; media provided as a fragment list.
void	setSendToBackupServer(boolean backup) Setup to send to a backup destination
boolean	updateGroupMasterPlaylistPlaybackURI(String groupName, PlaylistModel masterPlaylist) Get the group master playlist URI for the given group master playlist file that a player would use to consume the content from the CDN Example: "http://myHost.com/myPath/myGroup/playlist.m3u8"
boolean	updateMasterPlaylistPlaybackURI(PlaylistModel playlist) update the master playlist URI for the provided playlist model that a player would use to consume the content from the CDN Example: "http://myHost.com/myPath/myStream/playlist.m3u8" where "playlist.m3u8" is the value given for masterPlaylistFilename
boolean	updateMediaPlaylistPlaybackURI(PlaylistModel playlist) update/set the media playlist (chunklist) URI for the provided media playlist file that a player would use to consume the content from the CDN Example: "http://myHost.com/myPath/myStream/chunklist.m3u8" where "chunklist.m3u8" is the value given for mediaPlaylistFilename
boolean	updateMediaSegmentPlaybackURI(MediaSegmentModel mediaSegment) set the media URI for the given media (chunk) file that a player would use to consume the content from the CDN Example: "http://myHost.com/myPath/myStream/media_1.ts" where "media_1.ts" is the value given for mediaFilename

Methods inherited from class com.wowza.wms.pushpublish.protocol.cupertino.PushPublishHTTPCupertino

adaptiveGroupPlaylistNeedsUpdating, addTagToPlaylist, addTagToPlaylist, createGroupPlaylist, createMasterPlaylist, createMediaPlaylist, createMediaSegmentModel, createOutputItem, createTag, disconnect, disconnect, error, getConnectedState, getContextStr, getGroupPlaylistRenditionDescription, getLastChunkId, getLiveStreamPacketizerName, getMediaPlaylistPlaybackURL, getMessagesAttemptedCount, getMessagesFailedCount, getMessagesRetriedCount, getPacketizerLock, getPlaylistCount, getRandomSessionStr, getRenditionsStr, isGroupReady, isInRedundancyPair, outputSend, printPlaylist, resetNewPacketizer, sendGroupPlaylist, setRenditionsStr, writeTagToString

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

getAdaptiveGroupName, 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, 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.IPushPublishHTTPGroupMember

getAdaptiveGroupName, isInAdaptiveGroup, isLogDebugManifest

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

getAppInstance, getDstStreamName, getSrcStreamName, isDebugLog

Field Detail

resolvedHostname

protected String resolvedHostname

Constructor Detail

PushPublishHTTPCupertinoAkamaiHandler

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

Throws:

com.wowza.wms.server.LicensingException

Method Detail

connect

public void connect()

Specified by:

connect in interface IPushPublish

Overrides:

connect in class PushPublishHTTPCupertino

createByteWriter

public HTTPByteWriter createByteWriter(java.net.URI uri,
                              int port)

deleteMediaSegment

public int deleteMediaSegment(MediaSegmentModel mediaSegment)

Description copied from interface: IPushPublishHTTPCupertino

Deletes the media (chunk) at the destination URI. Default implementation assumes the URI uses the HTTP schema and deletes the media using the WSE HTTPByteWriter. Implementations not using the HTTP schema or not wanting to use the default HTTPByteWriter should override the default method.

Parameters:

mediaSegment - the media destination URI

Returns:

number of bytes sent if successful (less than zero implies the implementation does not support, 0 is a failure, > 0 is success)

destroyByteWriter

public boolean destroyByteWriter()

getChunkDurationTarget

public int getChunkDurationTarget(ILiveStreamPacketizer liveStreamPacketizer)

Specified by:

getChunkDurationTarget in interface IPushPublishHTTPOutputBuilder

Overrides:

getChunkDurationTarget in class PushPublishHTTPCupertino

getDestionationLogData

public String getDestionationLogData()

Description copied from class: PushPublishHTTPCupertino

Get a JSON formatted string of data that represents the destination to include with the connect/disconnect logging

Specified by:

getDestionationLogData in interface IPushPublishHTTPCupertino

Specified by:

getDestionationLogData in class PushPublishHTTPCupertino

Returns:

JSON formatted string representation

getPlaylistProperties

public WMSProperties getPlaylistProperties()

Specified by:

getPlaylistProperties in interface IPushPublishHTTPGroupMember

Overrides:

getPlaylistProperties in class PushPublishHTTPCupertino

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 PushPublishHTTPCupertino

Parameters:

appInstance - the app instance

streamName - the source stream name

profileData - the profile params

maps - the map entry params

streamDebug - stream debug flag

isSendToBackupServer

public boolean isSendToBackupServer()

Description copied from interface: IPushPublishHTTPCupertino

Is this implementation sending to a backup server

Returns:

true if sending to a backup server

load

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

Description copied from class: PushPublishHTTPBase

Loads map and profile parameters

Overrides:

load in class PushPublishHTTPCupertino

Parameters:

dataMap - the data map

outputClose

public boolean outputClose()

Description copied from interface: IPushPublishHTTPCupertino

Close the destination (if needed). All items (playlist/media segments) have been pushed to bring the destination up to date with the current state

Returns:

true if the destination was closed

outputOpen

public boolean outputOpen()

Description copied from interface: IPushPublishHTTPCupertino

Open the destination (if needed) in preparation of having one or more items (playlists/media segments) pushed to it

Returns:

true if the destination was opened

resetConnection

public void resetConnection()

Specified by:

resetConnection in interface IPushPublish

Overrides:

resetConnection in class PushPublishHTTPCupertino

sendGroupMasterPlaylist

public int sendGroupMasterPlaylist(String groupName,
                          PlaylistModel playlist)

Description copied from interface: IPushPublishHTTPCupertino

Sends a group master playlist to the destination.

Parameters:

groupName - the group name

playlist - the group master playlist model

Returns:

number of bytes sent to output

sendMasterPlaylist

public int sendMasterPlaylist(PlaylistModel playlist)

Description copied from interface: IPushPublishHTTPCupertino

Sends the master playlist to the destination.

Parameters:

playlist - the master playlist model

Returns:

number of bytes sent to output (less than zero implies the implementation does not support, 0 is a failure, > 0 is success)

sendMediaPlaylist

public int sendMediaPlaylist(PlaylistModel playlist)

Description copied from interface: IPushPublishHTTPCupertino

Sends the media playlist to the destination.

Parameters:

playlist - the media playlist model

Returns:

number of bytes sent to output (less than zero implies the implementation does not support, 0 is a failure, > 0 is success)

sendMediaSegment

public int sendMediaSegment(MediaSegmentModel mediaSegment)

Description copied from interface: IPushPublishHTTPCupertino

Sends the media (chunk) to the destination; media provided as a fragment list.

Parameters:

mediaSegment - the media file in fragment list form

Returns:

number of bytes sent to output (less than zero implies the implementation does not support, 0 is a failure, > 0 is success)

setSendToBackupServer

public void setSendToBackupServer(boolean backup)

Description copied from interface: IPushPublishHTTPCupertino

Setup to send to a backup destination

updateGroupMasterPlaylistPlaybackURI

public boolean updateGroupMasterPlaylistPlaybackURI(String groupName,
                                           PlaylistModel masterPlaylist)

Description copied from interface: IPushPublishHTTPCupertino

Get the group master playlist URI for the given group master playlist file that a player would use to consume the content from the CDN Example: "http://myHost.com/myPath/myGroup/playlist.m3u8"

Parameters:

groupName - group name

masterPlaylist - master group playlist

Returns:

true if the uri was updated

updateMasterPlaylistPlaybackURI

public boolean updateMasterPlaylistPlaybackURI(PlaylistModel playlist)

Description copied from interface: IPushPublishHTTPCupertino

update the master playlist URI for the provided playlist model that a player would use to consume the content from the CDN Example: "http://myHost.com/myPath/myStream/playlist.m3u8" where "playlist.m3u8" is the value given for masterPlaylistFilename

Parameters:

playlist - the master playlist model to update the URI in

Returns:

true if the URI was updated

updateMediaPlaylistPlaybackURI

public boolean updateMediaPlaylistPlaybackURI(PlaylistModel playlist)

Description copied from interface: IPushPublishHTTPCupertino

update/set the media playlist (chunklist) URI for the provided media playlist file that a player would use to consume the content from the CDN Example: "http://myHost.com/myPath/myStream/chunklist.m3u8" where "chunklist.m3u8" is the value given for mediaPlaylistFilename

Parameters:

playlist - to update the uri in

Returns:

true if the playlist uri was updated

updateMediaSegmentPlaybackURI

public boolean updateMediaSegmentPlaybackURI(MediaSegmentModel mediaSegment)

Description copied from interface: IPushPublishHTTPCupertino

set the media URI for the given media (chunk) file that a player would use to consume the content from the CDN Example: "http://myHost.com/myPath/myStream/media_1.ts" where "media_1.ts" is the value given for mediaFilename

Parameters:

mediaSegment - to update the uri of

Returns:

true if the uri was updated