Package io.antmedia.websocket

Class WebSocketCommunityHandler

java.lang.Object
io.antmedia.websocket.WebSocketCommunityHandler
public class WebSocketCommunityHandler extends Object

  • Field Details

  • Constructor Details

    • WebSocketCommunityHandler

      public WebSocketCommunityHandler(ApplicationContext appContext, jakarta.websocket.Session session)

  • Method Details

    • onClose

      public void onClose(jakarta.websocket.Session session)

    • onError

      public void onError(jakarta.websocket.Session session, Throwable throwable)

    • onMessage

      public void onMessage(jakarta.websocket.Session session, String message)

    • startRTMPAdaptor

      private void startRTMPAdaptor(jakarta.websocket.Session session, String streamId, boolean enableVideo)

    • getNewRTMPAdaptor

      public RTMPAdaptor getNewRTMPAdaptor(String outputURL, int height)

    • addICECandidate

      public void addICECandidate(String streamId, RTMPAdaptor connectionContext, String sdpMid, String sdp, long sdpMLineIndex)

    • setRemoteDescription

      private void setRemoteDescription(RTMPAdaptor connectionContext, String typeString, String sdpDescription, String streamId)

    • sendSDPConfiguration

      public void sendSDPConfiguration(String description, String type, String streamId, jakarta.websocket.Session session, Map<String,String> midSidMap, String linkedSessionForSignaling, String subscriberId)

    • sendPublishStartedMessage

      public void sendPublishStartedMessage(String streamId, jakarta.websocket.Session session, String roomName, String subscriberId)

    • sendStreamingStartedMessage

      public void sendStreamingStartedMessage(String streamId, jakarta.websocket.Session session)

    • sendStreamIdInUse

      public void sendStreamIdInUse(String streamId, jakarta.websocket.Session session)

    • sendPongMessage

      public void sendPongMessage(jakarta.websocket.Session session)

    • sendPublishFinishedMessage

      public void sendPublishFinishedMessage(String streamId, jakarta.websocket.Session session, String subscriberId)

    • sendStartMessage

      public void sendStartMessage(String streamId, jakarta.websocket.Session session, String subscriberId)

    • sendNoStreamIdSpecifiedError

      public final void sendNoStreamIdSpecifiedError(jakarta.websocket.Session session)

    • sendTakeCandidateMessage

      public void sendTakeCandidateMessage(long sdpMLineIndex, String sdpMid, String sdp, String streamId, jakarta.websocket.Session session, String linkedSessionForSignaling, String subscriberId)

    • sendMessage

      public void sendMessage(org.json.simple.JSONObject message, jakarta.websocket.Session session)

    • sendRoomNotActiveInformation

      public void sendRoomNotActiveInformation(String roomId)

    • sendRoomInformation

      public void sendRoomInformation(Map<String,String> streamIdNameMap, String roomId)
      Parameters:
      streamIdNameMap - this is the map that keys are stream ids and values are stream names
      roomId - is the id of the room
      subscriberId -

    • prepareStreamListJSON

      private void prepareStreamListJSON(Map<String,String> streamIdNameMap, org.json.simple.JSONArray jsonStreamIdArray, org.json.simple.JSONArray jsonStreamListArray, HashMap<String,String> streamMetaDataMap)

    • sendJoinedRoomMessage

      public void sendJoinedRoomMessage(String room, String newStreamId, Map<String,String> streamIdNameMap, HashMap<String,String> streamMetaDataMap)

    • getTakeCandidateJSON

      public static org.json.simple.JSONObject getTakeCandidateJSON(long sdpMLineIndex, String sdpMid, String sdp, String streamId, String linkedSessionForSignaling, String subscriberId)

    • getSDPConfigurationJSON

      public static org.json.simple.JSONObject getSDPConfigurationJSON(String description, String type, String streamId, Map<String,String> midSidMap, String linkedSessionForSignaling, String subscriberId)

    • sendInvalidStreamNameError

      public void sendInvalidStreamNameError(String streamId, jakarta.websocket.Session session)

    • getAppContext

      public ApplicationContext getAppContext()

    • setAppContext

      public void setAppContext(ApplicationContext appContext)

    • setAppAdaptor

      public void setAppAdaptor(AntMediaApplicationAdapter appAdaptor)

    • sendRemoteDescriptionSetFailure

      public void sendRemoteDescriptionSetFailure(jakarta.websocket.Session session, String streamId, String subscriberId)

    • sendLocalDescriptionSetFailure

      public void sendLocalDescriptionSetFailure(jakarta.websocket.Session session, String streamId, String subscriberId)

    • sendNotFoundJSON

      public void sendNotFoundJSON(String streamId, String reason, jakarta.websocket.Session session)

    • sendNotFoundJSON

      public void sendNotFoundJSON(String streamId, jakarta.websocket.Session session)

    • sendStreamingStartsSoonMessage

      public void sendStreamingStartsSoonMessage(String streamId, jakarta.websocket.Session session)

    • sendServerError

      public void sendServerError(String streamId, jakarta.websocket.Session session)

    • setSession

      public void setSession(jakarta.websocket.Session session)

    • getUserAgent

      public String getUserAgent()

    • setUserAgent

      public void setUserAgent(String userAgent)

    • getClientIP

      public String getClientIP()

    • setClientIP

      public void setClientIP(String clientIP)