Package io.antmedia.rest

Class ClusterNotificationService

java.lang.Object

io.antmedia.rest.RestServiceBase

io.antmedia.rest.ClusterNotificationService

@Component
@Path("/cluster-communication")
public class ClusterNotificationService
extends RestServiceBase

Nested Class Summary

Nested classes/interfaces inherited from class io.antmedia.rest.RestServiceBase

RestServiceBase.AppBroadcastStatistics, RestServiceBase.BroadcastStatistics, RestServiceBase.ProcessBuilderFactory

Field Summary

Fields

Modifier and Type	Field	Description
protected static org.slf4j.Logger	logger

Fields inherited from class io.antmedia.rest.RestServiceBase

appCtx, appInstance, BUILD_NUMBER, COMMUNITY_EDITION, dataStoreFactory, ENDPOINT_GENERIC, ENTERPRISE_EDITION, ERROR_SOCIAL_ENDPOINT_EXCEPTION_IN_ASKING_AUTHPARAMS, ERROR_SOCIAL_ENDPOINT_UNDEFINED_CLIENT_ID, ERROR_SOCIAL_ENDPOINT_UNDEFINED_ENDPOINT, FETCH_REQUEST_REDIRECTED_TO_ORIGIN, FETCHER_NOT_STARTED_ERROR, HIGH_CPU_ERROR, HTTP, INVALID_STREAM_NAME_ERROR, IPV4_REGEX, LOOPBACK_REGEX, MAX_ITEM_IN_ONE_LIST, RECORD_DISABLE, RECORD_ENABLE, RECORD_NO_SET, REPLACE_CHARS, REPLACE_CHARS_FOR_SECURITY, RTSP, scope, servletContext

Constructor Summary

Constructors

Constructor	Description
ClusterNotificationService()

Method Summary

Modifier and Type	Method	Description
Result	publishStarted(String id, String role, String mainTrackId)
Result	publishStopped(String id, String role, String mainTrackId)

Methods inherited from class io.antmedia.rest.RestServiceBase

addEndpoint, addEndpoint, addIPCamera, addSource, addStreamSource, addSubTrack, checkStopStreaming, checkStreamUrl, connectToCamera, createBroadcastWithStreamID, deleteBroadcast, deleteBroadcasts, deleteVoD, deleteVoDs, enableRecordMuxing, getAppContext, getApplication, getAppSettings, getBroadcastStatistics, getBroadcastTotalStatistics, getBuildNumber, getCameraErrorById, getDataStore, getDataStoreFactory, getDetectionList, getIPArray, getJwtToken, getMp4Muxer, getMuxAdaptor, getOnvifDeviceProfiles, getProcess, getProcessBuilderFactory, getRoomInfoFromConference, getScope, getServerSettings, getSoftwareVersion, getStreamsDirectory, getToken, getTokenService, getVoD, getWebRTCAdaptor, getWebRTCClientStatsList, importLiveStreams2Stalker, importVoDs, importVoDsToStalker, isAlreadyRecording, isEnterprise, isInSameNodeInCluster, isMainTrack, isStreaming, logFailedOperation, logWarning, lookupBroadcast, moveAbsolute, moveContinous, moveRelative, playNextItem, processRTMPEndpoint, removeEndpoint, removeRTMPEndpoint, removeSubTrack, replaceCharsForSecurity, revokeTokens, saveBroadcast, searchOnvifDevices, sendDataChannelMessage, setAppCtx, setApplication, setAppSettings, setDataStore, setDataStoreFactory, setProcessBuilderFactory, setResultSuccess, setScope, setServerSettings, startRecord, startStreamSource, startVoDScriptProcess, stopRecord, stopStreaming, synchUserVodList, unlinksVoD, updateBroadcast, updatePlayListItemDurationsIfApplicable, updateStreamSource, uploadVoDFile, validateIPaddress, validateStreamURL, validateToken, waitStopStreaming

Methods inherited from class java.lang.Object

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

Field Details

logger

protected static org.slf4j.Logger logger

Constructor Details

ClusterNotificationService

public ClusterNotificationService()

Method Details

publishStarted

@POST
@Path("/publish-started-notification/{id}")
@Produces("application/json")
public Result publishStarted(@PathParam("id")
 String id,
 @QueryParam("role")
 String role,
 @QueryParam("mainTrackId")
 String mainTrackId)

publishStopped

@POST
@Path("/publish-stopped-notification/{id}")
@Produces("application/json")
public Result publishStopped(@PathParam("id")
 String id,
 @QueryParam("role")
 String role,
 @QueryParam("mainTrackId")
 String mainTrackId)