org.apache.activemq.apollo.transport.pipe
Class PipeTransportServer

java.lang.Object
  extended by org.apache.activemq.apollo.transport.pipe.PipeTransportServer
All Implemented Interfaces:
TransportServer, Service

public class PipeTransportServer
extends java.lang.Object
implements TransportServer

Author:
Hiram Chirino

Field Summary
protected  java.util.concurrent.atomic.AtomicInteger connectionCounter
           
protected  java.net.URI connectURI
           
protected  TransportAcceptListener listener
           
protected  boolean marshal
           
protected  java.lang.String name
           
protected  ProtocolCodecFactory.Provider protocolCodecFactory
           
 
Constructor Summary
PipeTransportServer()
           
 
Method Summary
 PipeTransport connect()
           
protected  PipeTransport createClientTransport()
           
protected  PipeTransport createServerTransport()
           
 java.lang.String getBoundAddress()
           
 java.lang.String getConnectAddress()
           
 org.fusesource.hawtdispatch.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 setAcceptListener(TransportAcceptListener listener)
          Registers an TransportAcceptListener which is notified of accepted channels.
 void setConnectURI(java.net.URI connectURI)
           
 void setDispatchQueue(org.fusesource.hawtdispatch.DispatchQueue queue)
          Sets the dispatch queue used by the transport
 void setMarshal(boolean marshal)
           
 void setName(java.lang.String name)
           
 void setProtocolCodecFactory(ProtocolCodecFactory.Provider protocolCodecFactory)
           
 void start()
           
 void start(java.lang.Runnable onCompleted)
           
 void stop()
           
 void stop(java.lang.Runnable onCompleted)
           
 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.net.URI connectURI

listener

protected TransportAcceptListener listener

name

protected java.lang.String name

protocolCodecFactory

protected ProtocolCodecFactory.Provider protocolCodecFactory

marshal

protected boolean marshal

connectionCounter

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

PipeTransportServer

public PipeTransportServer()
Method Detail

getBoundAddress

public java.lang.String getBoundAddress()
Specified by:
getBoundAddress in interface TransportServer

getConnectAddress

public java.lang.String getConnectAddress()
Specified by:
getConnectAddress 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 org.fusesource.hawtdispatch.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(org.fusesource.hawtdispatch.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

setAcceptListener

public void setAcceptListener(TransportAcceptListener listener)
Description copied from interface: TransportServer
Registers an TransportAcceptListener which is notified of accepted channels.

Specified by:
setAcceptListener in interface TransportServer

start

public void start()
           throws java.lang.Exception
Specified by:
start in interface Service
Throws:
java.lang.Exception

start

public void start(java.lang.Runnable onCompleted)
           throws java.lang.Exception
Specified by:
start in interface Service
Throws:
java.lang.Exception

stop

public void stop()
          throws java.lang.Exception
Specified by:
stop in interface Service
Throws:
java.lang.Exception

stop

public void stop(java.lang.Runnable onCompleted)
          throws java.lang.Exception
Specified by:
stop in interface Service
Throws:
java.lang.Exception

setConnectURI

public void setConnectURI(java.net.URI 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()

setProtocolCodecFactory

public void setProtocolCodecFactory(ProtocolCodecFactory.Provider protocolCodecFactory)

isMarshal

public boolean isMarshal()

setMarshal

public void setMarshal(boolean marshal)


Copyright © 2005-2011 The Apache Software Foundation. All Rights Reserved.