Class PushPublishHTTPCupertinoGoogleHandler
- 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.PushPublishHTTPCupertinoGoogleHandler
-
- All Implemented Interfaces:
IPushPublish
,IPushPublishHTTPGroupMember
,IPushPublishHTTPOutputBuilder
,IPushPublishHTTPCupertino
public class PushPublishHTTPCupertinoGoogleHandler extends PushPublishHTTPCupertino
-
-
Field Summary
Fields Modifier and Type Field Description protected String
bucketName
static String
BUCKETVAR
static String
COMMANDPATHDEL
static String
COMMANDPATHPOST
protected int
connectionTimeout
static String
DEFAULTGCEHOST
static int
DEFAULTGCEPORT
protected boolean
deleteSentChunks
protected static String
destinationPath
protected static String
destinationURLPrefix
protected boolean
fakePosts
static String
FILENAMEVAR
protected boolean
httpWriterDebug
protected boolean
isPlaybackSSL
protected boolean
isSendSSL
protected static String
LINE_FEED
protected static String
playbackDomain
protected static String
playbackURLPrefix
protected String
project
static String
PROJECTQP
static String
PROJECTQPVAR
static String
PROJECTVAR
static String
QUERYPARAMS
protected int
readWriteTimeout
protected boolean
sendToBackupServer
-
Fields inherited from class com.wowza.wms.pushpublish.protocol.cupertino.PushPublishHTTPCupertino
addEndListOnDisconnect, chunkDurationTarget, CHUNKLISTNAME_AUDIOONLY, CHUNKLISTNAME_AUDIOVIDEO, CHUNKLISTNAME_KEYFRAMEONLY, CHUNKLISTNAME_VIDEOONLY, CHUNKLISTNAMES, keepMediaSegmentDataAfterSending, liveStreamPacketizerCupertino, minNumToDelete, minNumToSend, PLAYLISTNAME, pusher, RENDITION_AUDIOONLY, RENDITION_AUDIOVIDEO, RENDITION_KEYFRAMEONLY, RENDITION_SUBTITLES, RENDITION_VIDEOONLY, RENDITIONINDEX_AUDIOONLY, RENDITIONINDEX_AUDIOVIDEO, RENDITIONINDEX_COUNT, RENDITIONINDEX_KEYFRAMEONLY, RENDITIONINDEX_SUBTITLES, RENDITIONINDEX_VIDEOONLY, SUBTITLELISTNAME
-
Fields inherited from class com.wowza.wms.pushpublish.model.PushPublishHTTPBase
CACHE_CONTROL_FACTOR, CACHE_CONTROL_HEADER, CACHE_CONTROL_HEADER_KEY, CACHE_CONTROL_HEADER_NONE, CACHE_CONTROL_MEDIA_DEFAULT, httpLogManifests, httpManifestDebug, INDETERMINATE_PLAYLIST_COUNT, maxSegmentCountFromMap, maxSegmentCountFromPacketizer, MIN_PLAYLIST_COUNT, playlistAcrossSessions, playlistBaseUrl, 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, 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
-
Fields inherited from interface com.wowza.wms.pushpublish.model.IPushPublishHTTPOutputBuilder
PUSHER_ERROR_LIVEPACKETIZER_NOT_CONFIGURED, PUSHER_ERROR_RENDITIONS_MISCONFIGURED
-
-
Constructor Summary
Constructors Constructor Description PushPublishHTTPCupertinoGoogleHandler()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
connect()
int
deleteMediaSegment(MediaSegmentModel mediaSegment)
Deletes the media (chunk) at the destination URI.int
getChunkDurationTarget(ILiveStreamPacketizer liveStreamPacketizer)
String
getContextStr()
String
getDestinationDomain()
String
getDestinationPath()
String
getDestionationLogData()
Get a JSON formatted string of data that represents the destination to include with the connect/disconnect loggingString
getIngressURL()
String
getPlaybackDomain()
String
getPlaybackPath()
String
getPlaybackURL()
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 servervoid
load(java.util.HashMap<String,String> dataMap)
Loads map and profile parametersboolean
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 itvoid
resetConnection()
int
sendGroupMasterPlaylist(String groupName, PlaylistModel masterPlaylist)
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 destinationboolean
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 masterPlaylistFilenameboolean
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 mediaPlaylistFilenameboolean
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, addPlaylistToMasterPlaylist, addTagToPlaylist, addTagToPlaylist, createGroupPlaylist, createMasterPlaylist, createMediaPlaylist, createMediaSegmentModel, createOutputItem, createStreamInfTag, createTag, disconnect, disconnect, error, getConnectedState, getGroupPlaylistRenditionDescription, getHeaderSegment, getLastChunkId, getLiveStreamPacketizerCupertino, getLiveStreamPacketizerName, getMediaPlaylistForRendtion, getMediaPlaylistPlaybackURL, getMediaPlaylists, getMediaPlaylistStr, getMessagesAttemptedCount, getMessagesFailedCount, getMessagesRetriedCount, getPacketizerLock, getPlaylistCount, getPlaylistProperties, getRandomSessionStr, getRenditionsStr, isGroupReady, isInRedundancyPair, isRendition, loadMediaSegment, outputSend, prepareMediaPlaylist, printPlaylist, processPlaylistChunks, renditionIndexToRendition, renditionToPacketizerRendition, renditionToRenditionIndex, resetNewPacketizer, sendGroupPlaylist, setLiveStreamPacketizer, setRenditionsStr, writeTagToString
-
Methods inherited from class com.wowza.wms.pushpublish.model.PushPublishHTTPBase
getAdaptiveGroupName, getMaxSegmentCount, getPlaylistBaseUrl, getPlaylistMap, getPlaylistTimeout, isInAdaptiveGroup, isLogDebugManifest, isPlaylistAcrossSessions, isRelativePlaylists, logDebugManifest, setAdaptiveGroupName, setMaxSegmentCountFromMap, setMaxSegmentCountFromPacketizer, setPlaylistAcrossSessions, setPlaylistBaseUrl, setPlaylistCountFromMap, setPlaylistCountFromPacketizer, setPlaylistTimeout, setRelativePlaylists
-
Methods inherited from class com.wowza.wms.pushpublish.model.PushPublishBase
add, addIOPerformance2, clearLoggingValues, createPushPublishSession, getAppInstance, getBandwidth, getBaseParams, getDestinationID, getDestinationName, getDestinationServer, getDstStreamName, getEntryName, getHostname, 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, setAppInstance, setDebugLog, setDestinationName, setDestinationServer, setDestinationServer, setDstStreamName, setEntryName, setExternalRedundancy, setExternalRedundancy, setHost, setHostname, setImplementation, setInetAddr, setPassword, setPlaybackHostname, setPort, setPort, 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
-
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
-
destinationURLPrefix
protected static final String destinationURLPrefix
- See Also:
- Constant Field Values
-
playbackURLPrefix
protected static final String playbackURLPrefix
- See Also:
- Constant Field Values
-
playbackDomain
protected static final String playbackDomain
- See Also:
- Constant Field Values
-
destinationPath
protected static final String destinationPath
- See Also:
- Constant Field Values
-
DEFAULTGCEHOST
public static final String DEFAULTGCEHOST
- See Also:
- Constant Field Values
-
DEFAULTGCEPORT
public static final int DEFAULTGCEPORT
- See Also:
- Constant Field Values
-
BUCKETVAR
public static final String BUCKETVAR
- See Also:
- Constant Field Values
-
COMMANDPATHPOST
public static final String COMMANDPATHPOST
- See Also:
- Constant Field Values
-
COMMANDPATHDEL
public static final String COMMANDPATHDEL
- See Also:
- Constant Field Values
-
FILENAMEVAR
public static final String FILENAMEVAR
- See Also:
- Constant Field Values
-
PROJECTVAR
public static final String PROJECTVAR
- See Also:
- Constant Field Values
-
PROJECTQPVAR
public static final String PROJECTQPVAR
- See Also:
- Constant Field Values
-
PROJECTQP
public static final String PROJECTQP
- See Also:
- Constant Field Values
-
QUERYPARAMS
public static final String QUERYPARAMS
- See Also:
- Constant Field Values
-
project
protected String project
-
bucketName
protected String bucketName
-
LINE_FEED
protected static final String LINE_FEED
- See Also:
- Constant Field Values
-
sendToBackupServer
protected boolean sendToBackupServer
-
httpWriterDebug
protected boolean httpWriterDebug
-
deleteSentChunks
protected boolean deleteSentChunks
-
fakePosts
protected boolean fakePosts
-
isSendSSL
protected boolean isSendSSL
-
isPlaybackSSL
protected boolean isPlaybackSSL
-
connectionTimeout
protected int connectionTimeout
-
readWriteTimeout
protected int readWriteTimeout
-
-
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 streamDebug)
Description copied from class:PushPublishHTTPBase
Inits the instance.- Specified by:
init
in interfaceIPushPublish
- Overrides:
init
in classPushPublishHTTPCupertino
- Parameters:
appInstance
- the app instancestreamName
- the source stream nameprofileData
- the profile paramsmaps
- the map entry paramsstreamDebug
- stream debug flag
-
load
public void load(java.util.HashMap<String,String> dataMap)
Description copied from class:PushPublishHTTPBase
Loads map and profile parameters- Overrides:
load
in classPushPublishHTTPCupertino
- Parameters:
dataMap
- the data map
-
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
-
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
-
connect
public void connect()
- Specified by:
connect
in interfaceIPushPublish
- Overrides:
connect
in classPushPublishHTTPCupertino
-
resetConnection
public void resetConnection()
- Specified by:
resetConnection
in interfaceIPushPublish
- Overrides:
resetConnection
in classPushPublishHTTPCupertino
-
getChunkDurationTarget
public int getChunkDurationTarget(ILiveStreamPacketizer liveStreamPacketizer)
- Specified by:
getChunkDurationTarget
in interfaceIPushPublishHTTPOutputBuilder
- Overrides:
getChunkDurationTarget
in classPushPublishHTTPCupertino
-
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
-
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 namemasterPlaylist
- 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
-
sendGroupMasterPlaylist
public int sendGroupMasterPlaylist(String groupName, PlaylistModel masterPlaylist)
Description copied from interface:IPushPublishHTTPCupertino
Sends a group master playlist to the destination.- Parameters:
groupName
- the group namemasterPlaylist
- 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)
-
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)
-
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 interfaceIPushPublishHTTPCupertino
- Specified by:
getDestionationLogData
in classPushPublishHTTPCupertino
- Returns:
- JSON formatted string representation
-
getDestinationDomain
public String getDestinationDomain()
-
getDestinationPath
public String getDestinationPath()
-
getContextStr
public String getContextStr()
- Specified by:
getContextStr
in interfaceIPushPublish
- Overrides:
getContextStr
in classPushPublishHTTPCupertino
-
getIngressURL
public String getIngressURL()
-
getPlaybackURL
public String getPlaybackURL()
-
getPlaybackDomain
public String getPlaybackDomain()
-
getPlaybackPath
public String getPlaybackPath()
-
-