Package org.objectweb.joram.client.connector

Class ManagedConnectionFactoryImpl

java.lang.Object

org.objectweb.joram.client.connector.ManagedConnectionFactoryConfig

org.objectweb.joram.client.connector.ManagedConnectionFactoryImpl

All Implemented Interfaces:

Serializable, ManagedConnectionFactory, ResourceAdapterAssociation, ValidatingManagedConnectionFactory

Direct Known Subclasses:

ManagedQueueConnectionFactoryImpl, ManagedTopicConnectionFactoryImpl

public class ManagedConnectionFactoryImpl
extends ManagedConnectionFactoryConfig
implements ManagedConnectionFactory, ResourceAdapterAssociation, ValidatingManagedConnectionFactory, Serializable

A ManagedConnectionFactoryImpl instance manages outbound connectivity to a given JORAM server.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
private static boolean	DEBUG
private static Logger	logger
protected PrintWriter	out	Out stream for error logging and tracing.
(package private) JoramResourceAdapter	ra	Resource adapter central authority.
private static long	serialVersionUID	Define serialVersionUID for interoperability.

Fields inherited from class org.objectweb.joram.client.connector.ManagedConnectionFactoryConfig

MODE_PTP, MODE_PUBSUB, MODE_UNIFIED

Constructor Summary

Constructors

Constructor	Description
ManagedConnectionFactoryImpl()	Constructs a ManagedConnectionFactoryImpl instance.

Method Summary

Modifier and Type	Method	Description
Object	createConnectionFactory()	Method called in the non managed case for creating an OutboundConnectionFactory instance.
Object	createConnectionFactory(ConnectionManager cxManager)	Method called by an application server (managed case) for creating an OutboundConnectionFactory instance.
protected XAConnectionFactory	createFactory(ConnectionRequestInfo cxRequest)
ManagedConnection	createManagedConnection(Subject subject, ConnectionRequestInfo cxRequest)	Creates a new physical connection to the underlying JORAM server, and returns a ManagedConnectionImpl instance for a managed environment.
protected XAConnection	createXAConnection(XAConnectionFactory factory, String userName, String password)
boolean	equals(Object o)	Compares managed factories according to their configuration.
Set<ManagedConnectionImpl>	getInvalidConnections(Set connectionSet)	From a set of managed connections, returns the set of invalid ones.
PrintWriter	getLogWriter()	Gets the log writer of this ManagedConnectionFactoryImpl instance.
String	getName()
ResourceAdapter	getResourceAdapter()	Returns the resource adapter central authority instance.
int	hashCode()	Returns a code depending on the managed factory configuration.
ManagedConnection	matchManagedConnections(Set connectionSet, Subject subject, ConnectionRequestInfo cxRequest)	Finds a matching connection from the candidate set of connections and returns a ManagedConnectionImpl instance.
void	setLogWriter(PrintWriter out)	Sets the log writer for this ManagedConnectionFactoryImpl instance.
void	setResourceAdapter(ResourceAdapter ra)	Sets the resource adapter central authority.

Methods inherited from class org.objectweb.joram.client.connector.ManagedConnectionFactoryConfig

getAsyncSend, getCnxPendingTimer, getConnectingTimer, getHostName, getIdentityClass, getMode, getMultiThreadSync, getMultiThreadSyncDelay, getOutLocalAddress, getOutLocalPort, getPassword, getServerPort, getTxPendingTimer, getUserName, isAsyncSend, isCollocated, isMultiThreadSync, setAsyncSend, setCnxPendingTimer, setCollocated, setConnectingTimer, setHostName, setIdentityClass, setInInterceptors, setManagedConnectionFactoryConfig, setMode, setMultiThreadSync, setMultiThreadSyncDelay, setName, setOutInterceptors, setOutLocalAddress, setOutLocalPort, setParameters, setPassword, setServerPort, setTxPendingTimer, setUserName

Methods inherited from class java.lang.Object

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

Field Detail

serialVersionUID

private static final long serialVersionUID

Define serialVersionUID for interoperability.

See Also:

Constant Field Values

logger

private static final Logger logger

DEBUG

private static final boolean DEBUG

out

protected transient PrintWriter out

Out stream for error logging and tracing.

ra

transient JoramResourceAdapter ra

Resource adapter central authority.

Constructor Detail

ManagedConnectionFactoryImpl

public ManagedConnectionFactoryImpl()

Constructs a ManagedConnectionFactoryImpl instance.

Method Detail

createConnectionFactory

public Object createConnectionFactory(ConnectionManager cxManager)
                               throws ResourceException

Method called by an application server (managed case) for creating an OutboundConnectionFactory instance.

Specified by:

createConnectionFactory in interface ManagedConnectionFactory

Parameters:

cxManager - Application server's connections pooling manager.

Throws:

ResourceException - Never thrown.

createConnectionFactory

public Object createConnectionFactory()
                               throws ResourceException

Method called in the non managed case for creating an OutboundConnectionFactory instance.

Specified by:

createConnectionFactory in interface ManagedConnectionFactory

Throws:

ResourceException - Never thrown.

createFactory

protected XAConnectionFactory createFactory(ConnectionRequestInfo cxRequest)
                                     throws ResourceException

Throws:

ResourceException

createXAConnection

protected XAConnection createXAConnection(XAConnectionFactory factory,
                                          String userName,
                                          String password)
                                   throws ResourceException

Throws:

ResourceException

createManagedConnection

public final ManagedConnection createManagedConnection(Subject subject,
                                                       ConnectionRequestInfo cxRequest)
                                                throws ResourceException

Creates a new physical connection to the underlying JORAM server, and returns a ManagedConnectionImpl instance for a managed environment.

Specified by:

createManagedConnection in interface ManagedConnectionFactory

Parameters:

subject - Security data, not taken into account.

cxRequest - User identification data, may be null.

Throws:

CommException - If the JORAM server is not reachable.

SecurityException - If the connecting is not allowed.

IllegalStateException - If the central Joram adapter state is invalid.

ResourceException - If the provided user info is invalid, or if connecting fails for any other reason.

matchManagedConnections

public final ManagedConnection matchManagedConnections(Set connectionSet,
                                                       Subject subject,
                                                       ConnectionRequestInfo cxRequest)
                                                throws ResourceException

Finds a matching connection from the candidate set of connections and returns a ManagedConnectionImpl instance.

Specified by:

matchManagedConnections in interface ManagedConnectionFactory

Parameters:

connectionSet - Set of connections to test.

subject - Security data, not taken into account.

cxRequest - User identification data, may be null.

Throws:

ResourceException - If the provided connection request info is invalid.

setLogWriter

public void setLogWriter(PrintWriter out)
                  throws ResourceException

Sets the log writer for this ManagedConnectionFactoryImpl instance.

Specified by:

setLogWriter in interface ManagedConnectionFactory

Throws:

ResourceException

getLogWriter

public PrintWriter getLogWriter()
                         throws ResourceException

Gets the log writer of this ManagedConnectionFactoryImpl instance.

Specified by:

getLogWriter in interface ManagedConnectionFactory

Throws:

ResourceException

getName

public String getName()

Overrides:

getName in class ManagedConnectionFactoryConfig

Returns:

the name

hashCode

public int hashCode()

Returns a code depending on the managed factory configuration.

Specified by:

hashCode in interface ManagedConnectionFactory

Overrides:

hashCode in class Object

equals

public boolean equals(Object o)

Compares managed factories according to their configuration.

Specified by:

equals in interface ManagedConnectionFactory

Overrides:

equals in class Object

getResourceAdapter

public ResourceAdapter getResourceAdapter()

Returns the resource adapter central authority instance.

Specified by:

getResourceAdapter in interface ResourceAdapterAssociation

setResourceAdapter

public void setResourceAdapter(ResourceAdapter ra)
                        throws ResourceException

Sets the resource adapter central authority.

Specified by:

setResourceAdapter in interface ResourceAdapterAssociation

Throws:

ResourceException - If the adapter could not be set.

getInvalidConnections

public Set<ManagedConnectionImpl> getInvalidConnections(Set connectionSet)
                                                 throws ResourceException

From a set of managed connections, returns the set of invalid ones.

Specified by:

getInvalidConnections in interface ValidatingManagedConnectionFactory

Throws:

ResourceException