Package org.ow2.joram.jakarta.connector
Class ManagedConnectionFactoryConfig
- java.lang.Object
-
- org.ow2.joram.jakarta.connector.ManagedConnectionFactoryConfig
-
- All Implemented Interfaces:
Serializable
- Direct Known Subclasses:
ManagedConnectionFactoryImpl
public class ManagedConnectionFactoryConfig extends Object implements Serializable
AManagedConnectionFactoryConfigstore configuration of manages outbound connectivity to a given JORAM server.- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description private booleanasyncSendDetermines whether the produced messages are asynchronously sent or not (without or with acknowledgement) Default is false (with ack).private intcnxPendingTimerPeriod in milliseconds between two ping requests sent by the client connection to the server; if the server does not receive any ping request during more than 2 * cnxPendingTimer, the connection is considered as dead and processed as required.private booleancollocatedtruefor collocated outbound connectivity.private intconnectingTimerDuration in seconds during which connecting is attempted (connecting might take time if the server is temporarily not reachable); the 0 value is set for connecting only once and aborting if connecting failed.private StringhostNameUnderlying JORAM server host name.private StringidentityClassDefault identityClassprivate StringinInterceptorsComma separated list of IN interceptors.private Stringmodestatic StringMODE_PTPstatic StringMODE_PUBSUBstatic StringMODE_UNIFIEDprivate booleanmultiThreadSyncDetermines whether client threads which are using the same connection are synchronized in order to group together the requests they send.private intmultiThreadSyncDelayThe maximum time the threads hang if 'multiThreadSync' is true.private Stringnameprivate StringoutInterceptorsComma separated list of OUT interceptors.private StringoutLocalAddressThis is the local IP address on which the TCP connection is activated.private intoutLocalPortThis is the local IP address port on which the TCP connection is activatedprivate StringpasswordDefault user password.private static longserialVersionUIDDefine serialVersionUID for interoperability.private intserverPortUnderlying JORAM server port number. -1 if collocatedprivate inttxPendingTimerDuration in seconds during which a JMS transacted (non XA) session might be pending; above that duration the session is rolled back and closed; the 0 value means "no timer".private StringuserNameDefault user identification.
-
Constructor Summary
Constructors Constructor Description ManagedConnectionFactoryConfig()Constructs aManagedConnectionFactoryConfiginstance.
-
Method Summary
-
-
-
Field Detail
-
serialVersionUID
private static final long serialVersionUID
Define serialVersionUID for interoperability.- See Also:
- Constant Field Values
-
collocated
private boolean collocated
truefor collocated outbound connectivity.
-
hostName
private String hostName
Underlying JORAM server host name.
-
serverPort
private int serverPort
Underlying JORAM server port number. -1 if collocated
-
userName
private String userName
Default user identification.
-
password
private String password
Default user password.
-
identityClass
private String identityClass
Default identityClass
-
connectingTimer
private int connectingTimer
Duration in seconds during which connecting is attempted (connecting might take time if the server is temporarily not reachable); the 0 value is set for connecting only once and aborting if connecting failed.
-
txPendingTimer
private int txPendingTimer
Duration in seconds during which a JMS transacted (non XA) session might be pending; above that duration the session is rolled back and closed; the 0 value means "no timer".
-
cnxPendingTimer
private int cnxPendingTimer
Period in milliseconds between two ping requests sent by the client connection to the server; if the server does not receive any ping request during more than 2 * cnxPendingTimer, the connection is considered as dead and processed as required.
-
asyncSend
private boolean asyncSend
Determines whether the produced messages are asynchronously sent or not (without or with acknowledgement) Default is false (with ack).
-
multiThreadSync
private boolean multiThreadSync
Determines whether client threads which are using the same connection are synchronized in order to group together the requests they send. Default is false.
-
multiThreadSyncDelay
private int multiThreadSyncDelay
The maximum time the threads hang if 'multiThreadSync' is true. Either they wake up (wait time out) or they are notified (by the first woken up thread).Default is 1 ms.
-
outLocalAddress
private String outLocalAddress
This is the local IP address on which the TCP connection is activated. The value can either be a machine name, such as "java.sun.com", or a textual representation of its IP address.
-
outLocalPort
private int outLocalPort
This is the local IP address port on which the TCP connection is activated
-
inInterceptors
private String inInterceptors
Comma separated list of IN interceptors.
-
outInterceptors
private String outInterceptors
Comma separated list of OUT interceptors.
-
MODE_UNIFIED
public static final String MODE_UNIFIED
- See Also:
- Constant Field Values
-
MODE_PTP
public static final String MODE_PTP
- See Also:
- Constant Field Values
-
MODE_PUBSUB
public static final String MODE_PUBSUB
- See Also:
- Constant Field Values
-
mode
private String mode
-
name
private String name
-
-
Method Detail
-
getConnectingTimer
public Integer getConnectingTimer()
-
setConnectingTimer
public void setConnectingTimer(Integer connectingTimer)
-
getTxPendingTimer
public Integer getTxPendingTimer()
-
setTxPendingTimer
public void setTxPendingTimer(Integer txPendingTimer)
-
getCnxPendingTimer
public Integer getCnxPendingTimer()
-
setCnxPendingTimer
public void setCnxPendingTimer(Integer cnxPendingTimer)
-
getAsyncSend
public Boolean getAsyncSend()
-
setAsyncSend
public void setAsyncSend(Boolean asyncSend)
-
isAsyncSend
public boolean isAsyncSend()
-
getMultiThreadSync
public Boolean getMultiThreadSync()
-
setMultiThreadSync
public void setMultiThreadSync(Boolean multiThreadSync)
-
isMultiThreadSync
public boolean isMultiThreadSync()
-
getMultiThreadSyncDelay
public Integer getMultiThreadSyncDelay()
-
setMultiThreadSyncDelay
public void setMultiThreadSyncDelay(Integer multiThreadSyncDelay)
-
setParameters
protected void setParameters(Object factory)
-
setCollocated
public void setCollocated(Boolean collocated)
-
setHostName
public void setHostName(String hostName)
-
setServerPort
public void setServerPort(Integer serverPort)
-
setUserName
public void setUserName(String userName)
-
setPassword
public void setPassword(String password)
-
setIdentityClass
public void setIdentityClass(String identityClass)
-
isCollocated
public Boolean isCollocated()
-
getHostName
public String getHostName()
-
getServerPort
public Integer getServerPort()
-
getUserName
public String getUserName()
-
getPassword
String getPassword()
-
getIdentityClass
public String getIdentityClass()
-
getOutLocalAddress
public String getOutLocalAddress()
-
getOutLocalPort
public Integer getOutLocalPort()
-
setOutLocalAddress
public void setOutLocalAddress(String outLocalAddress)
-
setOutLocalPort
public void setOutLocalPort(Integer outLocalPort)
-
setOutInterceptors
public void setOutInterceptors(String outInterceptors)
-
setInInterceptors
public void setInInterceptors(String inInterceptors)
-
getMode
public String getMode()
- Returns:
- the mode
-
setMode
public void setMode(String mode)
- Parameters:
mode- the mode to set
-
getName
public String getName()
- Returns:
- the name
-
setName
public void setName(String name)
- Parameters:
name- the name to set
-
setManagedConnectionFactoryConfig
public void setManagedConnectionFactoryConfig(Properties props)
-
-