Package org.red5.server.net.rtmp

Class RTMPMinaIoHandler

java.lang.Object
org.apache.mina.core.service.IoHandlerAdapter
org.red5.server.net.rtmp.RTMPMinaIoHandler
All Implemented Interfaces:
org.apache.mina.core.service.IoHandler
Direct Known Subclasses:
RTMPSMinaIoHandler
public class RTMPMinaIoHandler extends org.apache.mina.core.service.IoHandlerAdapter
Handles all RTMP protocol events fired by the MINA framework.

  • Field Details

    • log

      private static org.slf4j.Logger log

    • handler

      protected IRTMPHandler handler
      RTMP events handler

  • Constructor Details

    • RTMPMinaIoHandler

      public RTMPMinaIoHandler()

  • Method Details

    • sessionCreated

      public void sessionCreated(org.apache.mina.core.session.IoSession session) throws Exception
      Specified by:
      sessionCreated in interface org.apache.mina.core.service.IoHandler
      Overrides:
      sessionCreated in class org.apache.mina.core.service.IoHandlerAdapter
      Throws:
      Exception

    • sessionOpened

      public void sessionOpened(org.apache.mina.core.session.IoSession session) throws Exception
      Specified by:
      sessionOpened in interface org.apache.mina.core.service.IoHandler
      Overrides:
      sessionOpened in class org.apache.mina.core.service.IoHandlerAdapter
      Throws:
      Exception

    • sessionClosed

      public void sessionClosed(org.apache.mina.core.session.IoSession session) throws Exception
      Specified by:
      sessionClosed in interface org.apache.mina.core.service.IoHandler
      Overrides:
      sessionClosed in class org.apache.mina.core.service.IoHandlerAdapter
      Throws:
      Exception

    • messageReceived

      public void messageReceived(org.apache.mina.core.session.IoSession session, Object message) throws Exception
      Specified by:
      messageReceived in interface org.apache.mina.core.service.IoHandler
      Overrides:
      messageReceived in class org.apache.mina.core.service.IoHandlerAdapter
      Throws:
      Exception

    • messageSent

      public void messageSent(org.apache.mina.core.session.IoSession session, Object message) throws Exception
      Specified by:
      messageSent in interface org.apache.mina.core.service.IoHandler
      Overrides:
      messageSent in class org.apache.mina.core.service.IoHandlerAdapter
      Throws:
      Exception

    • exceptionCaught

      public void exceptionCaught(org.apache.mina.core.session.IoSession session, Throwable cause) throws Exception
      Specified by:
      exceptionCaught in interface org.apache.mina.core.service.IoHandler
      Overrides:
      exceptionCaught in class org.apache.mina.core.service.IoHandlerAdapter
      Throws:
      Exception

    • forceClose

      private void forceClose(org.apache.mina.core.session.IoSession session)
      Force the NioSession to be released and cleaned up.
      Parameters:
      session -

    • cleanSession

      private void cleanSession(org.apache.mina.core.session.IoSession session, boolean immediately)
      Close and clean-up the IoSession.
      Parameters:
      session -
      immediately - close without waiting for the write queue to flush

    • setHandler

      public void setHandler(IRTMPHandler handler)
      Setter for handler.
      Parameters:
      handler - RTMP events handler

    • setCodecFactory

      @Deprecated public void setCodecFactory(org.apache.mina.filter.codec.ProtocolCodecFactory codecFactory)
      Deprecated.
      Parameters:
      codecFactory - the codecFactory to set

    • createRTMPMinaConnection

      protected RTMPMinaConnection createRTMPMinaConnection()