org.fusesource.hawtdispatch.transport

Class UdpTransportServer

java.lang.Object

org.fusesource.hawtdispatch.transport.ServiceBase

org.fusesource.hawtdispatch.transport.UdpTransportServer

All Implemented Interfaces:

TransportServer

public class UdpTransportServer
extends ServiceBase
implements TransportServer

Nested Class Summary

Nested classes/interfaces inherited from class org.fusesource.hawtdispatch.transport.ServiceBase

ServiceBase.CallbackSupport, ServiceBase.STARTING, ServiceBase.State, ServiceBase.STOPPING

Field Summary

Fields

Modifier and Type	Field and Description
private java.net.InetSocketAddress	bindAddress
private java.lang.String	bindScheme
private java.util.concurrent.Executor	blockingExecutor
private java.nio.channels.DatagramChannel	channel
private DispatchQueue	dispatchQueue
private TransportServerListener	listener
private UdpTransport	transport

Fields inherited from class org.fusesource.hawtdispatch.transport.ServiceBase

_serviceState, CREATED, STARTED, STOPPED

Constructor Summary

Constructors

Constructor and Description
UdpTransportServer(java.net.URI location)

Method Summary

Modifier and Type	Method and Description
protected void	_start(Task onCompleted)
protected void	_stop(Task onCompleted)
private void	accept()
protected UdpTransport	createTransport()
java.util.concurrent.Executor	getBlockingExecutor()
java.lang.String	getBoundAddress()
DispatchQueue	getDispatchQueue() Returns the dispatch queue used by the transport
java.net.InetSocketAddress	getSocketAddress()
private void	queueAccept()
void	resume() resume accepting new transports
void	setBlockingExecutor(java.util.concurrent.Executor blockingExecutor)
void	setDispatchQueue(DispatchQueue dispatchQueue) Sets the dispatch queue used by the transport
void	setTransportServerListener(TransportServerListener listener) Registers an TransportAcceptListener which is notified of accepted channels.
void	suspend() suspend accepting new transports
java.lang.String	toString()

Methods inherited from class org.fusesource.hawtdispatch.transport.ServiceBase

getServiceState, start, start, stop, stop

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.fusesource.hawtdispatch.transport.TransportServer

start, start, stop, stop

Field Detail

bindScheme

private final java.lang.String bindScheme

bindAddress

private final java.net.InetSocketAddress bindAddress

channel

private java.nio.channels.DatagramChannel channel

listener

private TransportServerListener listener

dispatchQueue

private DispatchQueue dispatchQueue

blockingExecutor

private java.util.concurrent.Executor blockingExecutor

transport

private UdpTransport transport

Constructor Detail

UdpTransportServer

public UdpTransportServer(java.net.URI location)
                   throws java.net.UnknownHostException

Throws:

java.net.UnknownHostException

Method Detail

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

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

Specified by:

getDispatchQueue in class ServiceBase

Returns:

setDispatchQueue

public void setDispatchQueue(DispatchQueue dispatchQueue)

Description copied from interface: TransportServer

Sets the dispatch queue used by the transport

Specified by:

setDispatchQueue in interface TransportServer

_start

protected void _start(Task onCompleted)

Specified by:

_start in class ServiceBase

queueAccept

private void queueAccept()

accept

private void accept()

createTransport

protected UdpTransport createTransport()

_stop

protected void _stop(Task onCompleted)

Specified by:

_stop in class ServiceBase

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

getBoundAddress

public java.lang.String getBoundAddress()

Specified by:

getBoundAddress in interface TransportServer

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

Returns:

pretty print of this

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