org.red5.server.net.rtmp
Class RTMPMinaTransport
java.lang.Object
org.red5.server.net.rtmp.RTMPMinaTransport
- All Implemented Interfaces:
- RTMPMinaTransportMXBean
public class RTMPMinaTransport
- extends Object
- implements RTMPMinaTransportMXBean
Transport setup class configures socket acceptor and thread pools for RTMP in Mina.
Note: This code originates from AsyncWeb. Originally modified by Luke Hubbard.
- Author:
- Luke Hubbard, Paul Gregoire
acceptor
protected SocketAcceptor acceptor
addresses
protected Set<SocketAddress> addresses
ioHandler
protected IoHandlerAdapter ioHandler
stats
protected IoServiceStatistics stats
ioThreads
protected int ioThreads
serviceManagerObjectName
protected ObjectName serviceManagerObjectName
- MBean object name used for de/registration purposes.
enableMinaMonitor
protected boolean enableMinaMonitor
minaPollInterval
protected int minaPollInterval
tcpNoDelay
protected boolean tcpNoDelay
useHeapBuffers
protected boolean useHeapBuffers
RTMPMinaTransport
public RTMPMinaTransport()
start
public void start()
throws Exception
- Specified by:
start
in interface RTMPMinaTransportMXBean
- Throws:
Exception
stop
public void stop()
- Specified by:
stop
in interface RTMPMinaTransportMXBean
setConnector
public void setConnector(InetSocketAddress connector)
setConnectors
public void setConnectors(List<InetSocketAddress> connectors)
setIoHandler
public void setIoHandler(IoHandlerAdapter rtmpIOHandler)
setIoThreads
public void setIoThreads(int ioThreads)
- Specified by:
setIoThreads
in interface RTMPMinaTransportMXBean
setTcpNoDelay
public void setTcpNoDelay(boolean tcpNoDelay)
- Specified by:
setTcpNoDelay
in interface RTMPMinaTransportMXBean
setUseHeapBuffers
public void setUseHeapBuffers(boolean useHeapBuffers)
- Specified by:
setUseHeapBuffers
in interface RTMPMinaTransportMXBean
setEnableMinaMonitor
public void setEnableMinaMonitor(boolean enableMinaMonitor)
- Parameters:
enableMinaMonitor
- the enableMinaMonitor to set
setMinaPollInterval
public void setMinaPollInterval(int minaPollInterval)
toString
public String toString()
- Overrides:
toString
in class Object
Copyright © 2006-2012 The Red5 Project