public abstract class BaseRTMPTConnection extends RTMPConnection
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
Constructor and Description |
---|
BaseRTMPTConnection(String type) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes connection
|
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()
Total number of messages that are pending to be sent to the connection.
|
abstract org.apache.mina.core.buffer.IoBuffer |
getPendingMessages(int targetSize)
Return any pending messages up to a given size.
|
long |
getReadBytes()
Total number of bytes read from the connection.
|
long |
getWrittenBytes()
Total number of bytes written to the connection.
|
boolean |
isClosing()
Getter for property 'closing'.
|
void |
realClose()
Real close
|
void |
setDecoder(RTMPProtocolDecoder decoder) |
void |
setEncoder(RTMPProtocolEncoder encoder) |
void |
setHandler(IRTMPHandler handler) |
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.
|
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, onInactive, 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
public BaseRTMPTConnection(String type)
public abstract org.apache.mina.core.buffer.IoBuffer getPendingMessages(int targetSize)
targetSize
- the size the resulting buffer should havepublic void close()
close
in interface IConnection
close
in class RTMPConnection
public boolean isClosing()
public void realClose()
public void writeRaw(org.apache.mina.core.buffer.IoBuffer packet)
writeRaw
in class RTMPConnection
packet
- the buffer containing the raw datapublic long getReadBytes()
getReadBytes
in interface IConnection
getReadBytes
in class RTMPConnection
public long getWrittenBytes()
getWrittenBytes
in interface IConnection
getWrittenBytes
in class RTMPConnection
public long getPendingMessages()
getPendingMessages
in interface IConnection
getPendingMessages
in class BaseConnection
public List<?> decode(org.apache.mina.core.buffer.IoBuffer data)
data
- the data to decodepublic void write(Packet packet)
write
in class RTMPConnection
packet
- the packet to sendprotected org.apache.mina.core.buffer.IoBuffer foldPendingMessages(int targetSize)
public void setHandler(IRTMPHandler handler)
public void setDecoder(RTMPProtocolDecoder decoder)
public void setEncoder(RTMPProtocolEncoder encoder)
Copyright © 2006-2012 The Red5 Project