| Package | Description |
|---|---|
| ds.funnel.data.channel | |
| ds.funnel.data.channel.tcp | |
| ds.funnel.data.channel.udp |
| Modifier and Type | Method and Description |
|---|---|
abstract ChannelManager |
ChannelAddress.connect(java.nio.channels.ByteChannel inChannel,
ChannelProtocol inProtocol)
Completes a connection made to the node.
|
abstract ChannelManager |
ChannelAddress.connect(ChannelProtocol inProtocol)
Opens a new connection to the node.
|
void |
ChannelManager.finishConnect(ChannelAddress inAddress,
ChannelProtocol inProtocol)
Finish the connection process by updating the address and protocol.
|
void |
ChannelManagerImpl.finishConnect(ChannelAddress inAddr,
ChannelProtocol inProtocol) |
abstract ChannelListener |
ChannelAddress.listen(ChannelProtocolFactory inProtocolFactory)
Starts a listener on this address.
|
void |
ChannelManager.wakeup()
Wake up reader and writer tasks.
|
void |
ChannelManagerImpl.wakeup() |
| Modifier and Type | Method and Description |
|---|---|
ChannelManager |
TCPChannelAddr.connect(java.nio.channels.ByteChannel inChannel,
ChannelProtocol inProtocol) |
ChannelManager |
TCPChannelAddr.connect(ChannelProtocol inProtocol) |
ChannelListener |
TCPChannelAddr.listen(ChannelProtocolFactory inProtocolFactory) |
| Modifier and Type | Method and Description |
|---|---|
ChannelManager |
UDPChannelAddr.connect(java.nio.channels.ByteChannel inChannel,
ChannelProtocol inProtocol) |
ChannelManager |
UDPChannelAddr.connect(ChannelProtocol inProtocol) |
ChannelListener |
UDPChannelAddr.listen(ChannelProtocolFactory inProtocolFactory) |