org.bitcoinj.net

Class NioServer

java.lang.Object

com.google.common.util.concurrent.AbstractExecutionThreadService

org.bitcoinj.net.NioServer

All Implemented Interfaces:

Service

public class NioServer
extends AbstractExecutionThreadService

Creates a simple server listener which listens for incoming client connections and uses a StreamParser to process data.

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

Service.Listener, Service.State

Constructor Summary

Constructors

Constructor and Description
NioServer(StreamParserFactory parserFactory, InetSocketAddress bindAddress) Creates a new server which is capable of listening for incoming connections and processing client provided data using StreamParsers created by the given StreamParserFactory

Method Summary

Modifier and Type	Method and Description
protected void	run()
void	triggerShutdown() Invoked by the Execution service when it's time to stop.

Methods inherited from class com.google.common.util.concurrent.AbstractExecutionThreadService

addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, executor, failureCause, isRunning, serviceName, shutDown, start, startAndWait, startAsync, startUp, state, stop, stopAndWait, stopAsync, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

NioServer

public NioServer(StreamParserFactory parserFactory,
                 InetSocketAddress bindAddress)
          throws IOException

Creates a new server which is capable of listening for incoming connections and processing client provided data using StreamParsers created by the given StreamParserFactory

Throws:

IOException - If there is an issue opening the server socket or binding fails for some reason

Method Detail

run

protected void run()
            throws Exception

Specified by:

run in class AbstractExecutionThreadService

Throws:

Exception

triggerShutdown

public void triggerShutdown()

Invoked by the Execution service when it's time to stop. Calling this method directly will NOT stop the service, call AbstractExecutionThreadService.stop() instead.

Overrides:

triggerShutdown in class AbstractExecutionThreadService