public class ActivationSpecImpl extends Object implements ActivationSpec, ResourceAdapterAssociation, Serializable
ActivationSpecImpl
instance holds configuration information
related to an endpoint deployment.Modifier and Type | Field and Description |
---|---|
private String |
acknowledgeMode
Acknowledgement mode.
|
static String |
AUTO_ACKNOWLEDGE
Value for the property
acknowledgeMode
defined in the MDB deployment descriptor. |
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.
|
private Boolean |
collocated
true if the underlying JORAM server is collocated. |
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.
|
private Boolean |
deleteDurableSubscription
Determine whether durable subscription must be deleted or not
at close time of the InboundConsumer.
|
private String |
destination
The name of the destination to get messages from.
|
private String |
destinationType
The type of the destination to get messages from.
|
static String |
DUPS_OK_ACKNOWLEDGE
Value for the property
acknowledgeMode
defined in the MDB deployment descriptor. |
private String |
hostName
Host name or IP of the underlying JORAM server.
|
private String |
identityClass
identity class name.
|
static Logger |
logger |
private String |
maxMessages
The maximum number of messages that can be assigned
to a server session at one time
Default is 10.
|
private String |
maxNumberOfWorks
Maximum number of work instances to be submitted (0 for infinite).
|
private String |
messageSelector
Message selector.
|
private String |
name |
private String |
password
User password.
|
private int |
queueMessageReadMax
The maximum number of messages that can be
read at once from a queue.
|
private JoramAdapter |
ra
Resource adapter central authority.
|
private static long |
serialVersionUID |
private int |
serverPort
Port number of the underlying JORAM server.
|
private String |
subscriptionDurability
Subscription durability.
|
private String |
subscriptionName
Durable subscription name, if any.
|
private int |
topicAckBufferMax
The maximum number of acknowledgements
that can be buffered in
Session.DUPS_OK_ACKNOWLEDGE mode when listening to a topic.
|
private int |
topicActivationThreshold
This threshold is the minimum
messages number below which
the subscription is activated.
|
private int |
topicPassivationThreshold
This threshold is the maximum messages
number over
which the subscription is passivated.
|
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".
|
private String |
userName
User identification.
|
Constructor and Description |
---|
ActivationSpecImpl()
Constructs an
ActivationSpecImpl instance. |
Modifier and Type | Method and Description |
---|---|
String |
getAcknowledgeMode()
Returns the acknowledgment mode.
|
Integer |
getCnxPendingTimer() |
Boolean |
getCollocated() |
Integer |
getConnectingTimer() |
Boolean |
getDeleteDurableSubscription()
Returns the deleteDurableSubscription attribute.
|
String |
getDestination()
Returns the destination name.
|
String |
getDestinationType()
Returns the destination type.
|
String |
getHostName() |
String |
getIdentityClass()
Returns the identity class name.
|
String |
getMaxMessages() |
String |
getMaxNumberOfWorks()
Returns the maximum number of work instances to be submitted.
|
String |
getMessageSelector()
Returns the message selector.
|
String |
getName() |
String |
getPassword()
Returns the user password.
|
Integer |
getQueueMessageReadMax() |
ResourceAdapter |
getResourceAdapter()
Returns the resource adapter central authority instance.
|
Integer |
getServerPort() |
String |
getSubscriptionDurability()
Returns the subscription durability.
|
String |
getSubscriptionName()
Returns the name of the durable subscription.
|
Integer |
getTopicAckBufferMax() |
Integer |
getTopicActivationThreshold() |
Integer |
getTopicPassivationThreshold() |
Integer |
getTxPendingTimer() |
String |
getUserName()
Returns the user identification.
|
void |
setAcknowledgeMode(String acknowledgeMode)
Sets the acknowledgment mode.
|
void |
setActivationSpecConfig(Properties props) |
void |
setCnxPendingTimer(String cnxPendingTimer) |
void |
setCollocated(String collocatedServer) |
void |
setConnectingTimer(String connectingTimer) |
void |
setDeleteDurableSubscription(String deleteDurableSubscription)
Set the deleteDurableSubscription attribute.
|
void |
setDestination(String destination)
Sets the destination name.
|
void |
setDestinationType(String destinationType)
Sets the destination type (either "javax.jms.Queue" or
"javax.jms.Topic").
|
void |
setHostName(String hostName) |
void |
setIdentityClass(String identityClass)
set the identity class name.
|
void |
setMaxMessages(String maxMessages) |
void |
setMaxNumberOfWorks(String maxNumberOfWorks)
Sets the maximum number of work instances to be submitted.
|
void |
setMessageSelector(String messageSelector)
Sets the message selector.
|
void |
setName(String name) |
void |
setPassword(String password)
Sets the user password.
|
void |
setQueueMessageReadMax(String queueMessageReadMax) |
void |
setResourceAdapter(ResourceAdapter ra)
Sets the resource adapter central authority.
|
void |
setServerPort(String serverPort) |
void |
setSubscriptionDurability(String subscriptionDurability)
Sets the durability of the subscription.
|
void |
setSubscriptionName(String subscriptionName)
Sets the name of the durable subscription.
|
void |
setTopicAckBufferMax(String topicAckBufferMax) |
void |
setTopicActivationThreshold(String topicActivationThreshold) |
void |
setTopicPassivationThreshold(String topicPassivationThreshold) |
void |
setTxPendingTimer(String txPendingTimer) |
void |
setUserName(String userName)
Sets the user identification.
|
String |
toString() |
void |
validate()
Checks if the configuration information is valid.
|
private static final long serialVersionUID
public static Logger logger
public static final String AUTO_ACKNOWLEDGE
acknowledgeMode
defined in the MDB deployment descriptor.public static final String DUPS_OK_ACKNOWLEDGE
acknowledgeMode
defined in the MDB deployment descriptor.private String destinationType
private String destination
private String userName
private String password
private String identityClass
private String messageSelector
private String subscriptionDurability
private String subscriptionName
private String acknowledgeMode
private String maxNumberOfWorks
private String maxMessages
private Boolean deleteDurableSubscription
Default is false.
private transient JoramAdapter ra
private Boolean collocated
true
if the underlying JORAM server is collocated.private String hostName
private int serverPort
private int connectingTimer
private int txPendingTimer
private int cnxPendingTimer
private int queueMessageReadMax
private int topicAckBufferMax
private int topicPassivationThreshold
private int topicActivationThreshold
private String name
public ActivationSpecImpl()
ActivationSpecImpl
instance.public void setCollocated(String collocatedServer)
public Boolean getCollocated()
public String getHostName()
public void setHostName(String hostName)
public Integer getServerPort()
public void setServerPort(String serverPort)
public Integer getConnectingTimer()
public void setConnectingTimer(String connectingTimer)
public Integer getTxPendingTimer()
public void setTxPendingTimer(String txPendingTimer)
public Integer getCnxPendingTimer()
public void setCnxPendingTimer(String cnxPendingTimer)
public Integer getQueueMessageReadMax()
public void setQueueMessageReadMax(String queueMessageReadMax)
public Integer getTopicAckBufferMax()
public void setTopicAckBufferMax(String topicAckBufferMax)
public Integer getTopicPassivationThreshold()
public void setTopicPassivationThreshold(String topicPassivationThreshold)
public Integer getTopicActivationThreshold()
public void setTopicActivationThreshold(String topicActivationThreshold)
public String getName()
public void setName(String name)
name
- the name to setpublic void validate() throws InvalidPropertyException
validate
in interface ActivationSpec
InvalidPropertyException
- If a parameter is missing, incorrect,
or not consistent with other
parameters.public void setResourceAdapter(ResourceAdapter ra) throws ResourceException
setResourceAdapter
in interface ResourceAdapterAssociation
ResourceException
public ResourceAdapter getResourceAdapter()
getResourceAdapter
in interface ResourceAdapterAssociation
public void setDestinationType(String destinationType)
public void setDestination(String destination)
public void setUserName(String userName)
public void setPassword(String password)
public void setIdentityClass(String identityClass)
public void setMessageSelector(String messageSelector)
public void setSubscriptionDurability(String subscriptionDurability)
public void setSubscriptionName(String subscriptionName)
public void setAcknowledgeMode(String acknowledgeMode)
public void setMaxNumberOfWorks(String maxNumberOfWorks)
public void setMaxMessages(String maxMessages)
public void setDeleteDurableSubscription(String deleteDurableSubscription)
deleteDurableSubscription
- to set deleteDurableSubscriptiondeleteDurableSubscription
public String getDestinationType()
public String getDestination()
public String getUserName()
public String getPassword()
public String getIdentityClass()
public String getMessageSelector()
public String getSubscriptionDurability()
public String getSubscriptionName()
public String getAcknowledgeMode()
public String getMaxNumberOfWorks()
public String getMaxMessages()
public Boolean getDeleteDurableSubscription()
deleteDurableSubscription
public void setActivationSpecConfig(Properties props)
Copyright © 2023 ScalAgent D.T.. All rights reserved.