Package org.ovirt.vdsm.jsonrpc.client.reactors

Class ReactorListener

java.lang.Object

org.ovirt.vdsm.jsonrpc.client.reactors.ReactorListener

public final class ReactorListener
extends Object

NioListener provides a way to react on incoming messages.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ReactorListener.EventListener

Field Summary

Fields

Modifier and Type	Field	Description
private final ServerSocketChannel	channel
private final ReactorListener.EventListener	eventListener
private static org.slf4j.Logger	log
private final Reactor	reactor
private final Selector	selector

Constructor Summary

Constructors

Constructor	Description
ReactorListener(Reactor reactor, InetSocketAddress address, Selector selector, ReactorListener.EventListener eventListener)

Method Summary

Modifier and Type	Method	Description
ReactorClient	accept()
Future<Void>	close()
int	getPort()
private ServerSocketChannel	setupChannel(InetSocketAddress address)

Methods inherited from class java.lang.Object

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

Field Details

log

private static org.slf4j.Logger log

eventListener

private final ReactorListener.EventListener eventListener

channel

private final ServerSocketChannel channel

reactor

private final Reactor reactor

selector

private final Selector selector

Constructor Details

ReactorListener

public ReactorListener(Reactor reactor,
 InetSocketAddress address,
 Selector selector,
 ReactorListener.EventListener eventListener)
                throws IOException

Throws:

IOException

Method Details

setupChannel

private ServerSocketChannel setupChannel(InetSocketAddress address)
                                  throws IOException

Throws:

IOException

getPort

public int getPort()

accept

public ReactorClient accept()

close

public Future<Void> close()