public class ManagedTopicConnectionFactoryImpl extends ManagedConnectionFactoryImpl
ManagedTopicConnectionFactoryImpl
instance manages
PubSub outbound connectivity to a given JORAM server.Modifier and Type | Field and Description |
---|---|
static 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(jakarta.resource.spi.ConnectionManager cxManager)
Method called by an application server (managed case) for creating an
OutboundTopicConnectionFactory instance. |
protected jakarta.jms.XAConnectionFactory |
createFactory(jakarta.resource.spi.ConnectionRequestInfo cxRequest) |
protected jakarta.jms.XAConnection |
createXAConnection(jakarta.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 Logger logger
public ManagedTopicConnectionFactoryImpl()
ManagedTopicConnectionFactoryImpl
instance.public Object createConnectionFactory(jakarta.resource.spi.ConnectionManager cxManager) throws jakarta.resource.ResourceException
OutboundTopicConnectionFactory
instance.createConnectionFactory
in interface jakarta.resource.spi.ManagedConnectionFactory
createConnectionFactory
in class ManagedConnectionFactoryImpl
cxManager
- Application server's connections pooling manager.jakarta.resource.ResourceException
- Never thrown.public Object createConnectionFactory() throws jakarta.resource.ResourceException
OutboundTopicConnectionFactory
instance.createConnectionFactory
in interface jakarta.resource.spi.ManagedConnectionFactory
createConnectionFactory
in class ManagedConnectionFactoryImpl
jakarta.resource.ResourceException
- Never thrown.protected jakarta.jms.XAConnectionFactory createFactory(jakarta.resource.spi.ConnectionRequestInfo cxRequest) throws jakarta.resource.ResourceException
createFactory
in class ManagedConnectionFactoryImpl
jakarta.resource.ResourceException
protected jakarta.jms.XAConnection createXAConnection(jakarta.jms.XAConnectionFactory factory, String userName, String password) throws jakarta.resource.ResourceException
createXAConnection
in class ManagedConnectionFactoryImpl
jakarta.resource.ResourceException
public int hashCode()
hashCode
in interface jakarta.resource.spi.ManagedConnectionFactory
hashCode
in class ManagedConnectionFactoryImpl
public boolean equals(Object o)
equals
in interface jakarta.resource.spi.ManagedConnectionFactory
equals
in class ManagedConnectionFactoryImpl
Copyright © 2022 ScalAgent D.T.. All rights reserved.