@Override
    public void messageReceived(IoSession session, Object message) throws Exception {
        log.debug("messageReceived");
        if (message instanceof Packet && message != null) {
            String sessionId = (String) session.getAttribute(RTMPConnection.RTMP_SESSION_ID);
            log.trace("Session id: {}", sessionId);
            RTMPMinaConnection conn = (RTMPMinaConnection) getConnectionManager(session).getConnectionBySessionId(sessionId);
            Red5.setConnectionLocal(conn);
            conn.handleMessageReceived((Packet) message);
            Red5.setConnectionLocal(null);
        } else {
            log.debug("Not packet type: {}", message);
        }
    }
@ Override public void messageReceived ( IoSession session , Object message ) throws Exception { log . debug ( "messageReceived" ) ; if ( message instanceof Packet && message != null ) { String sessionId = ( String ) session . getAttribute ( RTMPConnection . RTMP_SESSION_ID ) ; log . trace ( "Session id: {}" , sessionId ) ; RTMPMinaConnection conn = ( RTMPMinaConnection ) getConnectionManager ( session ) . getConnectionBySessionId ( sessionId ) ; Red5 . setConnectionLocal ( conn ) ; conn . handleMessageReceived ( ( Packet ) message ) ; Red5 . setConnectionLocal ( null ) ; } else { log . debug ( "Not packet type: {}" , message ) ; } }
{@inheritDoc}