org.fusesource.stompjms.client.transport
Interface TransportServer

All Known Implementing Classes:

SslTransportServer, TcpTransportServer

public interface TransportServer

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

Version:

$Revision: 1.4 $

Method Summary

java.lang.String	getBoundAddress()
java.lang.String	getConnectAddress()
org.fusesource.hawtdispatch.DispatchQueue	getDispatchQueue() Returns the dispatch queue used by the transport
java.net.SocketAddress	getSocketAddress()
void	resume() resume accepting new transports
void	setAcceptListener(TransportServerListener acceptListener) Registers an TransportAcceptListener which is notified of accepted channels.
void	setDispatchQueue(org.fusesource.hawtdispatch.DispatchQueue queue) Sets the dispatch queue used by the transport
void	start(java.lang.Runnable onComplete) Starts the service.
void	stop(java.lang.Runnable onComplete) Stops the service.
void	suspend() suspend accepting new transports

Method Detail

start

void start(java.lang.Runnable 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

stop

void stop(java.lang.Runnable 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

setAcceptListener

void setAcceptListener(TransportServerListener acceptListener)

Registers an TransportAcceptListener which is notified of accepted channels.

Parameters:

acceptListener -

getBoundAddress

java.lang.String getBoundAddress()

getConnectAddress

java.lang.String getConnectAddress()

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

org.fusesource.hawtdispatch.DispatchQueue getDispatchQueue()

Returns the dispatch queue used by the transport

Returns:

setDispatchQueue

void setDispatchQueue(org.fusesource.hawtdispatch.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