com.google.bitcoin.net

Class NioServer

java.lang.Object

com.google.common.util.concurrent.AbstractExecutionThreadService

com.google.bitcoin.net.NioServer

All Implemented Interfaces:

com.google.common.util.concurrent.Service

public class NioServer
extends com.google.common.util.concurrent.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

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.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

Methods

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, executor, getServiceName, isRunning, shutDown, start, startAndWait, startUp, state, stop, stopAndWait, 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 com.google.common.util.concurrent.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 com.google.common.util.concurrent.AbstractExecutionThreadService