activemq-cpp-3.9.0
|
#include <src/main/activemq/core/ActiveMQConnectionFactory.h>
Public Member Functions | |
ActiveMQConnectionFactory () | |
ActiveMQConnectionFactory (const std::string &uri, const std::string &username="", const std::string &password="") | |
Constructor. More... | |
ActiveMQConnectionFactory (const decaf::net::URI &uri, const std::string &username="", const std::string &password="") | |
Constructor. More... | |
virtual | ~ActiveMQConnectionFactory () |
virtual cms::Connection * | createConnection () |
Creates a connection with the default user identity. More... | |
virtual cms::Connection * | createConnection (const std::string &username, const std::string &password) |
Creates a connection with the specified user identity. More... | |
virtual cms::Connection * | createConnection (const std::string &username, const std::string &password, const std::string &clientId) |
Creates a connection with the specified user identity. More... | |
void | setUsername (const std::string &username) |
Sets the username that should be used when creating a new connection. More... | |
const std::string & | getUsername () const |
Gets the username that this factory will use when creating a new connection instance. More... | |
void | setPassword (const std::string &password) |
Sets the password that should be used when creating a new connection. More... | |
const std::string & | getPassword () const |
Gets the password that this factory will use when creating a new connection instance. More... | |
std::string | getClientId () const |
Gets the Configured Client Id. More... | |
void | setClientId (const std::string &clientId) |
Sets the Client Id. More... | |
void | setBrokerURI (const std::string &uri) |
Sets the Broker URI that should be used when creating a new connection instance. More... | |
void | setBrokerURI (const decaf::net::URI &uri) |
Sets the Broker URI that should be used when creating a new connection instance. More... | |
const decaf::net::URI & | getBrokerURI () const |
Gets the Broker URI that this factory will use when creating a new connection instance. More... | |
virtual void | setExceptionListener (cms::ExceptionListener *listener) |
Set an CMS ExceptionListener that will be set on eat connection once it has been created. More... | |
virtual cms::ExceptionListener * | getExceptionListener () const |
Returns the currently set ExceptionListener that will be set on any new Connection instance that is created by this factory. More... | |
virtual void | setMessageTransformer (cms::MessageTransformer *transformer) |
Set an MessageTransformer instance that is passed on to all Connection objects created from this ConnectionFactory. More... | |
virtual cms::MessageTransformer * | getMessageTransformer () const |
Gets the currently configured MessageTransformer for this ConnectionFactory. More... | |
void | setPrefetchPolicy (PrefetchPolicy *policy) |
Sets the PrefetchPolicy instance that this factory should use when it creates new Connection instances. More... | |
PrefetchPolicy * | getPrefetchPolicy () const |
Gets the pointer to the current PrefetchPolicy that is in use by this ConnectionFactory. More... | |
void | setRedeliveryPolicy (RedeliveryPolicy *policy) |
Sets the RedeliveryPolicy instance that this factory should use when it creates new Connection instances. More... | |
RedeliveryPolicy * | getRedeliveryPolicy () const |
Gets the pointer to the current RedeliveryPolicy that is in use by this ConnectionFactory. More... | |
bool | isDispatchAsync () const |
void | setDispatchAsync (bool value) |
Should messages be dispatched synchronously or asynchronously from the producer thread for non-durable topics in the broker? For fast consumers set this to false. More... | |
bool | isAlwaysSyncSend () const |
Gets if the Connection should always send things Synchronously. More... | |
void | setAlwaysSyncSend (bool value) |
Sets if the Connection should always send things Synchronously. More... | |
bool | isUseAsyncSend () const |
Gets if the useAsyncSend option is set. More... | |
void | setUseAsyncSend (bool value) |
Sets the useAsyncSend option. More... | |
bool | isSendAcksAsync () const |
Returns whether Message acknowledgments are sent asynchronously meaning no response is required from the broker before the ack completes. More... | |
void | setSendAcksAsync (bool sendAcksAsync) |
Sets whether Message acknowledgments are sent asynchronously meaning no response is required from the broker before the ack completes. More... | |
bool | isUseCompression () const |
Gets if the Connection is configured for Message body compression. More... | |
void | setUseCompression (bool value) |
Sets whether Message body compression is enabled. More... | |
void | setCompressionLevel (int value) |
Sets the Compression level used when Message body compression is enabled, a value of -1 causes the Compression Library to use the default setting which is a balance of speed and compression. More... | |
int | getCompressionLevel () const |
Gets the currently configured Compression level for Message bodies. More... | |
unsigned int | getSendTimeout () const |
Gets the assigned send timeout for this Connector. More... | |
void | setSendTimeout (unsigned int timeout) |
Sets the send timeout to use when sending Message objects, this will cause all messages to be sent using a Synchronous request is non-zero. More... | |
unsigned int | getCloseTimeout () const |
Gets the assigned close timeout for this Connector. More... | |
void | setCloseTimeout (unsigned int timeout) |
Sets the close timeout to use when sending the disconnect request. More... | |
unsigned int | getProducerWindowSize () const |
Gets the configured producer window size for Producers that are created from this connector. More... | |
void | setProducerWindowSize (unsigned int windowSize) |
Sets the size in Bytes of messages that a producer can send before it is blocked to await a ProducerAck from the broker that frees enough memory to allow another message to be sent. More... | |
bool | isMessagePrioritySupported () const |
void | setMessagePrioritySupported (bool value) |
Set whether or not this factory should create Connection objects with the Message priority support function enabled. More... | |
bool | isUseRetroactiveConsumer () const |
Should all created consumers be retroactive. More... | |
void | setUseRetroactiveConsumer (bool useRetroactiveConsumer) |
Sets whether or not retroactive consumers are enabled. More... | |
bool | isExclusiveConsumer () const |
Should all created consumers be exclusive. More... | |
void | setExclusiveConsumer (bool exclusiveConsumer) |
Enables or disables whether or not queue consumers should be exclusive or not for example to preserve ordering when not using Message Groups. More... | |
bool | isWatchTopicAdvisories () const |
Is the Connection created by this factory configured to watch for advisory messages that inform the Connection about temporary destination create / destroy. More... | |
void | setWatchTopicAdvisories (bool value) |
Sets whether Connection's created by this factory will listen for advisory messages regarding temporary destination creation and deletion. More... | |
int | getAuditDepth () const |
Get the audit depth for Messages for consumers when using a fault tolerant transport. More... | |
void | setAuditDepth (int auditDepth) |
Set the audit depth for Messages for consumers when using a fault tolerant transport. More... | |
int | getAuditMaximumProducerNumber () const |
The number of Producers that will be audited. More... | |
void | setAuditMaximumProducerNumber (int auditMaximumProducerNumber) |
The number of Producers that will be audited. More... | |
bool | isCheckForDuplicates () const |
Gets the value of the configured Duplicate Message detection feature. More... | |
void | setCheckForDuplicates (bool checkForDuplicates) |
Gets the value of the configured Duplicate Message detection feature. More... | |
bool | isTransactedIndividualAck () const |
when true, submit individual transacted acks immediately rather than with transaction completion. More... | |
void | setTransactedIndividualAck (bool transactedIndividualAck) |
when true, submit individual transacted acks immediately rather than with transaction completion. More... | |
bool | isNonBlockingRedelivery () const |
Returns true if non-blocking redelivery of Messages is configured for Consumers that are rolled back or recovered. More... | |
void | setNonBlockingRedelivery (bool nonBlockingRedelivery) |
When true a MessageConsumer will not stop Message delivery before re-delivering Messages from a rolled back transaction. More... | |
long long | getConsumerFailoverRedeliveryWaitPeriod () const |
Gets the delay period for a consumer redelivery. More... | |
void | setConsumerFailoverRedeliveryWaitPeriod (long long value) |
Sets the delay period for a consumer redelivery. More... | |
bool | isOptimizeAcknowledge () const |
void | setOptimizeAcknowledge (bool optimizeAcknowledge) |
Sets if Consumers are configured to use Optimized Acknowledge by default. More... | |
long long | getOptimizeAcknowledgeTimeOut () const |
Gets the time between optimized ack batches in milliseconds. More... | |
void | setOptimizeAcknowledgeTimeOut (long long optimizeAcknowledgeTimeOut) |
The max time in milliseconds between optimized ack batches. More... | |
long long | getOptimizedAckScheduledAckInterval () const |
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. More... | |
void | setOptimizedAckScheduledAckInterval (long long optimizedAckScheduledAckInterval) |
Sets the amount of time between scheduled sends of any outstanding Message Acks for consumers that have been configured with optimizeAcknowledge enabled. More... | |
bool | isAlwaysSessionAsync () const |
Returns the current value of the always session async option. More... | |
void | setAlwaysSessionAsync (bool alwaysSessionAsync) |
If this flag is not set 'true' then a separate thread is not used for dispatching messages for each Session in the Connection. More... | |
bool | isConsumerExpiryCheckEnabled () |
void | setConsumerExpiryCheckEnabled (bool consumerExpiryCheckEnabled) |
Configures whether this consumer will perform message expiration processing on all incoming messages. More... | |
Public Member Functions inherited from cms::ConnectionFactory | |
virtual | ~ConnectionFactory () |
Static Public Member Functions | |
static cms::Connection * | createConnection (const std::string &uri, const std::string &username, const std::string &password, const std::string &clientId="") |
Creates a connection with the specified user identity. More... | |
Static Public Member Functions inherited from cms::ConnectionFactory | |
static cms::ConnectionFactory * | createCMSConnectionFactory (const std::string &brokerURI) |
Static method that is used to create a provider specific connection factory. More... | |
Static Public Attributes | |
static const std::string | DEFAULT_URI |
Protected Member Functions | |
virtual ActiveMQConnection * | createActiveMQConnection (const Pointer< transport::Transport > &transport, const Pointer< decaf::util::Properties > &properties) |
Create a new ActiveMQConnection instnace using the provided Transport and Properties. More... | |
activemq::core::ActiveMQConnectionFactory::ActiveMQConnectionFactory | ( | ) |
activemq::core::ActiveMQConnectionFactory::ActiveMQConnectionFactory | ( | const std::string & | uri, |
const std::string & | username = "" , |
||
const std::string & | password = "" |
||
) |
Constructor.
uri | The URI of the Broker we are connecting to. |
username | The user name to authenticate with this connection. |
password | The password to authenticate with this connection. |
activemq::core::ActiveMQConnectionFactory::ActiveMQConnectionFactory | ( | const decaf::net::URI & | uri, |
const std::string & | username = "" , |
||
const std::string & | password = "" |
||
) |
Constructor.
uri | The URI of the Broker we are connecting to. |
username | The user name to authenticate with this connection. |
password | The password to authenticate with this connection. |
|
virtual |
|
protectedvirtual |
Create a new ActiveMQConnection instnace using the provided Transport and Properties.
Subclasses can override this to control the actual type of ActiveMQConnection that is created.
transport | The Transport that the Connection should use to communicate with the Broker. |
properties | The Properties that are assigned to the new Connection instance. |
Reimplemented in activemq::core::ActiveMQXAConnectionFactory.
|
virtual |
Creates a connection with the default user identity.
The connection is created in stopped mode. No messages will be delivered until the Connection.start method is explicitly called.
CMSException | if an error occurs. |
Implements cms::ConnectionFactory.
|
virtual |
Creates a connection with the specified user identity.
The connection is created in stopped mode. No messages will be delivered until the Connection.start method is explicitly called. The user name and password values passed here do not change the defaults, subsequent calls to the parameterless createConnection will continue to use the default values that were set in the Constructor.
username | The user name to authenticate with this connection. |
password | The password to authenticate with this connection. |
CMSSecurityException | if the user credentials are invalid. |
CMSException | if an error occurs. |
Implements cms::ConnectionFactory.
|
virtual |
Creates a connection with the specified user identity.
The connection is created in stopped mode. No messages will be delivered until the Connection.start method is explicitly called. The username and password values passed here do not change the defaults, subsequent calls to the parameterless createConnection will continue to use the default values that were set in the Constructor.
username | The user name to authenticate with this connection. |
password | The password to authenticate with this connection. |
clientId | The client Id to assign to connection if "" then a random client Id is created for this connection. |
CMSSecurityException | if the user credentials are invalid. |
CMSException | if an error occurs. |
Implements cms::ConnectionFactory.
|
static |
Creates a connection with the specified user identity.
The connection is created in stopped mode. No messages will be delivered until the Connection.start method is explicitly called.
uri | The URI of the Broker we are connecting to. |
username | The name of the user to authenticate with. |
password | The password for the user to authenticate with. |
clientId | The unique client id to assign to connection, defaults to "". |
CMSException. |
int activemq::core::ActiveMQConnectionFactory::getAuditDepth | ( | ) | const |
Get the audit depth for Messages for consumers when using a fault tolerant transport.
The higher the value the more messages are checked for duplication, and the larger the performance impact of duplicate detection will be.
int activemq::core::ActiveMQConnectionFactory::getAuditMaximumProducerNumber | ( | ) | const |
The number of Producers that will be audited.
const decaf::net::URI& activemq::core::ActiveMQConnectionFactory::getBrokerURI | ( | ) | const |
Gets the Broker URI that this factory will use when creating a new connection instance.
std::string activemq::core::ActiveMQConnectionFactory::getClientId | ( | ) | const |
Gets the Configured Client Id.
unsigned int activemq::core::ActiveMQConnectionFactory::getCloseTimeout | ( | ) | const |
Gets the assigned close timeout for this Connector.
int activemq::core::ActiveMQConnectionFactory::getCompressionLevel | ( | ) | const |
Gets the currently configured Compression level for Message bodies.
long long activemq::core::ActiveMQConnectionFactory::getConsumerFailoverRedeliveryWaitPeriod | ( | ) | const |
Gets the delay period for a consumer redelivery.
|
virtual |
Returns the currently set ExceptionListener that will be set on any new Connection instance that is created by this factory.
Implements cms::ConnectionFactory.
|
virtual |
Gets the currently configured MessageTransformer for this ConnectionFactory.
Implements cms::ConnectionFactory.
long long activemq::core::ActiveMQConnectionFactory::getOptimizeAcknowledgeTimeOut | ( | ) | const |
Gets the time between optimized ack batches in milliseconds.
long long activemq::core::ActiveMQConnectionFactory::getOptimizedAckScheduledAckInterval | ( | ) | const |
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.
const std::string& activemq::core::ActiveMQConnectionFactory::getPassword | ( | ) | const |
Gets the password that this factory will use when creating a new connection instance.
PrefetchPolicy* activemq::core::ActiveMQConnectionFactory::getPrefetchPolicy | ( | ) | const |
Gets the pointer to the current PrefetchPolicy that is in use by this ConnectionFactory.
unsigned int activemq::core::ActiveMQConnectionFactory::getProducerWindowSize | ( | ) | const |
Gets the configured producer window size for Producers that are created from this connector.
This only applies if there is no send timeout and the producer is able to send asynchronously.
RedeliveryPolicy* activemq::core::ActiveMQConnectionFactory::getRedeliveryPolicy | ( | ) | const |
Gets the pointer to the current RedeliveryPolicy that is in use by this ConnectionFactory.
unsigned int activemq::core::ActiveMQConnectionFactory::getSendTimeout | ( | ) | const |
Gets the assigned send timeout for this Connector.
const std::string& activemq::core::ActiveMQConnectionFactory::getUsername | ( | ) | const |
Gets the username that this factory will use when creating a new connection instance.
bool activemq::core::ActiveMQConnectionFactory::isAlwaysSessionAsync | ( | ) | const |
Returns the current value of the always session async option.
bool activemq::core::ActiveMQConnectionFactory::isAlwaysSyncSend | ( | ) | const |
Gets if the Connection should always send things Synchronously.
bool activemq::core::ActiveMQConnectionFactory::isCheckForDuplicates | ( | ) | const |
Gets the value of the configured Duplicate Message detection feature.
When enabled and a fault tolerant transport is used (think failover) then this feature will help to detect and filter duplicate messages that might otherwise be delivered to a consumer after a connection failure.
Disabling this can increase performance since no Message auditing will occur.
bool activemq::core::ActiveMQConnectionFactory::isConsumerExpiryCheckEnabled | ( | ) |
bool activemq::core::ActiveMQConnectionFactory::isDispatchAsync | ( | ) | const |
bool activemq::core::ActiveMQConnectionFactory::isExclusiveConsumer | ( | ) | const |
Should all created consumers be exclusive.
bool activemq::core::ActiveMQConnectionFactory::isMessagePrioritySupported | ( | ) | const |
bool activemq::core::ActiveMQConnectionFactory::isNonBlockingRedelivery | ( | ) | const |
Returns true if non-blocking redelivery of Messages is configured for Consumers that are rolled back or recovered.
bool activemq::core::ActiveMQConnectionFactory::isOptimizeAcknowledge | ( | ) | const |
bool activemq::core::ActiveMQConnectionFactory::isSendAcksAsync | ( | ) | const |
Returns whether Message acknowledgments are sent asynchronously meaning no response is required from the broker before the ack completes.
bool activemq::core::ActiveMQConnectionFactory::isTransactedIndividualAck | ( | ) | const |
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 KahaDB set to Rewrite On Redelivery.
bool activemq::core::ActiveMQConnectionFactory::isUseAsyncSend | ( | ) | const |
Gets if the useAsyncSend option is set.
bool activemq::core::ActiveMQConnectionFactory::isUseCompression | ( | ) | const |
Gets if the Connection is configured for Message body compression.
bool activemq::core::ActiveMQConnectionFactory::isUseRetroactiveConsumer | ( | ) | const |
Should all created consumers be retroactive.
bool activemq::core::ActiveMQConnectionFactory::isWatchTopicAdvisories | ( | ) | const |
Is the Connection created by this factory configured to watch for advisory messages that inform the Connection about temporary destination create / destroy.
void activemq::core::ActiveMQConnectionFactory::setAlwaysSessionAsync | ( | bool | alwaysSessionAsync | ) |
If this flag is not set 'true' 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.
alwaysSessionAsync | The alwaysSessionAsync value to use when creating new sessions. |
void activemq::core::ActiveMQConnectionFactory::setAlwaysSyncSend | ( | bool | value | ) |
Sets if the Connection should always send things Synchronously.
value | true if sends should always be Synchronous. |
void activemq::core::ActiveMQConnectionFactory::setAuditDepth | ( | int | auditDepth | ) |
Set the audit depth for Messages for consumers when using a fault tolerant transport.
The higher the value the more messages are checked for duplication, and the larger the performance impact of duplicate detection will be.
auditDepth | The configured audit depth. |
void activemq::core::ActiveMQConnectionFactory::setAuditMaximumProducerNumber | ( | int | auditMaximumProducerNumber | ) |
The number of Producers that will be audited.
auditMaximumProducerNumber | The configured number of producers to include in the audit. |
void activemq::core::ActiveMQConnectionFactory::setBrokerURI | ( | const std::string & | uri | ) |
Sets the Broker URI that should be used when creating a new connection instance.
uri | The string form of the Broker URI, this will be converted to a URI object. |
void activemq::core::ActiveMQConnectionFactory::setBrokerURI | ( | const decaf::net::URI & | uri | ) |
Sets the Broker URI that should be used when creating a new connection instance.
uri | The URI of the broker that this client will connect to. |
void activemq::core::ActiveMQConnectionFactory::setCheckForDuplicates | ( | bool | checkForDuplicates | ) |
Gets the value of the configured Duplicate Message detection feature.
When enabled and a fault tolerant transport is used (think failover) then this feature will help to detect and filter duplicate messages that might otherwise be delivered to a consumer after a connection failure.
Disabling this can increase performance since no Message auditing will occur.
checkForDuplicates | The checkForDuplicates value to be configured. |
void activemq::core::ActiveMQConnectionFactory::setClientId | ( | const std::string & | clientId | ) |
Sets the Client Id.
clientId | - The new clientId value. |
void activemq::core::ActiveMQConnectionFactory::setCloseTimeout | ( | unsigned int | timeout | ) |
Sets the close timeout to use when sending the disconnect request.
timeout | - The time to wait for a close message. |
void activemq::core::ActiveMQConnectionFactory::setCompressionLevel | ( | int | value | ) |
Sets the Compression level used when Message body compression is enabled, a value of -1 causes the Compression Library to use the default setting which is a balance of speed and compression.
The range of compression levels is [0..9] where 0 indicates best speed and 9 indicates best compression.
value | A signed int value that controls the compression level. |
void activemq::core::ActiveMQConnectionFactory::setConsumerExpiryCheckEnabled | ( | bool | consumerExpiryCheckEnabled | ) |
Configures whether this consumer will perform message expiration processing on all incoming messages.
This feature is enabled by default.
consumerExpiryCheckEnabled | False if the default message expiration checks should be disabled. |
void activemq::core::ActiveMQConnectionFactory::setConsumerFailoverRedeliveryWaitPeriod | ( | long long | value | ) |
Sets the delay period for a consumer redelivery.
value | The configured time delay in milliseconds. |
void activemq::core::ActiveMQConnectionFactory::setDispatchAsync | ( | bool | value | ) |
Should messages be dispatched synchronously or asynchronously from the producer thread for non-durable topics in the broker? For fast consumers set this to false.
For slow consumers set it to true so that dispatching will not block fast consumers. .
value | The value of the dispatch asynchronously option sent to the broker. |
|
virtual |
Set an CMS ExceptionListener that will be set on eat connection once it has been created.
The factory does not take ownership of this pointer, the client must ensure that its lifetime is scoped to the connection that it is applied to.
listener | The listener to set on the connection or NULL for no listener. |
Implements cms::ConnectionFactory.
void activemq::core::ActiveMQConnectionFactory::setExclusiveConsumer | ( | bool | exclusiveConsumer | ) |
Enables or disables whether or not queue consumers should be exclusive or not for example to preserve ordering when not using Message Groups.
exclusiveConsumer | The value of this configuration option. |
void activemq::core::ActiveMQConnectionFactory::setMessagePrioritySupported | ( | bool | value | ) |
Set whether or not this factory should create Connection objects with the Message priority support function enabled.
value | Boolean indicating if Message priority should be enabled. |
|
virtual |
Set an MessageTransformer instance that is passed on to all Connection objects created from this ConnectionFactory.
transformer | Pointer to the cms::MessageTransformer to set on all newly created Connection objects. |
Implements cms::ConnectionFactory.
void activemq::core::ActiveMQConnectionFactory::setNonBlockingRedelivery | ( | bool | nonBlockingRedelivery | ) |
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.
nonBlockingRedelivery | The value to configure for non-blocking redelivery. |
void activemq::core::ActiveMQConnectionFactory::setOptimizeAcknowledge | ( | bool | optimizeAcknowledge | ) |
Sets if Consumers are configured to use Optimized Acknowledge by default.
optimizeAcknowledge | The optimizeAcknowledge mode to set. |
void activemq::core::ActiveMQConnectionFactory::setOptimizeAcknowledgeTimeOut | ( | long long | optimizeAcknowledgeTimeOut | ) |
The max time in milliseconds between optimized ack batches.
optimizeAcknowledgeTimeOut | The time in milliseconds for optimized ack batches. |
void activemq::core::ActiveMQConnectionFactory::setOptimizedAckScheduledAckInterval | ( | long long | optimizedAckScheduledAckInterval | ) |
Sets the amount of time between scheduled sends of any outstanding Message Acks for consumers that have been configured with optimizeAcknowledge enabled.
Time is given in Milliseconds.
optimizedAckScheduledAckInterval | The scheduledOptimizedAckInterval to use for new Consumers. |
void activemq::core::ActiveMQConnectionFactory::setPassword | ( | const std::string & | password | ) |
Sets the password that should be used when creating a new connection.
password | string |
void activemq::core::ActiveMQConnectionFactory::setPrefetchPolicy | ( | PrefetchPolicy * | policy | ) |
Sets the PrefetchPolicy instance that this factory should use when it creates new Connection instances.
The PrefetchPolicy passed becomes the property of the factory and will be deleted when the factory is destroyed.
policy | The new PrefetchPolicy that the ConnectionFactory should clone for Connections. |
void activemq::core::ActiveMQConnectionFactory::setProducerWindowSize | ( | unsigned int | windowSize | ) |
Sets the size in Bytes of messages that a producer can send before it is blocked to await a ProducerAck from the broker that frees enough memory to allow another message to be sent.
windowSize | - The size in bytes of the Producers memory window. |
void activemq::core::ActiveMQConnectionFactory::setRedeliveryPolicy | ( | RedeliveryPolicy * | policy | ) |
Sets the RedeliveryPolicy instance that this factory should use when it creates new Connection instances.
The RedeliveryPolicy passed becomes the property of the factory and will be deleted when the factory is destroyed.
policy | The new RedeliveryPolicy that the ConnectionFactory should clone for Connections. |
void activemq::core::ActiveMQConnectionFactory::setSendAcksAsync | ( | bool | sendAcksAsync | ) |
Sets whether Message acknowledgments are sent asynchronously meaning no response is required from the broker before the ack completes.
sendAcksAsync | The sendAcksAsync configuration value to set. |
void activemq::core::ActiveMQConnectionFactory::setSendTimeout | ( | unsigned int | timeout | ) |
Sets the send timeout to use when sending Message objects, this will cause all messages to be sent using a Synchronous request is non-zero.
timeout | - The time to wait for a response. |
void activemq::core::ActiveMQConnectionFactory::setTransactedIndividualAck | ( | bool | transactedIndividualAck | ) |
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 KahaDB set to Rewrite On Redelivery.
transactedIndividualAck | The value to set. |
void activemq::core::ActiveMQConnectionFactory::setUseAsyncSend | ( | bool | value | ) |
Sets the useAsyncSend option.
value | - true to activate, false to disable. |
void activemq::core::ActiveMQConnectionFactory::setUseCompression | ( | bool | value | ) |
Sets whether Message body compression is enabled.
value | Boolean indicating if Message body compression is enabled. |
void activemq::core::ActiveMQConnectionFactory::setUseRetroactiveConsumer | ( | bool | useRetroactiveConsumer | ) |
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.
useRetroactiveConsumer | The value of this configuration option. |
void activemq::core::ActiveMQConnectionFactory::setUsername | ( | const std::string & | username | ) |
Sets the username that should be used when creating a new connection.
username | string |
void activemq::core::ActiveMQConnectionFactory::setWatchTopicAdvisories | ( | bool | value | ) |
Sets whether Connection's created by this factory will listen for advisory messages regarding temporary destination creation and deletion.
value | Boolean indicating if advisory message monitoring should be enabled. |
|
static |