Class IOScheduler

java.lang.Object

com.swiftmq.impl.net.netty.scheduler.IOScheduler

Direct Known Subclasses:

NettyIOScheduler

public abstract class IOScheduler
extends Object

Constructor Summary

Constructors

Constructor	Description
IOScheduler(SwiftletContext ctx)

Method Summary

Modifier and Type	Method	Description
void	close()
int	createConnector(com.swiftmq.swiftlet.net.ConnectorMetaData metaData)
protected abstract TCPConnector	createConnectorInstance(com.swiftmq.swiftlet.net.ConnectorMetaData metaData, com.swiftmq.net.SocketFactory socketFactory)
int	createListener(com.swiftmq.swiftlet.net.ListenerMetaData metaData)
protected abstract TCPListener	createListenerInstance(com.swiftmq.swiftlet.net.ListenerMetaData metaData, com.swiftmq.net.SocketFactory socketFactory)
TCPConnector	getConnector(int connectorId)
TCPListener	getListener(int listenerId)
void	removeConnector(int connectorId)
void	removeListener(int listenerId)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

IOScheduler

public IOScheduler(SwiftletContext ctx)

Method Details

createListener

public int createListener(com.swiftmq.swiftlet.net.ListenerMetaData metaData)
                   throws Exception

Throws:

Exception

getListener

public TCPListener getListener(int listenerId)

createListenerInstance

protected abstract TCPListener createListenerInstance(com.swiftmq.swiftlet.net.ListenerMetaData metaData,
 com.swiftmq.net.SocketFactory socketFactory)
                                               throws Exception

Throws:

Exception

removeListener

public void removeListener(int listenerId)

createConnector

public int createConnector(com.swiftmq.swiftlet.net.ConnectorMetaData metaData)
                    throws Exception

Throws:

Exception

getConnector

public TCPConnector getConnector(int connectorId)

createConnectorInstance

protected abstract TCPConnector createConnectorInstance(com.swiftmq.swiftlet.net.ConnectorMetaData metaData,
 com.swiftmq.net.SocketFactory socketFactory)
                                                 throws Exception

Throws:

Exception

removeConnector

public void removeConnector(int connectorId)

close

public void close()