public class RTMPTConnection extends BaseRTMPTConnection
IConnection.EncodingbytesReadInterval, clientId, limitType, nextBytesRead, RTMP_CONNECTION_KEY, RTMP_ENCRYPTED, RTMP_HANDSHAKE, RTMP_NON_ENCRYPTED, RTMPE_CIPHER_IN, RTMPE_CIPHER_OUT, statebasicScopes, client, closed, droppedMessages, host, params, path, readMessages, remoteAddress, remoteAddresses, remotePort, scope, sessionId, type, writtenMessagesattributesPERSISTENT, POLLING, TRANSIENT| Modifier and Type | Method and Description |
|---|---|
IoBuffer |
getPendingMessages(int targetSize)
Return any pending messages up to a given size.
|
byte |
getPollingDelay()
Return the polling delay to use.
|
protected void |
onInactive()
Inactive state event handler.
|
void |
realClose()
Real close
|
protected void |
setServlet(RTMPTServlet servlet)
Set the servlet that created the connection.
|
void |
setServletRequest(javax.servlet.http.HttpServletRequest request)
Setter for servlet request.
|
close, decode, foldPendingMessages, getPendingMessages, getReadBytes, getWrittenBytes, isClosing, setDecoder, setEncoder, setHandler, write, writeRawaddClientStream, closeChannel, connect, createOutputStream, createStreamName, deleteStreamById, equals, getChannel, getClientBytesRead, getEncoding, getId, getInvokeId, getLastPingTime, getNextAvailableChannelId, getPendingCall, getPendingVideoMessages, getState, getStateCode, getStreamByChannelId, getStreamById, getStreamIdForChannel, getStreams, getUsedStreamCount, hashCode, invoke, invoke, invoke, invoke, invoke, invoke, isChannelUsed, isValidStreamId, messageDropped, messageReceived, messageSent, newBroadcastStream, newPlaylistSubscriberStream, newSingleItemSubscriberStream, notify, notify, notify, notify, ping, ping, pingReceived, receivedBytesRead, registerDeferredResult, registerPendingCall, rememberStreamBufferDuration, removeClientStream, reserveStreamId, reserveStreamId, retrievePendingCall, sendPendingServiceCallsCloseError, setBandwidth, setId, setMaxHandshakeTimeout, setMaxInactivity, setPingInterval, setSchedulingService, setState, setStateCode, setup, startRoundTripMeasurement, startWaitForHandshake, toString, unregisterDeferredResult, unreserveStreamId, updateBytesRead, writingMessageconnect, dispatchEvent, getBasicScopes, getClient, getConnectParams, getDroppedMessages, getHost, getLock, getNextClientId, getPath, getReadMessages, getRemoteAddress, getRemoteAddresses, getRemotePort, getScope, getSessionId, getType, getWrittenMessages, handleEvent, initialize, isConnected, notifyEvent, registerBasicScope, unregisterBasicScopefilterNull, from, getAttribute, getAttribute, getAttributeNames, getAttributes, getBoolAttribute, getByteAttribute, getDoubleAttribute, getIntAttribute, getListAttribute, getLongAttribute, getMapAttribute, getSetAttribute, getShortAttribute, getStringAttribute, hasAttribute, removeAttribute, removeAttributes, setAttribute, setAttributes, setAttributesclone, finalize, getClass, notify, notifyAll, wait, wait, waitconnect, getBasicScopes, getClient, getConnectParams, getDroppedMessages, getHost, getPath, getReadMessages, getRemoteAddress, getRemoteAddresses, getRemotePort, getScope, getSessionId, getType, getWrittenMessages, initialize, isConnecteddispatchEventhandleEventnotifyEventgetBoolAttribute, getByteAttribute, getDoubleAttribute, getIntAttribute, getListAttribute, getLongAttribute, getMapAttribute, getSetAttribute, getShortAttribute, getStringAttributegetAttribute, getAttribute, getAttributeNames, getAttributes, hasAttribute, removeAttribute, removeAttributes, setAttribute, setAttributes, setAttributesprotected void setServlet(RTMPTServlet servlet)
servlet - public void realClose()
realClose in class BaseRTMPTConnectionprotected void onInactive()
onInactive in class RTMPConnectionpublic void setServletRequest(javax.servlet.http.HttpServletRequest request)
request - Servlet requestpublic byte getPollingDelay()
public IoBuffer getPendingMessages(int targetSize)
getPendingMessages in class BaseRTMPTConnectiontargetSize - the size the resulting buffer should haveCopyright © 2006-2012 The Red5 Project