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

Class ReactorListener

java.lang.Object

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

public final class ReactorListener
extends java.lang.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 java.nio.channels.ServerSocketChannel	channel
private ReactorListener.EventListener	eventListener
private static org.slf4j.Logger	log
private Reactor	reactor
private java.nio.channels.Selector	selector

Constructor Summary

Constructors

Constructor	Description
ReactorListener(Reactor reactor, java.net.InetSocketAddress address, java.nio.channels.Selector selector, ReactorListener.EventListener eventListener)

Method Summary

Modifier and Type	Method	Description
ReactorClient	accept()
java.util.concurrent.Future<java.lang.Void>	close()
int	getPort()
private java.nio.channels.ServerSocketChannel	setupChannel(java.net.InetSocketAddress address)

Methods inherited from class java.lang.Object

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

Field Detail

log

private static org.slf4j.Logger log

eventListener

private final ReactorListener.EventListener eventListener

channel

private final java.nio.channels.ServerSocketChannel channel

reactor

private final Reactor reactor

selector

private final java.nio.channels.Selector selector

Constructor Detail

ReactorListener

public ReactorListener(Reactor reactor,
                       java.net.InetSocketAddress address,
                       java.nio.channels.Selector selector,
                       ReactorListener.EventListener eventListener)
                throws java.io.IOException

Throws:

java.io.IOException

Method Detail

setupChannel

private java.nio.channels.ServerSocketChannel setupChannel(java.net.InetSocketAddress address)
                                                    throws java.io.IOException

Throws:

java.io.IOException

getPort

public int getPort()

accept

public ReactorClient accept()

close

public java.util.concurrent.Future<java.lang.Void> close()