Package org.red5.client.net.rtmpt

Class BaseRTMPTConnection

java.lang.Object

org.red5.server.AttributeStore

org.red5.server.BaseConnection

org.red5.server.net.rtmp.RTMPConnection

org.red5.client.net.rtmpt.BaseRTMPTConnection

All Implemented Interfaces:

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

Direct Known Subclasses:

RTMPTClientConnection

public abstract class BaseRTMPTConnection
extends RTMPConnection

Nested Class Summary

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

IConnection.Duty, IConnection.Encoding, IConnection.Type

Field Summary

Fields

Modifier and Type	Field	Description
protected String	clientSessionId	Clients session id, used to override the BaseConnection.sessionId for client implementations.

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
BaseRTMPTConnection(String type)

Method Summary

Modifier and Type	Method	Description
void	close()
List<?>	decode(org.apache.mina.core.buffer.IoBuffer data)	Decode data sent by the client.
protected org.apache.mina.core.buffer.IoBuffer	foldPendingMessages(int targetSize)
long	getPendingMessages()
abstract org.apache.mina.core.buffer.IoBuffer	getPendingMessages(int targetSize)	Return any pending messages up to a given size.
long	getReadBytes()
String	getSessionId()
long	getWrittenBytes()
boolean	isClosing()	Getter for property 'closing'.
void	realClose()	Real close
void	setDecoder(RTMPProtocolDecoder decoder)
void	setEncoder(RTMPProtocolEncoder encoder)
void	setHandler(IRTMPHandler handler)
void	setSessionId(String sessionId)
void	write(Packet packet)	Send RTMP packet down the connection.
void	writeRaw(org.apache.mina.core.buffer.IoBuffer packet)	Send raw data down the connection.

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, onInactive, 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

Field Details

clientSessionId

protected String clientSessionId

Clients session id, used to override the BaseConnection.sessionId for client implementations.

Constructor Details

BaseRTMPTConnection

public BaseRTMPTConnection(String type)

Method Details

getPendingMessages

public abstract org.apache.mina.core.buffer.IoBuffer getPendingMessages(int targetSize)

Return any pending messages up to a given size.

Parameters:

targetSize - the size the resulting buffer should have

Returns:

a buffer containing the data to send or null if no messages are pending

close

public void close()

Specified by:

close in interface IConnection

Overrides:

close in class RTMPConnection

isClosing

public boolean isClosing()

Getter for property 'closing'.

Returns:

Value for property 'closing'.

realClose

public void realClose()

Real close

writeRaw

public void writeRaw(org.apache.mina.core.buffer.IoBuffer packet)

Send raw data down the connection.

Specified by:

writeRaw in class RTMPConnection

Parameters:

packet - the buffer containing the raw data

getReadBytes

public long getReadBytes()

Specified by:

getReadBytes in interface IConnection

Overrides:

getReadBytes in class RTMPConnection

getWrittenBytes

public long getWrittenBytes()

Specified by:

getWrittenBytes in interface IConnection

Overrides:

getWrittenBytes in class RTMPConnection

getPendingMessages

public long getPendingMessages()

Specified by:

getPendingMessages in interface IConnection

Overrides:

getPendingMessages in class BaseConnection

setSessionId

public void setSessionId(String sessionId)

getSessionId

public String getSessionId()

Specified by:

getSessionId in interface IConnection

Overrides:

getSessionId in class BaseConnection

decode

public List<?> decode(org.apache.mina.core.buffer.IoBuffer data)

Decode data sent by the client.

Parameters:

data - the data to decode

Returns:

a list of decoded objects

write

public void write(Packet packet)

Send RTMP packet down the connection.

Specified by:

write in class RTMPConnection

Parameters:

packet - the packet to send

foldPendingMessages

protected org.apache.mina.core.buffer.IoBuffer foldPendingMessages(int targetSize)

setHandler

public void setHandler(IRTMPHandler handler)

Overrides:

setHandler in class RTMPConnection

setDecoder

public void setDecoder(RTMPProtocolDecoder decoder)

setEncoder

public void setEncoder(RTMPProtocolEncoder encoder)