public class RTMPTConnection extends BaseRTMPTConnection
IConnection.Encoding
bytesReadInterval, clientId, limitType, nextBytesRead, RTMP_CONNECTION_KEY, RTMP_ENCRYPTED, RTMP_HANDSHAKE, RTMP_NON_ENCRYPTED, RTMPE_CIPHER_IN, RTMPE_CIPHER_OUT, state
basicScopes, client, closed, droppedMessages, host, params, path, readMessages, remoteAddress, remoteAddresses, remotePort, scope, sessionId, type, writtenMessages
attributes
PERSISTENT, POLLING, TRANSIENT
Modifier and Type | Method and Description |
---|---|
org.apache.mina.core.buffer.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, writeRaw
addClientStream, 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, writingMessage
connect, dispatchEvent, getBasicScopes, getClient, getConnectParams, getDroppedMessages, getHost, getLock, getNextClientId, getPath, getReadMessages, getRemoteAddress, getRemoteAddresses, getRemotePort, getScope, getSessionId, getType, getWrittenMessages, handleEvent, initialize, isConnected, notifyEvent, registerBasicScope, unregisterBasicScope
filterNull, from, getAttribute, getAttribute, getAttributeNames, getAttributes, getBoolAttribute, getByteAttribute, getDoubleAttribute, getIntAttribute, getListAttribute, getLongAttribute, getMapAttribute, getSetAttribute, getShortAttribute, getStringAttribute, hasAttribute, removeAttribute, removeAttributes, setAttribute, setAttributes, setAttributes
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
connect, getBasicScopes, getClient, getConnectParams, getDroppedMessages, getHost, getPath, getReadMessages, getRemoteAddress, getRemoteAddresses, getRemotePort, getScope, getSessionId, getType, getWrittenMessages, initialize, isConnected
dispatchEvent
handleEvent
notifyEvent
getBoolAttribute, getByteAttribute, getDoubleAttribute, getIntAttribute, getListAttribute, getLongAttribute, getMapAttribute, getSetAttribute, getShortAttribute, getStringAttribute
getAttribute, getAttribute, getAttributeNames, getAttributes, hasAttribute, removeAttribute, removeAttributes, setAttribute, setAttributes, setAttributes
protected void setServlet(RTMPTServlet servlet)
servlet
- public void realClose()
realClose
in class BaseRTMPTConnection
protected void onInactive()
onInactive
in class RTMPConnection
public void setServletRequest(javax.servlet.http.HttpServletRequest request)
request
- Servlet requestpublic byte getPollingDelay()
public org.apache.mina.core.buffer.IoBuffer getPendingMessages(int targetSize)
getPendingMessages
in class BaseRTMPTConnection
targetSize
- the size the resulting buffer should haveCopyright © 2006-2012 The Red5 Project