org.fusesource.hawtdispatch.transport

Interface TransportServer

All Known Implementing Classes:

PipeTransportServer, SslTransportServer, TcpTransportServer, UdpTransportServer

public interface TransportServer

A TransportServer asynchronously accepts Transport objects and then delivers those objects to a TransportAcceptListener.

Version:

$Revision: 1.4 $

Method Summary

Modifier and Type	Method and Description
java.util.concurrent.Executor	getBlockingExecutor()
java.lang.String	getBoundAddress()
DispatchQueue	getDispatchQueue() Returns the dispatch queue used by the transport
java.net.SocketAddress	getSocketAddress()
void	resume() resume accepting new transports
void	setBlockingExecutor(java.util.concurrent.Executor blockingExecutor)
void	setDispatchQueue(DispatchQueue queue) Sets the dispatch queue used by the transport
void	setTransportServerListener(TransportServerListener acceptListener) Registers an TransportAcceptListener which is notified of accepted channels.
void	start(java.lang.Runnable onComplete)
void	start(Task onComplete) Starts the service.
void	stop(java.lang.Runnable onComplete)
void	stop(Task onComplete) Stops the service.
void	suspend() suspend accepting new transports

Method Detail

start

void start(Task onComplete)
    throws java.lang.Exception

Starts the service. Executes the onComplete runnable once the service has fully started up.

Parameters:

onComplete - my be set to null if not interested in a callback.

Throws:

java.lang.Exception

start

void start(java.lang.Runnable onComplete)
    throws java.lang.Exception

Throws:

java.lang.Exception

stop

void stop(Task onComplete)
   throws java.lang.Exception

Stops the service. Executes the onComplete runnable once the service has fully stopped.

Parameters:

onComplete - my be set to null if not interested in a callback.

Throws:

java.lang.Exception

stop

void stop(java.lang.Runnable onComplete)
   throws java.lang.Exception

Throws:

java.lang.Exception

setTransportServerListener

void setTransportServerListener(TransportServerListener acceptListener)

Registers an TransportAcceptListener which is notified of accepted channels.

Parameters:

acceptListener -

getBoundAddress

java.lang.String getBoundAddress()

getSocketAddress

java.net.SocketAddress getSocketAddress()

Returns:

The socket address that this transport is accepting connections on or null if this does not or is not currently accepting connections on a socket.

getDispatchQueue

DispatchQueue getDispatchQueue()

Returns the dispatch queue used by the transport

Returns:

setDispatchQueue

void setDispatchQueue(DispatchQueue queue)

Sets the dispatch queue used by the transport

Parameters:

queue -

suspend

void suspend()

suspend accepting new transports

resume

void resume()

resume accepting new transports

getBlockingExecutor

java.util.concurrent.Executor getBlockingExecutor()

setBlockingExecutor

void setBlockingExecutor(java.util.concurrent.Executor blockingExecutor)