Package org.red5.client.net.rtmpt

Class RTMPTClientConnection

java.lang.Object

org.red5.server.AttributeStore

org.red5.server.BaseConnection

org.red5.server.net.rtmp.RTMPConnection

org.red5.client.net.rtmpt.BaseRTMPTConnection

org.red5.client.net.rtmpt.RTMPTClientConnection

All Implemented Interfaces:

IEventDispatcher, IEventHandler, IEventListener, IAttributeStore, ICastingAttributeStore, IConnection, ICoreObject, IServiceCapableConnection, IStreamCapableConnection, AttributeStoreMXBean

public class RTMPTClientConnection
extends BaseRTMPTConnection

Nested Class Summary

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

IConnection.Duty, IConnection.Encoding, IConnection.Type

Field Summary

Fields inherited from class org.red5.client.net.rtmpt.BaseRTMPTConnection

clientSessionId

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

bytesReadInterval, channels, clientBytesRead, decoderLock, decoderState, deferredResults, encoderLock, executor, keepAliveTask, lastPingRoundTripTime, lastPingSentOn, lastPongReceivedOn, limitType, MAX_RESERVED_STREAMS, maxHandlingTimeout, maxInactivity, nextBytesRead, packetSequence, pendingCalls, pendingVideos, pingInterval, receivedPacketExecutor, receivedPacketFuture, receivedPacketQueue, receivedQueueSize, reservedStreams, RTMP_BUFFER, 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, streams, timer, transactionId, waitForHandshakeTask

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, isDebug, isTrace

Constructor Summary

Constructors

Constructor	Description
RTMPTClientConnection()

Method Summary

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.client.net.rtmpt.BaseRTMPTConnection

close, decode, foldPendingMessages, getPendingMessages, getReadBytes, getSessionId, getWrittenBytes, isClosing, realClose, setDecoder, setEncoder, setHandler, setSessionId, write, writeRaw

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, getIoSession, getLastPingSentAndLastPongReceivedInterval, getLastPingTime, getMaxHandlingTimeout, getMaxPollTimeout, 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, isConnected, isDisconnected, isEncrypted, isIdle, isValidStreamId, messageDropped, messageReceived, messageSent, messageTypeToName, newBroadcastStream, newPlaylistSubscriberStream, newSingleItemSubscriberStream, notify, notify, notify, notify, open, ping, ping, pingReceived, receivedBytesRead, registerDeferredResult, registerPendingCall, rememberStreamBufferDuration, removeClientStream, reserveStreamId, reserveStreamId, retrievePendingCall, sendPendingServiceCallsCloseError, sendSharedObjectMessage, setBandwidth, setChannelsConcurrencyLevel, setChannelsInitalCapacity, setDeadlockGuardScheduler, setEncrypted, setExecutor, setExecutorQueueSizeToDropAudioPackets, setMaxHandlingTimeout, setMaxHandshakeTimeout, setMaxInactivity, setMaxPollTimeout, 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, disconnect, equals, getBasicScopes, getClient, getConnectParams, getDroppedMessages, getDuty, getHost, getId, getLock, getPath, getReadMessages, getRemoteAddress, getRemoteAddresses, getRemotePort, getScope, getStreamId, getType, getWrittenMessages, handleEvent, hashCode, initialize, isClosed, isReaderIdle, isWriterIdle, notifyEvent, notifyPropertyChanged, registerBasicScope, registerBasicScope, removeListener, setClient, setDuty, setId, setStreamId, uninitialize, 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 class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

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, notifyPropertyChanged, removeListener, setClient, setStreamId, uninitialize

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

handleEvent

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

notifyEvent

Constructor Details

RTMPTClientConnection

public RTMPTClientConnection()

Method Details

onInactive

protected void onInactive()

Specified by:

onInactive in class 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