ds.granules.communication.direct.nio.client

Class NIOChannelConnector

java.lang.Object

ds.granules.communication.direct.nio.client.NIOChannelConnector

All Implemented Interfaces:

ChannelConnector, Runnable

public class NIOChannelConnector
extends Object
implements Runnable, ChannelConnector

Author:

Thilina Buddhika

Constructor Summary

Constructors

Constructor and Description
NIOChannelConnector(int reactorCount)

Method Summary

Methods

Modifier and Type	Method and Description
ChannelWriter	addNewConnection(String serverHost, int serverPort)
void	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

NIOChannelConnector

public NIOChannelConnector(int reactorCount)
                    throws IOException

Throws:

IOException

Method Detail

run

public void run()

Specified by:

run in interface Runnable

addNewConnection

public ChannelWriter addNewConnection(String serverHost,
                             int serverPort)
                               throws CommunicationsException

Specified by:

addNewConnection in interface ChannelConnector

Throws:

CommunicationsException