org.apache.activemq.apollo.broker.transport

Class TcpTransportFactory

java.lang.Object

org.apache.activemq.apollo.broker.transport.TcpTransportFactory

All Implemented Interfaces:

TransportFactory.Provider

Direct Known Subclasses:

SslTransportFactory

public class TcpTransportFactory
extends Object
implements TransportFactory.Provider

Author:

Hiram Chirino, David Martin Clavo david(dot)martin(dot)clavo(at)gmail.com (logging improvement modifications)

Constructor Summary

Constructors

Constructor and Description
TcpTransportFactory()

Method Summary

Methods

Modifier and Type	Method and Description
org.fusesource.hawtdispatch.transport.TransportServer	bind(String location)
org.fusesource.hawtdispatch.transport.Transport	connect(String location)
protected org.fusesource.hawtdispatch.transport.TcpTransportServer	createTcpTransportServer(URI location, Map<String,String> options) Allows subclasses of TcpTransportFactory to create custom instances of TcpTransportServer.
protected org.fusesource.hawtdispatch.transport.TcpTransport	createTransport(URI uri) Allows subclasses of TcpTransportFactory to create custom instances of TcpTransport.
protected URI	getLocalLocation(URI location)
protected String	getOption(Map options, String key, String def)

Methods inherited from class java.lang.Object

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

Constructor Detail

TcpTransportFactory

public TcpTransportFactory()

Method Detail

bind

public org.fusesource.hawtdispatch.transport.TransportServer bind(String location)
                                                           throws Exception

Specified by:

bind in interface TransportFactory.Provider

Throws:

Exception

connect

public org.fusesource.hawtdispatch.transport.Transport connect(String location)
                                                        throws Exception

Specified by:

connect in interface TransportFactory.Provider

Throws:

Exception

createTcpTransportServer

protected org.fusesource.hawtdispatch.transport.TcpTransportServer createTcpTransportServer(URI location,
                                                                                Map<String,String> options)
                                                                                     throws IOException,
                                                                                            URISyntaxException,
                                                                                            Exception

Allows subclasses of TcpTransportFactory to create custom instances of TcpTransportServer.

Throws:

IOException

URISyntaxException

Exception

createTransport

protected org.fusesource.hawtdispatch.transport.TcpTransport createTransport(URI uri)
                                                                      throws NoSuchAlgorithmException,
                                                                             Exception

Allows subclasses of TcpTransportFactory to create custom instances of TcpTransport.

Throws:

NoSuchAlgorithmException

Exception

getLocalLocation

protected URI getLocalLocation(URI location)

getOption

protected String getOption(Map options,
               String key,
               String def)