@ManagedResource public class RTMPMinaConnection extends RTMPConnection implements RTMPMinaConnectionMXBean
IConnection.Encoding
Modifier and Type | Field and Description |
---|---|
protected boolean |
bandwidthDetection |
protected int |
defaultClientBandwidth |
protected int |
defaultServerBandwidth |
protected static org.slf4j.Logger |
log |
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 |
---|
RTMPMinaConnection()
Constructs a new RTMPMinaConnection.
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes connection
|
boolean |
connect(IScope newScope,
Object[] params)
Connect to another scope on server with given parameters
|
int |
getDefaultClientBandwidth() |
int |
getDefaultServerBandwidth() |
org.apache.mina.core.session.IoSession |
getIoSession()
Return MINA I/O session.
|
int |
getLimitType() |
long |
getPendingMessages()
Total number of messages that are pending to be sent to the connection.
|
long |
getReadBytes()
Total number of bytes read from the connection.
|
long |
getWrittenBytes()
Total number of bytes written to the connection.
|
void |
invokeMethod(String method) |
boolean |
isBandwidthDetection() |
boolean |
isConnected()
Check whether connection is alive
|
protected void |
onInactive()
Inactive state event handler.
|
protected void |
registerJMX() |
void |
setBandwidthDetection(boolean bandwidthDetection) |
void |
setDefaultClientBandwidth(int defaultClientBandwidth) |
void |
setDefaultServerBandwidth(int defaultServerBandwidth) |
void |
setIoSession(org.apache.mina.core.session.IoSession protocolSession)
Setter for MINA I/O session (connection).
|
void |
setLimitType(int limitType) |
protected void |
unregisterJMX() |
void |
write(Packet out)
Write packet.
|
void |
writeRaw(org.apache.mina.core.buffer.IoBuffer out)
Write raw byte buffer.
|
addClientStream, closeChannel, 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, 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
getDroppedMessages, getHost, getPath, getPendingVideoMessages, getReadMessages, getRemoteAddress, getRemoteAddresses, getRemotePort, getSessionId, getType, getWrittenMessages
getAttributeNames, hasAttribute, removeAttribute, removeAttributes
connect, getBasicScopes, getClient, getConnectParams, getDroppedMessages, getHost, getPath, getReadMessages, getRemoteAddress, getRemoteAddresses, getRemotePort, getScope, getSessionId, getType, getWrittenMessages, initialize
dispatchEvent
handleEvent
notifyEvent
getBoolAttribute, getByteAttribute, getDoubleAttribute, getIntAttribute, getListAttribute, getLongAttribute, getMapAttribute, getSetAttribute, getShortAttribute, getStringAttribute
getAttribute, getAttribute, getAttributeNames, getAttributes, hasAttribute, removeAttribute, removeAttributes, setAttribute, setAttributes, setAttributes
protected static org.slf4j.Logger log
protected int defaultServerBandwidth
protected int defaultClientBandwidth
protected boolean bandwidthDetection
@ConstructorProperties(value="persistent") public RTMPMinaConnection()
public boolean connect(IScope newScope, Object[] params)
BaseConnection
connect
in interface IConnection
connect
in class RTMPConnection
newScope
- New scopeparams
- Parameters to connect withpublic void close()
close
in interface IConnection
close
in interface RTMPMinaConnectionMXBean
close
in class RTMPConnection
public org.apache.mina.core.session.IoSession getIoSession()
public int getDefaultServerBandwidth()
public void setDefaultServerBandwidth(int defaultServerBandwidth)
defaultServerBandwidth
- the defaultServerBandwidth to setpublic int getDefaultClientBandwidth()
public void setDefaultClientBandwidth(int defaultClientBandwidth)
defaultClientBandwidth
- the defaultClientBandwidth to setpublic int getLimitType()
public void setLimitType(int limitType)
limitType
- the limitType to setpublic boolean isBandwidthDetection()
public void setBandwidthDetection(boolean bandwidthDetection)
bandwidthDetection
- the bandwidthDetection to setpublic long getPendingMessages()
getPendingMessages
in interface IConnection
getPendingMessages
in interface RTMPMinaConnectionMXBean
getPendingMessages
in class BaseConnection
public long getReadBytes()
getReadBytes
in interface IConnection
getReadBytes
in interface RTMPMinaConnectionMXBean
getReadBytes
in class RTMPConnection
public long getWrittenBytes()
getWrittenBytes
in interface IConnection
getWrittenBytes
in interface RTMPMinaConnectionMXBean
getWrittenBytes
in class RTMPConnection
public void invokeMethod(String method)
invokeMethod
in interface RTMPMinaConnectionMXBean
public boolean isConnected()
isConnected
in interface IConnection
isConnected
in interface RTMPMinaConnectionMXBean
isConnected
in class BaseConnection
protected void onInactive()
onInactive
in class RTMPConnection
public void setIoSession(org.apache.mina.core.session.IoSession protocolSession)
protocolSession
- Protocol sessionpublic void write(Packet out)
write
in class RTMPConnection
out
- Packetpublic void writeRaw(org.apache.mina.core.buffer.IoBuffer out)
writeRaw
in class RTMPConnection
out
- IoBufferprotected void registerJMX()
protected void unregisterJMX()
Copyright © 2006-2012 The Red5 Project