QName |
Type |
Use |
Annotation |
alwaysSessionAsync |
xs:boolean |
optional |
If this flag is not set then a separate thread is not used for dispatching messages for each Session in
the Connection. However, a separate thread is always used if there is more than one session, or the session
isn't in auto acknowledge or duplicates ok mode. By default this value is set to true and session dispatch
happens asynchronously. |
|
alwaysSyncSend |
xs:boolean |
optional |
Set true if always require messages to be sync sent |
|
auditDepth |
xs:integer |
optional |
|
auditMaximumProducerNumber |
xs:integer |
optional |
|
beanName |
xs:string |
optional |
|
blobTransferPolicy |
xs:string |
optional |
Sets the policy used to describe how out-of-band BLOBs (Binary Large
OBjects) are transferred from producers to brokers to consumers |
|
brokerURL |
xs:string |
optional |
Sets the <a
href="http://activemq.apache.org/configuring-transports.html">connection
URL</a> used to connect to the ActiveMQ broker. |
|
checkForDuplicates |
xs:boolean |
optional |
|
clientID |
xs:string |
optional |
Sets the JMS clientID to use for the created connection. Note that this
can only be used by one connection at once so generally its a better idea
to set the clientID on a Connection |
|
clientIDPrefix |
xs:string |
optional |
Sets the prefix used by autogenerated JMS Client ID values which are used
if the JMS client does not explicitly specify on. |
|
clientIdGenerator |
xs:string |
optional |
|
clientInternalExceptionListener |
xs:string |
optional |
Allows an {@link ClientInternalExceptionListener} to be configured on the ConnectionFactory so that when this factory
is used by frameworks which don't expose the Connection such as Spring JmsTemplate, you can register
an exception listener.
<p> Note: access to this clientInternalExceptionListener will <b>not</b> be serialized if it is associated with more than
on connection (as it will be if more than one connection is subsequently created by this connection factory) |
|
closeTimeout |
xs:integer |
optional |
Sets the timeout before a close is considered complete. Normally a
close() on a connection waits for confirmation from the broker; this
allows that operation to timeout to save the client hanging if there is
no broker |
|
connectResponseTimeout |
xs:integer |
optional |
|
connectionIDPrefix |
xs:string |
optional |
Sets the prefix used by connection id generator |
|
connectionIdGenerator |
xs:string |
optional |
|
consumerExpiryCheckEnabled |
xs:boolean |
optional |
Controls whether message expiration checking is done in each MessageConsumer
prior to dispatching a message. Disabling this check can lead to consumption
of expired messages. |
|
consumerFailoverRedeliveryWaitPeriod |
xs:long |
optional |
|
copyMessageOnSend |
xs:boolean |
optional |
Should a JMS message be copied to a new JMS Message object as part of the
send() method in JMS. This is enabled by default to be compliant with the
JMS specification. You can disable it if you do not mutate JMS messages
after they are sent for a performance boost |
|
disableTimeStampsByDefault |
xs:boolean |
optional |
Sets whether or not timestamps on messages should be disabled or not. If
you disable them it adds a small performance boost. |
|
dispatchAsync |
xs:boolean |
optional |
Enables or disables the default setting of whether or not consumers have
their messages <a
href="http://activemq.apache.org/consumer-dispatch-async.html">dispatched
synchronously or asynchronously by the broker</a>. For non-durable
topics for example we typically dispatch synchronously by default to
minimize context switches which boost performance. However sometimes its
better to go slower to ensure that a single blocked consumer socket does
not block delivery to other consumers. |
|
exceptionListener |
xs:string |
optional |
Allows an {@link ExceptionListener} to be configured on the ConnectionFactory so that when this factory
is used by frameworks which don't expose the Connection such as Spring JmsTemplate, you can register
an exception listener.
<p> Note: access to this exceptionLinstener will <b>not</b> be serialized if it is associated with more than
on connection (as it will be if more than one connection is subsequently created by this connection factory) |
|
exclusiveConsumer |
xs:boolean |
optional |
Enables or disables whether or not queue consumers should be exclusive or
not for example to preserve ordering when not using <a
href="http://activemq.apache.org/message-groups.html">Message Groups</a> |
|
id |
xs:ID |
optional |
|
maxThreadPoolSize |
xs:integer |
optional |
|
messagePrioritySupported |
xs:boolean |
optional |
|
nestedMapAndListEnabled |
xs:boolean |
optional |
Enables/disables whether or not Message properties and MapMessage entries
support <a
href="http://activemq.apache.org/structured-message-properties-and-mapmessages.html">Nested
Structures</a> of Map and List objects |
|
nonBlockingRedelivery |
xs:boolean |
optional |
When true a MessageConsumer will not stop Message delivery before re-delivering Messages
from a rolled back transaction. This implies that message order will not be preserved and
also will result in the TransactedIndividualAck option to be enabled. |
|
objectMessageSerializationDefered |
xs:boolean |
optional |
When an object is set on an ObjectMessage, the JMS spec requires the
object to be serialized by that set method. Enabling this flag causes the
object to not get serialized. The object may subsequently get serialized
if the message needs to be sent over a socket or stored to disk. |
|
optimizeAcknowledge |
xs:boolean |
optional |
|
optimizeAcknowledgeTimeOut |
xs:long |
optional |
The max time in milliseconds between optimized ack batches |
|
optimizedAckScheduledAckInterval |
xs:long |
optional |
Gets the configured time interval that is used to force all MessageConsumers that have optimizedAcknowledge enabled
to send an ack for any outstanding Message Acks. By default this value is set to zero meaning that the consumers
will not do any background Message acknowledgment. |
|
optimizedMessageDispatch |
xs:boolean |
optional |
If this flag is set then an larger prefetch limit is used - only
applicable for durable topic subscribers. |
|
password |
xs:string |
optional |
Sets the JMS password used for connections created from this factory |
|
prefetchPolicy |
xs:string |
optional |
Sets the <a
href="http://activemq.apache.org/what-is-the-prefetch-limit-for.html">prefetch
policy</a> for consumers created by this connection. |
|
producerWindowSize |
xs:integer |
optional |
|
properties |
xs:string |
optional |
Get the properties from this instance for storing in JNDI |
|
redeliveryPolicy |
xs:string |
optional |
Sets the global default redelivery policy to be used when a message is delivered
but the session is rolled back |
|
redeliveryPolicyMap |
xs:string |
optional |
Sets the global redelivery policy mapping to be used when a message is delivered
but the session is rolled back |
|
rejectedTaskHandler |
xs:string |
optional |
|
rmIdFromConnectionId |
xs:boolean |
optional |
uses the connection id as the resource identity for XAResource.isSameRM
ensuring join will only occur on a single connection |
|
sendAcksAsync |
xs:boolean |
optional |
|
sendTimeout |
xs:integer |
optional |
|
sessionTaskRunner |
xs:string |
optional |
|
statsEnabled |
xs:boolean |
optional |
|
transactedIndividualAck |
xs:boolean |
optional |
when true, submit individual transacted acks immediately rather than with transaction completion.
This allows the acks to represent delivery status which can be persisted on rollback
Used in conjunction with org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter#setRewriteOnRedelivery(boolean) true |
|
transformer |
xs:string |
optional |
Sets the transformer used to transform messages before they are sent on
to the JMS bus or when they are received from the bus but before they are
delivered to the JMS client |
|
transportListener |
xs:string |
optional |
Allows a listener to be configured on the ConnectionFactory so that when this factory is used
with frameworks which don't expose the Connection such as Spring JmsTemplate, you can still register
a transport listener. |
|
trustAllPackages |
xs:boolean |
optional |
|
useAsyncSend |
xs:boolean |
optional |
Forces the use of <a
href="http://activemq.apache.org/async-sends.html">Async Sends</a> which
adds a massive performance boost; but means that the send() method will
return immediately whether the message has been sent or not which could
lead to message loss. |
|
useBeanNameAsClientIdPrefix |
xs:boolean |
optional |
|
useCompression |
xs:boolean |
optional |
Enables the use of compression of the message bodies |
|
useDedicatedTaskRunner |
xs:boolean |
optional |
|
useRetroactiveConsumer |
xs:boolean |
optional |
Sets whether or not retroactive consumers are enabled. Retroactive
consumers allow non-durable topic subscribers to receive old messages
that were published before the non-durable subscriber started. |
|
userName |
xs:string |
optional |
Sets the JMS userName used by connections created by this factory |
|
warnAboutUnstartedConnectionTimeout |
xs:long |
optional |
Enables the timeout from a connection creation to when a warning is
generated if the connection is not properly started via
{@link Connection#start()} and a message is received by a consumer. It is
a very common gotcha to forget to <a
href="http://activemq.apache.org/i-am-not-receiving-any-messages-what-is-wrong.html">start
the connection</a> so this option makes the default case to create a
warning if the user forgets. To disable the warning just set the value to <
0 (say -1). |
|
watchTopicAdvisories |
xs:boolean |
optional |
|
xaAckMode |
xs:integer |
optional |
|