org.fusesource.hawtdispatch.transport

Class PipeTransportServer

java.lang.Object

org.fusesource.hawtdispatch.transport.PipeTransportServer

All Implemented Interfaces:

TransportServer

public class PipeTransportServer
extends java.lang.Object
implements TransportServer

Field Summary

Fields

Modifier and Type	Field and Description
private CustomDispatchSource<PipeTransport,java.util.LinkedList<PipeTransport>>	acceptSource
protected java.util.concurrent.atomic.AtomicInteger	connectionCounter
protected java.lang.String	connectURI
(package private) DispatchQueue	dispatchQueue
protected TransportServerListener	listener
protected boolean	marshal
protected java.lang.String	name

Constructor Summary

Constructors

Constructor and Description
PipeTransportServer()

Method Summary

Modifier and Type	Method and Description
PipeTransport	connect()
protected PipeTransport	createClientTransport()
protected PipeTransport	createServerTransport()
java.util.concurrent.Executor	getBlockingExecutor()
java.lang.String	getBoundAddress()
DispatchQueue	getDispatchQueue() Returns the dispatch queue used by the transport
java.lang.String	getName()
java.net.InetSocketAddress	getSocketAddress()
boolean	isMarshal()
void	resume() resume accepting new transports
void	setBlockingExecutor(java.util.concurrent.Executor blockingExecutor)
void	setConnectURI(java.lang.String connectURI)
void	setDispatchQueue(DispatchQueue queue) Sets the dispatch queue used by the transport
void	setMarshal(boolean marshal)
void	setName(java.lang.String name)
void	setTransportServerListener(TransportServerListener listener) Registers an TransportAcceptListener which is notified of accepted channels.
void	start(java.lang.Runnable onCompleted) Deprecated.
void	start(Task onCompleted) Starts the service.
void	stop(java.lang.Runnable onCompleted) Deprecated.
void	stop(Task onCompleted) Stops the service.
void	suspend() suspend accepting new transports

Methods inherited from class java.lang.Object

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

Field Detail

connectURI

protected java.lang.String connectURI

listener

protected TransportServerListener listener

name

protected java.lang.String name

marshal

protected boolean marshal

connectionCounter

protected final java.util.concurrent.atomic.AtomicInteger connectionCounter

dispatchQueue

DispatchQueue dispatchQueue

acceptSource

private CustomDispatchSource<PipeTransport,java.util.LinkedList<PipeTransport>> acceptSource

Constructor Detail

PipeTransportServer

public PipeTransportServer()

Method Detail

getBoundAddress

public java.lang.String getBoundAddress()

Specified by:

getBoundAddress in interface TransportServer

getSocketAddress

public java.net.InetSocketAddress getSocketAddress()

Specified by:

getSocketAddress in interface TransportServer

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

public DispatchQueue getDispatchQueue()

Description copied from interface: TransportServer

Returns the dispatch queue used by the transport

Specified by:

getDispatchQueue in interface TransportServer

Returns:

setDispatchQueue

public void setDispatchQueue(DispatchQueue queue)

Description copied from interface: TransportServer

Sets the dispatch queue used by the transport

Specified by:

setDispatchQueue in interface TransportServer

suspend

public void suspend()

Description copied from interface: TransportServer

suspend accepting new transports

Specified by:

suspend in interface TransportServer

resume

public void resume()

Description copied from interface: TransportServer

resume accepting new transports

Specified by:

resume in interface TransportServer

setTransportServerListener

public void setTransportServerListener(TransportServerListener listener)

Description copied from interface: TransportServer

Registers an TransportAcceptListener which is notified of accepted channels.

Specified by:

setTransportServerListener in interface TransportServer

start

@Deprecated
public void start(java.lang.Runnable onCompleted)
                       throws java.lang.Exception

Deprecated.

Specified by:

start in interface TransportServer

Throws:

java.lang.Exception

stop

@Deprecated
public void stop(java.lang.Runnable onCompleted)
                      throws java.lang.Exception

Deprecated.

Specified by:

stop in interface TransportServer

Throws:

java.lang.Exception

start

public void start(Task onCompleted)
           throws java.lang.Exception

Description copied from interface: TransportServer

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

Specified by:

start in interface TransportServer

Parameters:

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

Throws:

java.lang.Exception

stop

public void stop(Task onCompleted)
          throws java.lang.Exception

Description copied from interface: TransportServer

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

Specified by:

stop in interface TransportServer

Parameters:

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

Throws:

java.lang.Exception

setConnectURI

public void setConnectURI(java.lang.String connectURI)

setName

public void setName(java.lang.String name)

getName

public java.lang.String getName()

connect

public PipeTransport connect()

createClientTransport

protected PipeTransport createClientTransport()

createServerTransport

protected PipeTransport createServerTransport()

isMarshal

public boolean isMarshal()

setMarshal

public void setMarshal(boolean marshal)

getBlockingExecutor

public java.util.concurrent.Executor getBlockingExecutor()

Specified by:

getBlockingExecutor in interface TransportServer

setBlockingExecutor

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

Specified by:

setBlockingExecutor in interface TransportServer