org.mule.transport.tcp

Class AbstractTcpSocketFactory

java.lang.Object

org.mule.transport.tcp.AbstractTcpSocketFactory

All Implemented Interfaces:

org.apache.commons.pool.KeyedPoolableObjectFactory

Direct Known Subclasses:

SslSocketFactory, TcpSocketFactory

public abstract class AbstractTcpSocketFactory
extends Object
implements org.apache.commons.pool.KeyedPoolableObjectFactory

Creates a client socket using the socket address extracted from the endpoint. Addtional socket parameters will also be set from the connector

Constructor Summary

Constructors

Constructor and Description
AbstractTcpSocketFactory()

Method Summary

Methods

Modifier and Type	Method and Description
void	activateObject(Object key, Object object)
protected abstract Socket	createSocket(TcpSocketKey key)
void	destroyObject(Object key, Object object)
int	getConnectionTimeout()
Object	makeObject(Object key)
void	passivateObject(Object key, Object object)
void	setConnectionTimeout(int connectionTimeout)
boolean	validateObject(Object key, Object object)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractTcpSocketFactory

public AbstractTcpSocketFactory()

Method Detail

makeObject

public Object makeObject(Object key)
                  throws Exception

Specified by:

makeObject in interface org.apache.commons.pool.KeyedPoolableObjectFactory

Throws:

Exception

createSocket

protected abstract Socket createSocket(TcpSocketKey key)
                                throws IOException

Throws:

IOException

destroyObject

public void destroyObject(Object key,
                 Object object)
                   throws Exception

Specified by:

destroyObject in interface org.apache.commons.pool.KeyedPoolableObjectFactory

Throws:

Exception

validateObject

public boolean validateObject(Object key,
                     Object object)

Specified by:

validateObject in interface org.apache.commons.pool.KeyedPoolableObjectFactory

activateObject

public void activateObject(Object key,
                  Object object)
                    throws Exception

Specified by:

activateObject in interface org.apache.commons.pool.KeyedPoolableObjectFactory

Throws:

Exception

passivateObject

public void passivateObject(Object key,
                   Object object)
                     throws Exception

Specified by:

passivateObject in interface org.apache.commons.pool.KeyedPoolableObjectFactory

Throws:

Exception

getConnectionTimeout

public int getConnectionTimeout()

setConnectionTimeout

public void setConnectionTimeout(int connectionTimeout)