org.red5.server.net.rtmp
Class RTMPOriginConnection
java.lang.Object
org.red5.server.AttributeStore
org.red5.server.BaseConnection
org.red5.server.net.rtmp.RTMPConnection
org.red5.server.net.rtmp.RTMPOriginConnection
- All Implemented Interfaces:
- AttributeStoreMBean, ConnectionMBean, IEventDispatcher, IEventHandler, IEventListener, IAttributeStore, ICastingAttributeStore, IConnection, ICoreObject, IServiceCapableConnection, IStreamCapableConnection
public class RTMPOriginConnection
- extends RTMPConnection
A pseudo-connection on Origin that represents a client
on Edge.
The connection is created behind a MRTMP connection so
no handshake job or keep-alive job is necessary. No raw byte
data write is needed either.
- Version:
- $Id$
- Author:
- Steven Gong (steven.gong@gmail.com)
Fields inherited from class org.red5.server.BaseConnection |
basicScopes, client, closed, droppedMessages, host, params, path, readMessages, remoteAddress, remoteAddresses, remotePort, scope, sessionId, type, writtenMessages |
Methods inherited from class org.red5.server.net.rtmp.RTMPConnection |
addClientStream, closeChannel, connect, createOutputStream, createStreamName, deleteStreamById, getChannel, getClientBytesRead, getEncoding, getId, getInvokeId, getLastPingTime, getNextAvailableChannelId, getPendingCall, getPendingVideoMessages, getReadBytes, getStateCode, getStreamByChannelId, getStreamById, getStreamIdForChannel, getStreams, getUsedStreamCount, getWrittenBytes, invoke, invoke, invoke, invoke, invoke, invoke, isChannelUsed, messageDropped, messageReceived, messageSent, newBroadcastStream, newPlaylistSubscriberStream, newSingleItemSubscriberStream, notify, notify, notify, notify, ping, ping, pingReceived, receivedBytesRead, registerDeferredResult, registerPendingCall, rememberStreamBufferDuration, removeClientStream, reserveStreamId, retrievePendingCall, setId, setMaxHandshakeTimeout, setMaxInactivity, setPingInterval, setSchedulingService, setState, setStateCode, setup, toString, unregisterDeferredResult, unreserveStreamId, updateBytesRead, writingMessage |
Methods inherited from class org.red5.server.BaseConnection |
connect, dispatchEvent, getBasicScopes, getClient, getConnectParams, getDroppedMessages, getHost, getPath, getPendingMessages, getReadLock, getReadMessages, getRemoteAddress, getRemoteAddresses, getRemotePort, getScope, getSessionId, getType, getWriteLock, getWrittenMessages, handleEvent, initialize, isConnected, notifyEvent, registerBasicScope, unregisterBasicScope |
Methods inherited from class org.red5.server.AttributeStore |
filterNull, getAttribute, getAttribute, getAttributeNames, getAttributes, getBoolAttribute, getByteAttribute, getDoubleAttribute, getIntAttribute, getListAttribute, getLongAttribute, getMapAttribute, getSetAttribute, getShortAttribute, getStringAttribute, hasAttribute, removeAttribute, removeAttributes, setAttribute, setAttributes, setAttributes |
Methods inherited from interface org.red5.server.api.IConnection |
connect, getBasicScopes, getClient, getConnectParams, getDroppedMessages, getHost, getPath, getPendingMessages, getReadMessages, getRemoteAddress, getRemoteAddresses, getRemotePort, getScope, getSessionId, getType, getWrittenMessages, initialize, isConnected |
RTMPOriginConnection
public RTMPOriginConnection(String type,
int clientId)
RTMPOriginConnection
public RTMPOriginConnection(String type,
int clientId,
int ioSessionId)
getIoSessionId
public int getIoSessionId()
setMrtmpManager
public void setMrtmpManager(IMRTMPOriginManager mrtmpManager)
setHandler
public void setHandler(OriginMRTMPHandler handler)
getState
public RTMP getState()
- Overrides:
getState
in class RTMPConnection
onInactive
protected void onInactive()
- Description copied from class:
RTMPConnection
- Inactive state event handler.
- Specified by:
onInactive
in class RTMPConnection
rawWrite
public void rawWrite(IoBuffer out)
- Description copied from class:
RTMPConnection
- Write raw byte buffer.
- Specified by:
rawWrite
in class RTMPConnection
- Parameters:
out
- IoBuffer
write
public void write(Packet packet)
- Description copied from class:
RTMPConnection
- Write packet.
- Specified by:
write
in class RTMPConnection
- Parameters:
packet
- Packet
startRoundTripMeasurement
public void startRoundTripMeasurement()
- Description copied from class:
RTMPConnection
- Starts measurement.
- Overrides:
startRoundTripMeasurement
in class RTMPConnection
startWaitForHandshake
protected void startWaitForHandshake(ISchedulingService service)
- Description copied from class:
RTMPConnection
- Start waiting for a valid handshake.
- Overrides:
startWaitForHandshake
in class RTMPConnection
- Parameters:
service
- The scheduling service to use
close
public void close()
- Description copied from class:
RTMPConnection
- Closes connection
- Specified by:
close
in interface ConnectionMBean
- Specified by:
close
in interface IConnection
- Overrides:
close
in class RTMPConnection
realClose
public void realClose()
Copyright © 2006-2010 The Red5 Project