Class ManagedTopicConnectionFactoryImpl
- java.lang.Object
-
- org.objectweb.joram.client.connector.ManagedConnectionFactoryConfig
-
- org.objectweb.joram.client.connector.ManagedConnectionFactoryImpl
-
- org.objectweb.joram.client.connector.ManagedTopicConnectionFactoryImpl
-
- All Implemented Interfaces:
Serializable,ManagedConnectionFactory,ResourceAdapterAssociation,ValidatingManagedConnectionFactory
public class ManagedTopicConnectionFactoryImpl extends ManagedConnectionFactoryImpl
AManagedTopicConnectionFactoryImplinstance manages PubSub outbound connectivity to a given JORAM server.- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description private static booleanDEBUGprivate static Loggerloggerprivate static longserialVersionUID-
Fields inherited from class org.objectweb.joram.client.connector.ManagedConnectionFactoryImpl
out, ra
-
Fields inherited from class org.objectweb.joram.client.connector.ManagedConnectionFactoryConfig
MODE_PTP, MODE_PUBSUB, MODE_UNIFIED
-
-
Constructor Summary
Constructors Constructor Description ManagedTopicConnectionFactoryImpl()Constructs aManagedTopicConnectionFactoryImplinstance.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ObjectcreateConnectionFactory()Method called in the non managed case for creating anOutboundTopicConnectionFactoryinstance.ObjectcreateConnectionFactory(ConnectionManager cxManager)Method called by an application server (managed case) for creating anOutboundTopicConnectionFactoryinstance.protected XAConnectionFactorycreateFactory(ConnectionRequestInfo cxRequest)protected XAConnectioncreateXAConnection(XAConnectionFactory factory, String userName, String password)booleanequals(Object o)Compares managed factories according to their configuration.inthashCode()Returns a code depending on the managed factory configuration.-
Methods inherited from class org.objectweb.joram.client.connector.ManagedConnectionFactoryImpl
createManagedConnection, getInvalidConnections, getLogWriter, getName, getResourceAdapter, matchManagedConnections, setLogWriter, setResourceAdapter
-
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
-
-
-
-
Field Detail
-
serialVersionUID
private static final long serialVersionUID
- See Also:
- Constant Field Values
-
logger
private static final Logger logger
-
DEBUG
private static final boolean DEBUG
-
-
Method Detail
-
createConnectionFactory
public Object createConnectionFactory(ConnectionManager cxManager) throws ResourceException
Method called by an application server (managed case) for creating anOutboundTopicConnectionFactoryinstance.- Specified by:
createConnectionFactoryin interfaceManagedConnectionFactory- Overrides:
createConnectionFactoryin classManagedConnectionFactoryImpl- 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 anOutboundTopicConnectionFactoryinstance.- Specified by:
createConnectionFactoryin interfaceManagedConnectionFactory- Overrides:
createConnectionFactoryin classManagedConnectionFactoryImpl- Throws:
ResourceException- Never thrown.
-
createFactory
protected XAConnectionFactory createFactory(ConnectionRequestInfo cxRequest) throws ResourceException
- Overrides:
createFactoryin classManagedConnectionFactoryImpl- Throws:
ResourceException
-
createXAConnection
protected XAConnection createXAConnection(XAConnectionFactory factory, String userName, String password) throws ResourceException
- Overrides:
createXAConnectionin classManagedConnectionFactoryImpl- Throws:
ResourceException
-
hashCode
public int hashCode()
Returns a code depending on the managed factory configuration.- Specified by:
hashCodein interfaceManagedConnectionFactory- Overrides:
hashCodein classManagedConnectionFactoryImpl
-
equals
public boolean equals(Object o)
Compares managed factories according to their configuration.- Specified by:
equalsin interfaceManagedConnectionFactory- Overrides:
equalsin classManagedConnectionFactoryImpl
-
-