Public Member Functions |
| ActiveMQXAConnectionFactory () |
| ActiveMQXAConnectionFactory (const std::string &uri, const std::string &username="", const std::string &password="") |
| Constructor.
|
| ActiveMQXAConnectionFactory (const decaf::net::URI &uri, const std::string &username="", const std::string &password="") |
| Constructor.
|
virtual | ~ActiveMQXAConnectionFactory () |
virtual cms::XAConnection * | createXAConnection () |
| Creates an XAConnection with the default user name and password.
|
virtual cms::XAConnection * | createXAConnection (const std::string &userName, const std::string &password) |
| Creates an XA connection with the specified user name and password.
|
virtual | ~XAConnectionFactory () |
| ActiveMQConnectionFactory () |
| ActiveMQConnectionFactory (const std::string &uri, const std::string &username="", const std::string &password="") |
| Constructor.
|
| ActiveMQConnectionFactory (const decaf::net::URI &uri, const std::string &username="", const std::string &password="") |
| Constructor.
|
virtual | ~ActiveMQConnectionFactory () |
virtual cms::Connection * | createConnection () |
| Creates a connection with the default user identity.
|
virtual cms::Connection * | createConnection (const std::string &username, const std::string &password) |
| Creates a connection with the specified user identity.
|
virtual cms::Connection * | createConnection (const std::string &username, const std::string &password, const std::string &clientId) |
| Creates a connection with the specified user identity.
|
void | setUsername (const std::string &username) |
| Sets the username that should be used when creating a new connection.
|
const std::string & | getUsername () const |
| Gets the username that this factory will use when creating a new connection instance.
|
void | setPassword (const std::string &password) |
| Sets the password that should be used when creating a new connection.
|
const std::string & | getPassword () const |
| Gets the password that this factory will use when creating a new connection instance.
|
std::string | getClientId () const |
| Gets the Configured Client Id.
|
void | setClientId (const std::string &clientId) |
| Sets the Client Id.
|
void | setBrokerURI (const std::string &uri) |
| Sets the Broker URI that should be used when creating a new connection instance.
|
void | setBrokerURI (const decaf::net::URI &uri) |
| Sets the Broker URI that should be used when creating a new connection instance.
|
const decaf::net::URI & | getBrokerURI () const |
| Gets the Broker URI that this factory will use when creating a new connection instance.
|
virtual void | setExceptionListener (cms::ExceptionListener *listener) |
| Set an CMS ExceptionListener that will be set on eat connection once it has been created.
|
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.
|
virtual void | setMessageTransformer (cms::MessageTransformer *transformer) |
| Set an MessageTransformer instance that is passed on to all Connection objects created from this ConnectionFactory.
|
virtual cms::MessageTransformer * | getMessageTransformer () const |
| Gets the currently configured MessageTransformer for this ConnectionFactory.
|
void | setPrefetchPolicy (PrefetchPolicy *policy) |
| Sets the PrefetchPolicy instance that this factory should use when it creates new Connection instances.
|
PrefetchPolicy * | getPrefetchPolicy () const |
| Gets the pointer to the current PrefetchPolicy that is in use by this ConnectionFactory.
|
void | setRedeliveryPolicy (RedeliveryPolicy *policy) |
| Sets the RedeliveryPolicy instance that this factory should use when it creates new Connection instances.
|
RedeliveryPolicy * | getRedeliveryPolicy () const |
| Gets the pointer to the current RedeliveryPolicy that is in use by this ConnectionFactory.
|
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.
|
bool | isAlwaysSyncSend () const |
| Gets if the Connection should always send things Synchronously.
|
void | setAlwaysSyncSend (bool value) |
| Sets if the Connection should always send things Synchronously.
|
bool | isUseAsyncSend () const |
| Gets if the useAsyncSend option is set.
|
void | setUseAsyncSend (bool value) |
| Sets the useAsyncSend option.
|
bool | isUseCompression () const |
| Gets if the Connection is configured for Message body compression.
|
void | setUseCompression (bool value) |
| Sets whether Message body compression is enabled.
|
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.
|
int | getCompressionLevel () const |
| Gets the currently configured Compression level for Message bodies.
|
unsigned int | getSendTimeout () const |
| Gets the assigned send timeout for this Connector.
|
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.
|
unsigned int | getCloseTimeout () const |
| Gets the assigned close timeout for this Connector.
|
void | setCloseTimeout (unsigned int timeout) |
| Sets the close timeout to use when sending the disconnect request.
|
unsigned int | getProducerWindowSize () const |
| Gets the configured producer window size for Producers that are created from this connector.
|
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.
|
bool | isMessagePrioritySupported () const |
void | setMessagePrioritySupported (bool value) |
| Set whether or not this factory should create Connection objects with the Message priority support function enabled.
|
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.
|
void | setWatchTopicAdvisories (bool value) |
| Sets whether Connection's created by this factory will listen for advisory messages regarding temporary destination creation and deletion.
|
virtual | ~ConnectionFactory () |