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
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
connectIntraVMListener
(String swiftletName, IntraVMConnection connection) void
createIntraVMListener
(IntraVMListenerMetaData metaData) void
createTCPConnector
(ConnectorMetaData metaData) void
createTCPListener
(ListenerMetaData metaData) long
boolean
boolean
void
void
removeIntraVMListener
(IntraVMListenerMetaData metaData) void
removeTCPConnector
(ConnectorMetaData metaData) void
removeTCPListener
(ListenerMetaData metaData) void
setDelayed
(boolean delayed) protected void
shutdown()
void
protected void
startup
(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
-