Package org.omegazero.net.nio.client

Class PlainTCPClientManager

java.lang.Object

org.omegazero.net.nio.util.SelectorHandler

org.omegazero.net.nio.util.ConnectionSelectorHandler

org.omegazero.net.nio.client.TCPClientManager

org.omegazero.net.nio.client.PlainTCPClientManager

All Implemented Interfaces:

Runnable, NetClientManager, NetworkApplication

public class PlainTCPClientManager
extends TCPClientManager

TCPClientManager implementation for plaintext TCP sockets.

API Note:

Before version 2.1.0, this class was in package org.omegazero.net.client.

Field Summary

Fields inherited from class org.omegazero.net.nio.client.TCPClientManager

workerCreator

Constructor Summary

Constructors

Constructor	Description
PlainTCPClientManager(Function<SocketConnection,Consumer<Runnable>> worker)

Method Summary

Modifier and Type	Method	Description
protected ChannelConnection	createConnection(SelectionKey selectionKey, ConnectionParameters params)
protected void	handleConnect(ChannelConnection conn)	Called when a connection was established.

Methods inherited from class org.omegazero.net.nio.client.TCPClientManager

close, connection, handleSelectedKey, init, loopIteration, start

Methods inherited from class org.omegazero.net.nio.util.ConnectionSelectorHandler

handleConnectionClosed, onConnectionClosed

Methods inherited from class org.omegazero.net.nio.util.SelectorHandler

closeSelector, initSelector, isRunning, registerChannel, registerChannel, runSelectorLoop, selectorKeys, selectorWakeup

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.omegazero.net.common.NetworkApplication

run

Constructor Details

PlainTCPClientManager

public PlainTCPClientManager(Function<SocketConnection,Consumer<Runnable>> worker)

Method Details

createConnection

protected ChannelConnection createConnection(SelectionKey selectionKey,
 ConnectionParameters params)
                                      throws IOException

Specified by:

createConnection in class TCPClientManager

Throws:

IOException

handleConnect

protected void handleConnect(ChannelConnection conn)

Description copied from class: TCPClientManager

Called when a connection was established.

Specified by:

handleConnect in class TCPClientManager

Parameters:

conn - The ChannelConnection object representing the connection that was established