Package io.antmedia

Class AntMediaApplicationAdapter

java.lang.Object
org.red5.server.adapter.AbstractScopeAdapter
org.red5.server.adapter.StatefulScopeWrappingAdapter
org.red5.server.adapter.MultiThreadedApplicationAdapter
io.antmedia.AntMediaApplicationAdapter
All Implemented Interfaces:
IAntMediaStreamHandler, IShutdownListener, IEventHandler, IAttributeStore, ISchedulingService, IScopeAware, IScopeHandler, IScopeService, IBroadcastStreamService, IOnDemandStreamService, IStreamSecurityService, ISubscriberStreamService, IStreamAwareScopeHandler, ApplicationMXBean, AttributeStoreMXBean
public class AntMediaApplicationAdapter extends MultiThreadedApplicationAdapter implements IAntMediaStreamHandler, IShutdownListener

  • Field Details

    • STREAM_TIMEOUT_MS

      public static final int STREAM_TIMEOUT_MS
      Timeout value that stream is considered as finished or stuck
      See Also:

    • BEAN_NAME

      public static final String BEAN_NAME
      See Also:

    • BROADCAST_STATS_RESET

      public static final int BROADCAST_STATS_RESET
      See Also:

    • HOOK_ACTION_END_LIVE_STREAM

      public static final String HOOK_ACTION_END_LIVE_STREAM
      See Also:

    • HOOK_ACTION_START_LIVE_STREAM

      public static final String HOOK_ACTION_START_LIVE_STREAM
      See Also:

    • HOOK_ACTION_STREAM_STATUS

      public static final String HOOK_ACTION_STREAM_STATUS
      See Also:

    • HOOK_ACTION_VOD_READY

      public static final String HOOK_ACTION_VOD_READY
      See Also:

    • HOOK_ACTION_PUBLISH_TIMEOUT_ERROR

      public static final String HOOK_ACTION_PUBLISH_TIMEOUT_ERROR
      See Also:

    • HOOK_ACTION_ENCODER_NOT_OPENED_ERROR

      public static final String HOOK_ACTION_ENCODER_NOT_OPENED_ERROR
      See Also:

    • HOOK_ACTION_ENDPOINT_FAILED

      public static final String HOOK_ACTION_ENDPOINT_FAILED
      See Also:

    • HOOK_IDLE_TIME_EXPIRED

      public static final String HOOK_IDLE_TIME_EXPIRED
      See Also:

    • HOOK_ACTION_PLAY_STOPPED

      public static final String HOOK_ACTION_PLAY_STOPPED
      This is used to notify that the play is stopped
      See Also:

    • HOOK_ACTION_PLAY_STARTED

      public static final String HOOK_ACTION_PLAY_STARTED
      This is used to notify that the play is started
      See Also:

    • HOOK_ACTION_SUBTRACK_ADDED_IN_THE_MAINTRACK

      public static final String HOOK_ACTION_SUBTRACK_ADDED_IN_THE_MAINTRACK
      This is used to notify that the subtrack is created in the main track In video conferencing, it means a stream is started in the room
      See Also:

    • HOOK_ACTION_SUBTRACK_LEFT_FROM_THE_MAINTRACK

      public static final String HOOK_ACTION_SUBTRACK_LEFT_FROM_THE_MAINTRACK
      This is used to notify that the subtrack left the main track In video conferencing, it means a stream left the room
      See Also:

    • HOOK_ACTION_FIRST_ACTIVE_SUBTRACK_ADDED_IN_THE_MAINTRACK

      public static final String HOOK_ACTION_FIRST_ACTIVE_SUBTRACK_ADDED_IN_THE_MAINTRACK
      This is used to notify that the first active subtrack is created in the main track In video conferencing, it means the first stream is started in the room
      See Also:

    • HOOK_ACTION_NO_ACTIVE_SUBTRACKS_LEFT_IN_THE_MAINTRACK

      public static final String HOOK_ACTION_NO_ACTIVE_SUBTRACKS_LEFT_IN_THE_MAINTRACK
      This is used to notify that there is no active subtracks left in the main track. In video conferencing, it means there is no active stream left in the room
      See Also:

    • STREAMS

      public static final String STREAMS
      See Also:

    • DEFAULT_LOCALHOST

      public static final String DEFAULT_LOCALHOST
      See Also:

    • logger

      protected static org.slf4j.Logger logger

    • serverSettings

      private ServerSettings serverSettings

    • VOD

      public static final String VOD
      See Also:

    • LIVE_STREAM

      public static final String LIVE_STREAM
      See Also:

    • IP_CAMERA

      public static final String IP_CAMERA
      See Also:

    • STREAM_SOURCE

      public static final String STREAM_SOURCE
      See Also:

    • PLAY_LIST

      public static final String PLAY_LIST
      See Also:

    • END_POINT_LIMIT

      protected static final int END_POINT_LIMIT
      See Also:

    • CLUSTER_POST_RETRY_ATTEMPT_COUNT

      public static final int CLUSTER_POST_RETRY_ATTEMPT_COUNT
      See Also:

    • CLUSTER_POST_TIMEOUT_MS

      public static final int CLUSTER_POST_TIMEOUT_MS
      See Also:

    • VOD_IMPORT_ALLOWED_DIRECTORY

      private static final String VOD_IMPORT_ALLOWED_DIRECTORY
      See Also:

    • streamPublishSecurityList

      private List<IStreamPublishSecurity> streamPublishSecurityList

    • streamPlaySecurityList

      private List<IStreamPlaybackSecurity> streamPlaySecurityList

    • onvifCameraList

      private Map<String,OnvifCamera> onvifCameraList

    • streamFetcherManager

      protected StreamFetcherManager streamFetcherManager

    • muxAdaptors

      protected Map<String,MuxAdaptor> muxAdaptors

    • dataStore

      private DataStore dataStore

    • dataStoreFactory

      private DataStoreFactory dataStoreFactory

    • streamAcceptFilter

      private StreamAcceptFilter streamAcceptFilter

    • appSettings

      private AppSettings appSettings

    • vertx

      private io.vertx.core.Vertx vertx

    • encoderBlockedStreams

      protected List<String> encoderBlockedStreams

    • numberOfEncoderNotOpenedErrors

      private int numberOfEncoderNotOpenedErrors

    • publishTimeoutStreams

      protected int publishTimeoutStreams

    • publishTimeoutStreamsList

      private List<String> publishTimeoutStreamsList

    • shutdownProperly

      private boolean shutdownProperly

    • webRTCVideoReceiveStats

      protected WebRTCVideoReceiveStats webRTCVideoReceiveStats

    • webRTCAudioReceiveStats

      protected WebRTCAudioReceiveStats webRTCAudioReceiveStats

    • webRTCVideoSendStats

      protected WebRTCVideoSendStats webRTCVideoSendStats

    • webRTCAudioSendStats

      protected WebRTCAudioSendStats webRTCAudioSendStats

    • clusterNotifier

      private IClusterNotifier clusterNotifier

    • serverShuttingDown

      protected boolean serverShuttingDown

    • storageClient

      protected StorageClient storageClient

    • streamListeners

      protected Queue<IStreamListener> streamListeners

    • playListSchedulerTimer

      protected Map<String,Long> playListSchedulerTimer

    • clusterStreamFetcher

      IClusterStreamFetcher clusterStreamFetcher

    • subtrackPoller

      protected ISubtrackPoller subtrackPoller

    • random

      private Random random

    • statsCollector

      private IStatsCollector statsCollector

    • settingsUpdateListenerSet

      private Set<IAppSettingsUpdateListener> settingsUpdateListenerSet

    • rtmpClusterStreamFetcherMap

      private Map<String,RTMPClusterStreamFetcher> rtmpClusterStreamFetcherMap

    • mainTrackUpdateLocks

      private final com.github.benmanes.caffeine.cache.LoadingCache<String,Object> mainTrackUpdateLocks

  • Constructor Details

    • AntMediaApplicationAdapter

      public AntMediaApplicationAdapter()

  • Method Details

    • appStart

      public boolean appStart(IScope app)
      Description copied from class: MultiThreadedApplicationAdapter
      Called once on scope (that is, application or application room) start. You override MultiThreadedApplicationAdapter.appStart(IScope) or MultiThreadedApplicationAdapter.roomStart(IScope) in your application to make it act the way you want.
      Specified by:
      appStart in interface ApplicationMXBean
      Overrides:
      appStart in class MultiThreadedApplicationAdapter
      Parameters:
      app - Application scope object
      Returns:
      true if scope can be started, false otherwise

    • schedulePlayList

      public void schedulePlayList(long now, Broadcast broadcast)

    • cancelPlaylistSchedule

      public void cancelPlaylistSchedule(String streamId)

    • resetBroadcasts

      public Result resetBroadcasts()
      This method is called after ungraceful shutdown
      Returns:

    • createSymbolicLink

      private Result createSymbolicLink(File streamsFolder, File vodFolder)

    • importVoDFolder

      public Result importVoDFolder(String vodFolderPath)
      Import vod files recursively in the directory. It also created symbolic link to make the files streamable
      Parameters:
      vodFolderPath - absolute path of the vod folder to be imported
      Returns:

    • unlinksVoD

      public Result unlinksVoD(String directory)

    • deleteUserVoDByStreamId

      private int deleteUserVoDByStreamId(String streamId)

    • importToDB

      public int importToDB(File subDirectory, File baseDirectory)

    • deleteSymbolicLink

      private boolean deleteSymbolicLink(File vodDirectory, File streamsFolder)
      Deletes the symbolic link under the streams directory
      Parameters:
      vodDirectory -
      streamsFolder -
      Returns:
      Throws:
      IOException

    • getListenerHookURL

      public String getListenerHookURL(Broadcast broadcast)

    • notifyLiveStreamEnded

      public void notifyLiveStreamEnded(Broadcast broadcast, String subscriberId)

    • closeBroadcast

      public void closeBroadcast(String streamId, String subscriberId, Map<String,String> parameters)
      This method is used to close the broadcast stream
      Parameters:
      streamId -
      subscriberId -
      parameters -

    • runStreamEndedScript

      private void runStreamEndedScript(Broadcast broadcast)

    • saveMainBroadcast

      public static Broadcast saveMainBroadcast(String streamId, String mainTrackId, DataStore dataStore)

    • isInstanceAlive

      public static boolean isInstanceAlive(String originAdress, String hostAddress, int httpPort, String appName)

    • isEndpointReachable

      public static boolean isEndpointReachable(String endpoint)

    • updateMainTrackWithRecentlyFinishedBroadcast

      public void updateMainTrackWithRecentlyFinishedBroadcast(Broadcast finishedBroadcast)
      If multiple threads enter the method at the same time, the following method does not work correctly. So we had made it synchronized, then changed it. We make it synchronized for the same main track (room) IDs. Otherwise, one room was waiting for the others. It fixes the bug that sometimes main track(room) is not deleted in the video conferences mekya
      Parameters:
      finishedBroadcast -

    • resetHLSStats

      public void resetHLSStats(String streamId)

    • resetDASHStats

      public void resetDASHStats(String streamId)

    • streamPlayItemPlay

      public void streamPlayItemPlay(ISubscriberStream stream, IPlayItem item, boolean isLive)
      Description copied from interface: IStreamAwareScopeHandler
      Notified when a play item plays.
      Specified by:
      streamPlayItemPlay in interface IStreamAwareScopeHandler
      Overrides:
      streamPlayItemPlay in class MultiThreadedApplicationAdapter
      Parameters:
      stream - stream
      item - item
      isLive - true if live

    • streamPlayItemStop

      public void streamPlayItemStop(ISubscriberStream stream, IPlayItem item)
      Description copied from interface: IStreamAwareScopeHandler
      Notified when a play item stops.
      Specified by:
      streamPlayItemStop in interface IStreamAwareScopeHandler
      Overrides:
      streamPlayItemStop in class MultiThreadedApplicationAdapter
      Parameters:
      stream - stream
      item - item

    • streamSubscriberClose

      public void streamSubscriberClose(ISubscriberStream stream)
      Description copied from interface: IStreamAwareScopeHandler
      Notified when a subscriber closes.
      Specified by:
      streamSubscriberClose in interface IStreamAwareScopeHandler
      Overrides:
      streamSubscriberClose in class MultiThreadedApplicationAdapter
      Parameters:
      stream - stream

    • startPublish

      public void startPublish(String streamId, long absoluteStartTimeMs, String publishType, String subscriberId, Map<String,String> parameters)
      Description copied from interface: IAntMediaStreamHandler
      Notify the handler that stream is started to publish
      Specified by:
      startPublish in interface IAntMediaStreamHandler
      subscriberId - : It's the id of the subscriber. It can be null if it's not available.

    • logPublishStartedEvent

      private void logPublishStartedEvent(String streamId, String publishType, String subscriberId)

    • updateBroadcastStatus

      public Broadcast updateBroadcastStatus(String streamId, long absoluteStartTimeMs, String publishType, Broadcast broadcast)
      Description copied from interface: IAntMediaStreamHandler
      Update broadcast status to BROADCASTING
      Specified by:
      updateBroadcastStatus in interface IAntMediaStreamHandler
      Parameters:
      streamId - is the id of the stream.
      absoluteStartTimeMs - : It's the absolute start time if available
      publishType - : It's RTMP, WebRTC, StreamSource
      broadcast - : It's the broadcast object. If it's null, a new record will be created
      Returns:
      broadcast object from database

    • isBroadcastOnThisServer

      public boolean isBroadcastOnThisServer(Broadcast broadcast)

    • updateBroadcastStatus

      public Broadcast updateBroadcastStatus(String streamId, long absoluteStartTimeMs, String publishType, Broadcast broadcast, BroadcastUpdate broadcastUpdate, String status)
      Parameters:
      streamId -
      absoluteStartTimeMs -
      publishType -
      broadcast - : if it's null, it will be created
      broadcastUpdate - : if it's null, it will be created with getBroadcastUpdateForStatus(publishType, status). It's used to update some specific fields
      status - :
      Returns:

    • getFreshBroadcastUpdateForStatus

      public BroadcastUpdate getFreshBroadcastUpdateForStatus(String publishType, String status)
      It creates a broadcast update object for a broadcast that is about to start
      Parameters:
      publishType -
      status -
      Returns:

    • getServerSettings

      public ServerSettings getServerSettings()

    • createZombiBroadcast

      public static Broadcast createZombiBroadcast(String streamId, String streamName, String streamStatus, String publishType, String mainTrackStreamId, String metaData, String role)

    • saveUndefinedBroadcast

      public static Broadcast saveUndefinedBroadcast(String streamId, String streamName, AntMediaApplicationAdapter appAdapter, String streamStatus, long absoluteStartTimeMs, String publishType, String mainTrackStreamId, String metaData, String role)

    • saveBroadcast

      public static Broadcast saveBroadcast(Broadcast broadcast, AntMediaApplicationAdapter appAdapter)

    • muxingFinished

      public void muxingFinished(Broadcast broadcast, String streamId, File file, long startTime, long duration, int resolution, String previewFilePath, String vodId)
      Description copied from interface: IAntMediaStreamHandler
      Called by some muxer like MP4Muxer id actually is the name of the file however in some cases file name and the id may be different in some cases like there is already a file with that name
      Specified by:
      muxingFinished in interface IAntMediaStreamHandler
      Parameters:
      broadcast - object that muxed is finished
      streamId - is the id of the stream
      file - video file that muxed is finished
      duration - of the video in milliseconds
      resolution - height of the video
      previewFilePath - path of the preview file

    • notifyFirstActiveSubtrackInMainTrack

      public void notifyFirstActiveSubtrackInMainTrack(Broadcast mainTrack, String subtrackId)

    • notifyNoActiveSubtracksLeftInMainTrack

      public void notifyNoActiveSubtracksLeftInMainTrack(Broadcast mainTrack)

    • runConfiguredScript

      private void runConfiguredScript(String configuredScript, String... args)

    • getRelativePath

      public static String getRelativePath(String filePath)

    • sendWebHook

      public void sendWebHook(String id, String mainTrackId, String action, String streamName, String category, String vodName, String vodId, String metadata, String subscriberId, Map<String,String> parameters)

    • notifyHook

      public void notifyHook(@NotNull @NotNull String url, String id, String mainTrackId, String action, String streamName, String category, String vodName, String vodId, String metadata, String subscriberId, Map<String,String> parameters)
      Notify hook with parameters below
      Parameters:
      streamName - , name of the stream. It is not the name of the file. It is just a user friendly name
      category - , category of the stream
      url - is the url of the service to be called
      id - is the stream id that is unique for each stream
      mainTrackId - mainTrackId(roomId) of the stream
      action - is the name of the action to be notified, it has values such as HOOK_ACTION_END_LIVE_STREAM HOOK_ACTION_START_LIVE_STREAM
      vodName - name of the vod
      vodId - id of the vod in the datastore
      parameters -

    • notifyWebhookForStreamStatus

      public void notifyWebhookForStreamStatus(Broadcast broadcast, int width, int height, long totalByteReceived, int inputQueueSize, int encodingQueueSize, int dropFrameCountInEncoding, int dropPacketCountInIngestion, double speed)
      Description copied from interface: IAntMediaStreamHandler
      Notify the webhook about the stream status
      Specified by:
      notifyWebhookForStreamStatus in interface IAntMediaStreamHandler

    • putToMap

      private void putToMap(String keyName, Object keyValue, Map<String,Object> map)

    • sendClusterPost

      public boolean sendClusterPost(String url, String clusterCommunicationToken, byte[] data)

    • callClusterRestMethod

      public boolean callClusterRestMethod(String url, String clusterCommunicationToken, byte[] data)

    • trySendClusterPostWithDelay

      public void trySendClusterPostWithDelay(String url, String clusterCommunicationToken, int retryAttempts, CompletableFuture<Boolean> future, byte[] data)

    • sendPOST

      public void sendPOST(String url, Map<String,Object> variables, int retryAttempts, String contentType)
      Parameters:
      url -
      variables -
      retryAttempts -
      sendType - the type of the entity to be sent. It can be either "application/x-www-form-urlencoded" or "application/json"

    • retrySendPostWithDelay

      public void retrySendPostWithDelay(String url, Map<String,Object> variables, int retryAttempts, String contentType)

    • getHttpClient

      public org.apache.http.impl.client.CloseableHttpClient getHttpClient()

    • getStreamPublishSecurityList

      public List<IStreamPublishSecurity> getStreamPublishSecurityList()

    • setStreamPublishSecurityList

      public void setStreamPublishSecurityList(List<IStreamPublishSecurity> streamPublishSecurityList)

    • setStreamPlaySecurityList

      public void setStreamPlaySecurityList(List<IStreamPlaybackSecurity> streamPlaySecurityList)

    • getStreamPlaySecurityList

      public List<IStreamPlaybackSecurity> getStreamPlaySecurityList()

    • getAppSettings

      public AppSettings getAppSettings()
      Description copied from interface: IAntMediaStreamHandler
      Get the AppSettings of the application
      Specified by:
      getAppSettings in interface IAntMediaStreamHandler
      Returns:
      AppSettings

    • setAppSettings

      public void setAppSettings(AppSettings appSettings)

    • getStreamAcceptFilter

      public StreamAcceptFilter getStreamAcceptFilter()

    • setStreamAcceptFilter

      public void setStreamAcceptFilter(StreamAcceptFilter streamAcceptFilter)

    • isValidStreamParameters

      public boolean isValidStreamParameters(int width, int height, int fps, int bitrate, String streamId)
      Description copied from interface: IAntMediaStreamHandler
      Checks a Stream parameters is valid.
      Specified by:
      isValidStreamParameters in interface IAntMediaStreamHandler

    • isStreaming

      public static final boolean isStreaming(String status)
      Important information: Status field of Broadcast class checks the update time to report the status is broadcasting or not. Broadcast.getStatus()

    • startStreaming

      public Result startStreaming(Broadcast broadcast)

    • forwardStartStreaming

      public void forwardStartStreaming(Broadcast broadcast)

    • stopStreaming

      public Result stopStreaming(Broadcast broadcast, boolean stopSubtracks, String subscriberId)

    • isSubscriberBlocked

      public static boolean isSubscriberBlocked(DataStore dataStore, String streamId, String subscriberId, String type)

    • isSubscriberIdMatching

      public static boolean isSubscriberIdMatching(String subscriberId, String subscriberIdParameter)

    • createIdleCheckTimer

      private void createIdleCheckTimer(Broadcast broadcast, boolean isMainTrack)

    • notifyBroadcastIdleTimeExpired

      private void notifyBroadcastIdleTimeExpired(Broadcast broadcast)

    • getOnvifCamera

      public OnvifCamera getOnvifCamera(String id)

    • getStreamFetcherManager

      public StreamFetcherManager getStreamFetcherManager()

    • setStreamFetcherManager

      public void setStreamFetcherManager(StreamFetcherManager streamFetcherManager)

    • setQualityParameters

      public void setQualityParameters(String streamId, PublishStatsEvent stats, long currentTimeMillis)
      Description copied from interface: IAntMediaStreamHandler
      Sets quality parameters for the given stream ID. This method is called to update quality-related parameters for the specified stream during the publishing process.
      Specified by:
      setQualityParameters in interface IAntMediaStreamHandler
      Parameters:
      streamId - The unique identifier of the stream.
      stats - The current publishing statistics for the stream.
      currentTimeMillis - The current timestamp in milliseconds.

    • getDataStore

      public DataStore getDataStore()
      Description copied from interface: IAntMediaStreamHandler
      Get the DataStore of the application
      Specified by:
      getDataStore in interface IAntMediaStreamHandler
      Returns:
      DataStore

    • setDataStore

      public void setDataStore(DataStore dataStore)

    • getDataStoreFactory

      public DataStoreFactory getDataStoreFactory()

    • setDataStoreFactory

      public void setDataStoreFactory(DataStoreFactory dataStoreFactory)

    • setVertx

      public void setVertx(io.vertx.core.Vertx vertx)
      This setter for test cases
      Parameters:
      vertx -

    • fetchRtmpFromOriginIfExist

      public boolean fetchRtmpFromOriginIfExist(String streamId)

    • closeRTMPStreams

      public void closeRTMPStreams()

    • closeStreamFetchers

      public void closeStreamFetchers()

    • waitUntilLiveStreamsStopped

      public void waitUntilLiveStreamsStopped()

    • waitUntilThreadsStop

      public void waitUntilThreadsStop()

    • getActiveVertxThreadCount

      private int getActiveVertxThreadCount()

    • serverShuttingdown

      public void serverShuttingdown()
      Specified by:
      serverShuttingdown in interface IShutdownListener

    • appStop

      public void appStop(IScope app)
      Description copied from class: MultiThreadedApplicationAdapter
      Handler method. Called when application is stopped.
      Specified by:
      appStop in interface ApplicationMXBean
      Overrides:
      appStop in class MultiThreadedApplicationAdapter
      Parameters:
      app - Scope object

    • stopApplication

      public void stopApplication(boolean deleteDB)

    • closeDB

      public void closeDB(boolean deleteDB)

    • createInitializationProcess

      public Result createInitializationProcess(String appName)

    • createInitializationFile

      public void createInitializationFile(String appName, Result result, File initializedFile) throws IOException
      Throws:
      IOException

    • createShutdownFile

      public void createShutdownFile(String appName)

    • isShutdownProperly

      public boolean isShutdownProperly()

    • setShutdownProperly

      public void setShutdownProperly(boolean shutdownProperly)

    • muxAdaptorAdded

      public void muxAdaptorAdded(MuxAdaptor muxAdaptor)
      Description copied from interface: IAntMediaStreamHandler
      Adds a MuxAdaptor when a muxAdaptor is created
      Specified by:
      muxAdaptorAdded in interface IAntMediaStreamHandler

    • muxAdaptorRemoved

      public void muxAdaptorRemoved(MuxAdaptor muxAdaptor)
      Description copied from interface: IAntMediaStreamHandler
      Removes a MuxAdaptor when a muxAdaptor is closingResources
      Specified by:
      muxAdaptorRemoved in interface IAntMediaStreamHandler

    • getMuxAdaptor

      public MuxAdaptor getMuxAdaptor(String streamId)
      Description copied from interface: IAntMediaStreamHandler
      Get the MuxAdaptor of the stream. MuxAdaptor is the base class that is responsible for ingesting and distributing the stream
      Specified by:
      getMuxAdaptor in interface IAntMediaStreamHandler
      Returns:

    • getMuxAdaptors

      public Collection<MuxAdaptor> getMuxAdaptors()

    • getNumberOfEncodersBlocked

      public int getNumberOfEncodersBlocked()
      Number of encoders blocked.
      Returns:

    • encoderBlocked

      public void encoderBlocked(String streamId, boolean blocked)

    • incrementEncoderNotOpenedError

      public void incrementEncoderNotOpenedError(String streamId)

    • getNumberOfEncoderNotOpenedErrors

      public int getNumberOfEncoderNotOpenedErrors()

    • getNumberOfPublishTimeoutError

      public int getNumberOfPublishTimeoutError()

    • publishTimeoutError

      public void publishTimeoutError(String streamId, String subscriberId)

    • getWebRTCAudioReceiveStats

      public WebRTCAudioReceiveStats getWebRTCAudioReceiveStats()

    • getWebRTCVideoReceiveStats

      public WebRTCVideoReceiveStats getWebRTCVideoReceiveStats()

    • getWebRTCAudioSendStats

      public WebRTCAudioSendStats getWebRTCAudioSendStats()

    • getWebRTCVideoSendStats

      public WebRTCVideoSendStats getWebRTCVideoSendStats()

    • getVertx

      public io.vertx.core.Vertx getVertx()

    • updateSettings

      public boolean updateSettings(AppSettings newSettings, boolean notifyCluster, boolean checkUpdateTime)

    • notifySettingsUpdateListeners

      public void notifySettingsUpdateListeners(AppSettings appSettings)

    • addSettingsUpdateListener

      public void addSettingsUpdateListener(IAppSettingsUpdateListener listener)
      Description copied from interface: IAntMediaStreamHandler
      Add listener that is notified when the settings are updated
      Specified by:
      addSettingsUpdateListener in interface IAntMediaStreamHandler

    • isEncoderSettingsValid

      private boolean isEncoderSettingsValid(List<EncoderSettings> encoderSettingsList)

    • isTokenSecuritySettingsValid

      private boolean isTokenSecuritySettingsValid(AppSettings newSettings)

    • isIncomingSettingsDifferent

      public boolean isIncomingSettingsDifferent(AppSettings newSettings)
      Parameters:
      newSettings -
      checkUpdateTime -
      Returns:
      true if time are not equal, it means new settings is different than the current settings

    • setClusterNotifier

      public void setClusterNotifier(IClusterNotifier clusterNotifier)

    • updateAppSettingsFile

      public static boolean updateAppSettingsFile(String appName, AppSettings newAppsettings)

    • updateAppSettingsBean

      public void updateAppSettingsBean(AppSettings appSettings, AppSettings newSettings, boolean updateTime)

    • setStorageclientSettings

      public void setStorageclientSettings(AppSettings settings)

    • setAppSettingsFieldValue

      public static boolean setAppSettingsFieldValue(AppSettings appSettings, AppSettings newSettings, Field field)

    • setServerSettings

      public void setServerSettings(ServerSettings serverSettings)

    • isDataChannelEnabled

      public boolean isDataChannelEnabled()

    • isDataChannelMessagingSupported

      public boolean isDataChannelMessagingSupported()

    • sendDataChannelMessage

      public boolean sendDataChannelMessage(String streamId, String message)

    • doesWebRTCStreamExist

      public boolean doesWebRTCStreamExist(String streamId)

    • addPacketListener

      public boolean addPacketListener(String streamId, IPacketListener listener)
      Description copied from interface: IAntMediaStreamHandler
      Add listener to get audio and video packets from the internal of Ant Media Server. 'Packet' is the encoded data of audio/video 'Frame'.
      Specified by:
      addPacketListener in interface IAntMediaStreamHandler
      Returns:

    • endpointFailedUpdate

      public void endpointFailedUpdate(String streamId, String url)

    • removePacketListener

      public boolean removePacketListener(String streamId, IPacketListener listener)
      Description copied from interface: IAntMediaStreamHandler
      Remove listener from the Stream Handler to stop getting notified
      Specified by:
      removePacketListener in interface IAntMediaStreamHandler
      Returns:

    • addFrameListener

      public void addFrameListener(String streamId, IFrameListener listener)
      Description copied from interface: IAntMediaStreamHandler
      Add listener to get raw audio or video frames from the internal of Ant Media Server. The methods are called if the audio/video frames are decoded due to settings such adaptive bitrate etc.. This method does not force the Ant Media Server to decode the streams. 'Frame' is the decoded data of audio/video 'Packet'
      Specified by:
      addFrameListener in interface IAntMediaStreamHandler

    • createCustomBroadcast

      public IFrameListener createCustomBroadcast(String streamId)
      Description copied from interface: IAntMediaStreamHandler
      Create another broadcast. It's useful to create another manipulated version of the original broadcast in the plugins. The returning frame listener should be feed with raw audio and video frames
      Specified by:
      createCustomBroadcast in interface IAntMediaStreamHandler
      Returns:

    • createCustomBroadcast

      public IFrameListener createCustomBroadcast(String streamId, int height, int bitrate)
      Description copied from interface: IAntMediaStreamHandler
      Create another broadcast. It's useful to create another manipulated version of the original broadcast in the plugins. The returning frame listener should be feed with raw audio and video frames
      Specified by:
      createCustomBroadcast in interface IAntMediaStreamHandler
      Returns:

    • stopCustomBroadcast

      public void stopCustomBroadcast(String streamId)
      Description copied from interface: IAntMediaStreamHandler
      Stop the custom broadcast that is being created. Stop encoders and make database operations.
      Specified by:
      stopCustomBroadcast in interface IAntMediaStreamHandler

    • removeFrameListener

      public void removeFrameListener(String streamId, IFrameListener listener)
      Description copied from interface: IAntMediaStreamHandler
      Remove frame listener from the Stream Handler to stop getting notified
      Specified by:
      removeFrameListener in interface IAntMediaStreamHandler

    • isServerShuttingDown

      public boolean isServerShuttingDown()
      Specified by:
      isServerShuttingDown in interface IAntMediaStreamHandler
      Returns:
      true if server is shutting down

    • setStorageClient

      public void setStorageClient(StorageClient storageClient)

    • getStorageClient

      public StorageClient getStorageClient()

    • addStreamListener

      public void addStreamListener(IStreamListener listener)
      Description copied from interface: IAntMediaStreamHandler
      Add a stream listener to get notified when a new stream is started or finished. IStreamListener interface has callbacks for conference attendees. It's very useful to use in plugins.
      Specified by:
      addStreamListener in interface IAntMediaStreamHandler

    • removeStreamListener

      public void removeStreamListener(IStreamListener listener)
      Description copied from interface: IAntMediaStreamHandler
      Remove a stream listener from the Stream Handler to stop getting notified
      Specified by:
      removeStreamListener in interface IAntMediaStreamHandler

    • startHttpSignaling

      public CompletableFuture<Result> startHttpSignaling(PublishParameters publishParameters, String sdp, String sessionId)

    • stopWhipBroadcast

      public Result stopWhipBroadcast(String streamId, String sessionId)

    • stopPlayingBySubscriberId

      public boolean stopPlayingBySubscriberId(String subscriberId, String streamId)

    • stopPublishingBySubscriberId

      public boolean stopPublishingBySubscriberId(String subscriberId, String streamId)

    • stopPublish

      public void stopPublish(String streamId, String subscriberId)
      Description copied from interface: IAntMediaStreamHandler
      Notify the handler that is stream is stopped
      Specified by:
      stopPublish in interface IAntMediaStreamHandler
      subscriberId - : It's the id of the subscriber. It can be null if it's not available.

    • stopPublish

      public void stopPublish(String streamId, String subscriberId, Map<String,String> publishParameters)
      Description copied from interface: IAntMediaStreamHandler
      Notify the handler that is stream is stopped
      Specified by:
      stopPublish in interface IAntMediaStreamHandler
      subscriberId - : It's the id of the subscriber. It can be null if it's not available.
      publishParameters - : It's the parameters of the publish. It can be null if it's not available.

    • isClusterMode

      public boolean isClusterMode()

    • joinedTheRoom

      public void joinedTheRoom(String roomId, String streamId)

    • leftTheRoom

      public void leftTheRoom(String mainTrackId, String subtrackId)

    • createClusterStreamFetcher

      public IClusterStreamFetcher createClusterStreamFetcher()

    • getWebRTCClientsMap

      public Map<String,Queue<IWebRTCClient>> getWebRTCClientsMap()

    • getSubtrackPoller

      public ISubtrackPoller getSubtrackPoller()

    • setSubtrackPoller

      public void setSubtrackPoller(ISubtrackPoller subtrackPoller)

    • getPlayListSchedulerTimer

      public Map<String,Long> getPlayListSchedulerTimer()

    • getStatsCollector

      public IStatsCollector getStatsCollector()

    • setStatsCollector

      public void setStatsCollector(IStatsCollector statsCollector)

    • publishStarted

      public boolean publishStarted(String streamId, String role, String mainTrackId)
      This is a callback-method and called when a stream is fully started and it means it is called post publish operations has finished It can be called from the cluster side or from the local side to synch subtracks

    • publishStopped

      public boolean publishStopped(String streamId, String role, String mainTrackId)
      This method is called when a stream is fully stopped and it means it is called post publish operations has finished It can be called from the cluster side or from the local side to synch subtracks

    • notifyPublishStarted

      public void notifyPublishStarted(String streamId, String role, String mainTrackId)
      This method is called to notify the local node and cluster nodes when a stream is started

    • notifyPublishStopped

      public void notifyPublishStopped(String streamId, String role, String mainTrackId)

    • getDataChannelRouter

      public IDataChannelRouter getDataChannelRouter()
      Description copied from interface: IAntMediaStreamHandler
      Get data channel router for data channel delivery
      Specified by:
      getDataChannelRouter in interface IAntMediaStreamHandler
      Returns:

    • registerSubscriberToNode

      public void registerSubscriberToNode(String streamId, String subscriberId, String subscriberName)