Package org.red5.client.net.rtmpt

Class RTMPTClientConnection

  • All Implemented Interfaces:
    org.red5.server.api.event.IEventDispatcher, org.red5.server.api.event.IEventHandler, org.red5.server.api.event.IEventListener, org.red5.server.api.IAttributeStore, org.red5.server.api.ICastingAttributeStore, org.red5.server.api.IConnection, org.red5.server.api.ICoreObject, org.red5.server.api.service.IServiceCapableConnection, org.red5.server.api.stream.IStreamCapableConnection, org.red5.server.jmx.mxbeans.AttributeStoreMXBean, org.red5.server.net.rtmp.IReceivedMessageTaskQueueListener
    public class RTMPTClientConnection
extends BaseRTMPTConnection

    • Nested Class Summary

      • Nested classes/interfaces inherited from interface org.red5.server.api.IConnection

        org.red5.server.api.IConnection.Duty, org.red5.server.api.IConnection.Encoding, org.red5.server.api.IConnection.Type

    • Field Summary

      • Fields inherited from class org.red5.server.net.rtmp.RTMPConnection

        bytesReadInterval, deadlockGuardScheduler, decoderLock, decoderState, encoderLock, executor, isDebug, isTrace, limitType, MAX_RESERVED_STREAMS, maxHandlingTimeout, maxInactivity, nextBytesRead, RTMP_CONN_MANAGER, RTMP_ENCRYPTED, RTMP_ENCRYPTED_BLOWFISH, RTMP_ENCRYPTED_UNK, RTMP_ENCRYPTED_XTEA, RTMP_HANDLER, RTMP_HANDSHAKE, RTMP_NON_ENCRYPTED, RTMP_SESSION_ID, RTMPE_CIPHER_IN, RTMPE_CIPHER_OUT, running, scheduler, state

      • Fields inherited from class org.red5.server.BaseConnection

        basicScopes, client, connectionListeners, droppedMessages, duty, host, params, path, readMessages, remoteAddress, remoteAddresses, remotePort, scope, sessionId, type, writtenMessages

      • Fields inherited from class org.red5.server.AttributeStore

        attributes

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.apache.mina.core.buffer.IoBuffer getPendingMessages​(int targetSize)
      Return any pending messages up to a given size.
      protected void onInactive()  

      • Methods inherited from class org.red5.server.net.rtmp.RTMPConnection

        addClientStream, closeChannel, connect, createOutputStream, createStreamName, currentQueueSize, deleteStreamById, dispatchEvent, getChannel, getChannelIdForStreamId, getChannelsConcurrencyLevel, getChannelsInitalCapacity, getClientBytesRead, getDeadlockGuardScheduler, getDecoderLock, getDecoderState, getEncoderLock, getEncoding, getExecutor, getHandler, getId, getIoSession, getLastPingSentAndLastPongReceivedInterval, getLastPingTime, getMaxHandlingTimeout, getNextAvailableChannelId, getPendingCall, getPendingCallsConcurrencyLevel, getPendingCallsInitalCapacity, getPendingVideoMessages, getProtocol, getReservedStreamsConcurrencyLevel, getReservedStreamsInitalCapacity, getScheduler, getState, getStateCode, getStreamByChannelId, getStreamById, getStreamIdForChannelId, getStreams, getStreamsConcurrencyLevel, getStreamsInitalCapacity, getStreamsMap, getTimer, getTransactionId, getUsedStreamCount, handleMessageReceived, invoke, invoke, invoke, invoke, invoke, invoke, isChannelUsed, isDisconnected, isIdle, isValidStreamId, messageDropped, messageReceived, messageSent, messageTypeToName, newBroadcastStream, newPlaylistSubscriberStream, newSingleItemSubscriberStream, notify, notify, notify, notify, onTaskAdded, onTaskRemoved, open, ping, ping, pingReceived, receivedBytesRead, registerDeferredResult, registerPendingCall, rememberStreamBufferDuration, removeClientStream, reserveStreamId, reserveStreamId, retrievePendingCall, sendPendingServiceCallsCloseError, sendSharedObjectMessage, setBandwidth, setChannelsConcurrencyLevel, setChannelsInitalCapacity, setDeadlockGuardScheduler, setExecutor, setExecutorQueueSizeToDropAudioPackets, setId, setMaxHandlingTimeout, setMaxHandshakeTimeout, setMaxInactivity, setPendingCallsConcurrencyLevel, setPendingCallsInitalCapacity, setPingInterval, setReservedStreamsConcurrencyLevel, setReservedStreamsInitalCapacity, setScheduler, setStateCode, setStreamsConcurrencyLevel, setStreamsInitalCapacity, setup, startWaitForHandshake, status, status, toString, unregisterDeferredResult, unreserveStreamId, updateBytesRead, writingMessage

      • Methods inherited from class org.red5.server.BaseConnection

        addListener, connect, equals, getBasicScopes, getClient, getConnectParams, getDroppedMessages, getDuty, getHost, getLock, getPath, getReadMessages, getRemoteAddress, getRemoteAddresses, getRemotePort, getScope, getStreamId, getType, getWrittenMessages, handleEvent, hashCode, initialize, isClosed, isConnected, isReaderIdle, isWriterIdle, notifyEvent, registerBasicScope, registerBasicScope, removeListener, setClient, setDuty, setStreamId, unregisterBasicScope

      • Methods inherited from class org.red5.server.AttributeStore

        filterNull, from, getAttribute, getAttribute, getAttribute, getAttributeNames, getAttributes, getBoolAttribute, getByteAttribute, getDoubleAttribute, getIntAttribute, getListAttribute, getLongAttribute, getMapAttribute, getSetAttribute, getShortAttribute, getStringAttribute, hasAttribute, hasAttribute, removeAttribute, removeAttribute, removeAttributes, setAttribute, setAttribute, setAttributes, setAttributes, size

      • Methods inherited from interface org.red5.server.api.IAttributeStore

        getAttribute, getAttribute, getAttribute, getAttributeNames, getAttributes, hasAttribute, hasAttribute, removeAttribute, removeAttribute, removeAttributes, setAttribute, setAttribute, setAttributes, setAttributes, size

      • Methods inherited from interface org.red5.server.api.ICastingAttributeStore

        getBoolAttribute, getByteAttribute, getDoubleAttribute, getIntAttribute, getListAttribute, getLongAttribute, getMapAttribute, getSetAttribute, getShortAttribute, getStringAttribute

      • Methods inherited from interface org.red5.server.api.IConnection

        addListener, connect, getBasicScopes, getClient, getConnectParams, getDroppedMessages, getDuty, getHost, getPath, getReadMessages, getRemoteAddress, getRemoteAddresses, getRemotePort, getScope, getStreamId, getType, getWrittenMessages, initialize, isConnected, removeListener, setClient, setStreamId

      • Methods inherited from interface org.red5.server.api.event.IEventHandler

        handleEvent

      • Methods inherited from interface org.red5.server.api.event.IEventListener

        notifyEvent

    • Constructor Detail

      • RTMPTClientConnection

        public RTMPTClientConnection()

    • Method Detail

      • onInactive

        protected void onInactive()
        Specified by:
        onInactive in class org.red5.server.net.rtmp.RTMPConnection

      • getPendingMessages

        public org.apache.mina.core.buffer.IoBuffer getPendingMessages​(int targetSize)
        Description copied from class: BaseRTMPTConnection
        Return any pending messages up to a given size.
        Specified by:
        getPendingMessages in class BaseRTMPTConnection
        Parameters:
        targetSize - the size the resulting buffer should have
        Returns:
        a buffer containing the data to send or null if no messages are pending