public class ManagedTopicConnectionFactoryImpl extends ManagedConnectionFactoryImpl
ManagedTopicConnectionFactoryImpl
instance manages
PubSub outbound connectivity to a given JORAM server.Modifier and Type | Field and Description |
---|---|
static org.objectweb.util.monolog.api.Logger |
logger |
private static long |
serialVersionUID |
out, ra
asyncSend, MODE_PTP, MODE_PUBSUB, MODE_UNIFIED
Constructor and Description |
---|
ManagedTopicConnectionFactoryImpl()
Constructs a
ManagedTopicConnectionFactoryImpl instance. |
Modifier and Type | Method and Description |
---|---|
Object |
createConnectionFactory()
Method called in the non managed case for creating an
OutboundTopicConnectionFactory instance. |
Object |
createConnectionFactory(javax.resource.spi.ConnectionManager cxManager)
Method called by an application server (managed case) for creating an
OutboundTopicConnectionFactory instance. |
protected javax.jms.XAConnectionFactory |
createFactory(javax.resource.spi.ConnectionRequestInfo cxRequest) |
protected javax.jms.XAConnection |
createXAConnection(javax.jms.XAConnectionFactory factory,
String userName,
String password) |
boolean |
equals(Object o)
Compares managed factories according to their configuration.
|
int |
hashCode()
Returns a code depending on the managed factory configuration.
|
createManagedConnection, getInvalidConnections, getLogWriter, getResourceAdapter, matchManagedConnections, setLogWriter, setResourceAdapter
getAsyncSend, getCnxPendingTimer, getConnectingTimer, getHostName, getIdentityClass, getMode, getMultiThreadSync, getMultiThreadSyncDelay, getName, 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
private static final long serialVersionUID
public static org.objectweb.util.monolog.api.Logger logger
public ManagedTopicConnectionFactoryImpl()
ManagedTopicConnectionFactoryImpl
instance.public Object createConnectionFactory(javax.resource.spi.ConnectionManager cxManager) throws javax.resource.ResourceException
OutboundTopicConnectionFactory
instance.createConnectionFactory
in interface javax.resource.spi.ManagedConnectionFactory
createConnectionFactory
in class ManagedConnectionFactoryImpl
cxManager
- Application server's connections pooling manager.javax.resource.ResourceException
- Never thrown.public Object createConnectionFactory() throws javax.resource.ResourceException
OutboundTopicConnectionFactory
instance.createConnectionFactory
in interface javax.resource.spi.ManagedConnectionFactory
createConnectionFactory
in class ManagedConnectionFactoryImpl
javax.resource.ResourceException
- Never thrown.protected javax.jms.XAConnectionFactory createFactory(javax.resource.spi.ConnectionRequestInfo cxRequest) throws javax.resource.ResourceException
createFactory
in class ManagedConnectionFactoryImpl
javax.resource.ResourceException
protected javax.jms.XAConnection createXAConnection(javax.jms.XAConnectionFactory factory, String userName, String password) throws javax.resource.ResourceException
createXAConnection
in class ManagedConnectionFactoryImpl
javax.resource.ResourceException
public int hashCode()
hashCode
in interface javax.resource.spi.ManagedConnectionFactory
hashCode
in class ManagedConnectionFactoryImpl
public boolean equals(Object o)
equals
in interface javax.resource.spi.ManagedConnectionFactory
equals
in class ManagedConnectionFactoryImpl
Copyright © 2018 ScalAgent D.T.. All Rights Reserved.