Package com.swiftmq.impl.net.netty
Class NetworkSwiftletImpl
java.lang.Object
NetworkSwiftlet
com.swiftmq.impl.net.netty.NetworkSwiftletImpl
public class NetworkSwiftletImpl
extends NetworkSwiftlet
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidconnectIntraVMListener(String swiftletName, IntraVMConnection connection) voidcreateIntraVMListener(IntraVMListenerMetaData metaData) voidcreateTCPConnector(ConnectorMetaData metaData) voidcreateTCPListener(ListenerMetaData metaData) longbooleanbooleanvoidvoidremoveIntraVMListener(IntraVMListenerMetaData metaData) voidremoveTCPConnector(ConnectorMetaData metaData) voidremoveTCPListener(ListenerMetaData metaData) voidsetDelayed(boolean delayed) protected voidshutdown()voidprotected voidstartup(Configuration config)
-
Field Details
-
ivmScheduler
-
ioScheduler
-
-
Constructor Details
-
NetworkSwiftletImpl
public NetworkSwiftletImpl()
-
-
Method Details
-
performTimeAction
public void performTimeAction() -
isReuseServerSocket
public boolean isReuseServerSocket() -
isDnsResolve
public boolean isDnsResolve() -
getZombiConnectionTimeout
public long getZombiConnectionTimeout() -
createTCPListener
- Throws:
Exception
-
removeTCPListener
public void removeTCPListener(ListenerMetaData metaData) -
createIntraVMListener
- Throws:
Exception
-
removeIntraVMListener
public void removeIntraVMListener(IntraVMListenerMetaData metaData) -
connectIntraVMListener
public void connectIntraVMListener(String swiftletName, IntraVMConnection connection) throws Exception - Throws:
Exception
-
createTCPConnector
- Throws:
Exception
-
removeTCPConnector
public void removeTCPConnector(ConnectorMetaData metaData) -
setDelayed
public void setDelayed(boolean delayed) -
startDelayed
- Throws:
Exception
-
startup
protected void startup(Configuration config) throws SwiftletException - Throws:
SwiftletException
-
shutdown
protected void shutdown() throws SwiftletException- Throws:
SwiftletException
-