Public Member Functions |
| ActiveMQXAConnection (const Pointer< transport::Transport > &transport, const Pointer< decaf::util::Properties > &properties) |
virtual | ~ActiveMQXAConnection () |
virtual cms::XASession * | createXASession () |
| Creates an XASession object.
|
virtual cms::Session * | createSession (cms::Session::AcknowledgeMode ackMode) |
| Creates a new Session to work for this Connection using the specified acknowledgment mode.- Parameters
-
ackMode | the Acknowledgment Mode to use. |
- Exceptions
-
|
virtual | ~XAConnection () |
virtual | ~Connection () |
virtual | ~Startable () |
virtual | ~Stoppable () |
virtual | ~Closeable () |
| ActiveMQConnection (const Pointer< transport::Transport > transport, const Pointer< decaf::util::Properties > properties) |
| Constructor.
|
virtual | ~ActiveMQConnection () |
virtual void | addSession (Pointer< activemq::core::kernels::ActiveMQSessionKernel > session) |
| Adds the session resources for the given session instance.
|
virtual void | removeSession (Pointer< activemq::core::kernels::ActiveMQSessionKernel > session) |
| Removes the session resources for the given session instance.
|
virtual void | addProducer (Pointer< kernels::ActiveMQProducerKernel > producer) |
| Adds an active Producer to the Set of known producers.
|
virtual void | removeProducer (const Pointer< commands::ProducerId > &producerId) |
| Removes an active Producer to the Set of known producers.
|
virtual void | addDispatcher (const Pointer< commands::ConsumerId > &consumer, Dispatcher *dispatcher) |
| Adds a dispatcher for a consumer.
|
virtual void | removeDispatcher (const Pointer< commands::ConsumerId > &consumer) |
| Removes the dispatcher for a consumer.
|
virtual void | sendPullRequest (const commands::ConsumerInfo *consumer, long long timeout) |
| If supported sends a message pull request to the service provider asking for the delivery of a new message.
|
bool | isClosed () const |
| Checks if this connection has been closed.
|
bool | isStarted () const |
| Check if this connection has been started.
|
bool | isTransportFailed () const |
| Checks if the Connection's Transport has failed.
|
virtual void | destroyDestination (const commands::ActiveMQDestination *destination) |
| Requests that the Broker removes the given Destination.
|
virtual void | destroyDestination (const cms::Destination *destination) |
| Requests that the Broker removes the given Destination.
|
virtual const
cms::ConnectionMetaData * | getMetaData () const |
| Gets the metadata for this connection.- Returns
- the connection MetaData pointer ( caller does not own it ).
- Exceptions
-
CMSException | if the provider fails to get the connection metadata for this connection. |
- See Also
- ConnectionMetaData
- Since
- 2.0
|
virtual cms::Session * | createSession () |
| Creates an AUTO_ACKNOWLEDGE Session.- Exceptions
-
|
virtual std::string | getClientID () const |
| Get the Client Id for this session, the client Id is provider specific and is either assigned by the connection factory or set using the setClientID method.- Returns
- Client Id String for this Connection.
- Exceptions
-
CMSException | if the provider fails to return the client id or an internal error occurs. |
|
virtual void | setClientID (const std::string &clientID) |
| Sets the client identifier for this connection.The preferred way to assign a CMS client's client identifier is for it to be configured in a client-specific ConnectionFactory object and transparently assigned to the Connection object it creates.If a client sets the client identifier explicitly, it must do so immediately after it creates the connection and before any other action on the connection is taken. After this point, setting the client identifier is a programming error that should throw an IllegalStateException.- Parameters
-
clientID | The unique client identifier to assign to the Connection. |
- Exceptions
-
CMSException | if the provider fails to set the client id due to some internal error. |
InvalidClientIDException | if the id given is somehow invalid or is a duplicate. |
IllegalStateException | if the client tries to set the id after a Connection method has been called. |
|
virtual void | close () |
| Closes this connection as well as any Sessions created from it (and those Sessions' consumers and producers).- Exceptions
-
|
virtual void | start () |
| Starts the service.- Exceptions
-
|
virtual void | stop () |
| Stops this service.- Exceptions
-
CMSException | - if an internal error occurs while stopping the Service. |
|
virtual cms::ExceptionListener * | getExceptionListener () const |
| Gets the registered Exception Listener for this connection.- Returns
- pointer to an exception listener or NULL
|
virtual void | setExceptionListener (cms::ExceptionListener *listener) |
| Sets the registered Exception Listener for this connection.- Parameters
-
|
virtual void | setMessageTransformer (cms::MessageTransformer *transformer) |
| Set an MessageTransformer instance that is passed on to all Session objects created from this Connection.The CMS code never takes ownership of the MessageTransformer pointer which implies that the client code must ensure that the object remains valid for the lifetime of the CMS object to which the MessageTransformer has been assigned.- Parameters
-
|
virtual cms::MessageTransformer * | getMessageTransformer () const |
| Gets the currently configured MessageTransformer for this Connection.- Returns
- the pointer to the currently set cms::MessageTransformer.
|
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.
|
void | setDefaultClientId (const std::string &clientId) |
| Sets the Client Id.
|
void | setBrokerURL (const std::string &brokerURL) |
| Sets the Broker URL that should be used when creating a new connection instance.
|
const std::string & | getBrokerURL () const |
| Gets the Broker URL that this factory will use when creating a new connection instance.
|
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.
|
long long | getNextTempDestinationId () |
| Get the Next Temporary Destination Id.
|
long long | getNextLocalTransactionId () |
| Get the Next Temporary Destination Id.
|
bool | isWatchTopicAdvisories () const |
| Is the Connection configured to watch for advisory messages to maintain state of temporary destination create and destroy.
|
void | setWatchTopicAdvisories (bool value) |
| Sets whether this Connection is listening for advisory messages regarding temporary destination creation and deletion.
|
void | addTransportListener (transport::TransportListener *transportListener) |
| Adds a transport listener so that a client can be notified of events in the underlying transport, client's are always notified after the event has been processed by the Connection class.
|
void | removeTransportListener (transport::TransportListener *transportListener) |
| Removes a registered TransportListener from the Connection's set of Transport listeners, this listener will no longer receive any Transport related events.
|
virtual void | onCommand (const Pointer< commands::Command > command) |
| Event handler for the receipt of a non-response command from the transport.
|
virtual void | onException (const decaf::lang::Exception &ex) |
| Event handler for an exception from a command transport.
|
virtual void | transportInterrupted () |
| The transport has suffered an interruption from which it hopes to recover.
|
virtual void | transportResumed () |
| The transport has resumed after an interruption.
|
const commands::ConnectionInfo & | getConnectionInfo () const |
| Gets the ConnectionInfo for this Object, if the Connection is not open than this method throws an exception.
|
const commands::ConnectionId & | getConnectionId () const |
| Gets the ConnectionId for this Object, if the Connection is not open than this method throws an exception.
|
transport::Transport & | getTransport () const |
| Gets a reference to this object's Transport instance.
|
Pointer< threads::Scheduler > | getScheduler () const |
| Gets a reference to the Connection objects built in Scheduler instance.
|
std::string | getResourceManagerId () const |
| Returns the Id of the Resource Manager that this client will use should it be entered into an XA Transaction.
|
void | cleanup () |
| Clean up this connection object, reseting it back to a state that mirrors what a newly created ActiveMQConnection object has.
|
void | oneway (Pointer< commands::Command > command) |
| Sends a message without request that the broker send a response to indicate that it was received.
|
Pointer< commands::Response > | syncRequest (Pointer< commands::Command > command, unsigned int timeout=0) |
| Sends a synchronous request and returns the response from the broker.
|
void | asyncRequest (Pointer< commands::Command > command, cms::AsyncCallback *onComplete) |
| Sends a synchronous request and returns the response from the broker.
|
virtual void | fire (const exceptions::ActiveMQException &ex) |
| Notify the exception listener.
|
void | setTransportInterruptionProcessingComplete () |
| Indicates that a Connection resource that is processing the transportInterrupted event has completed.
|
void | setFirstFailureError (decaf::lang::Exception *error) |
| Sets the pointer to the first exception that caused the Connection to become failed.
|
decaf::lang::Exception * | getFirstFailureError () const |
| Gets the pointer to the first exception that caused the Connection to become failed.
|
void | onAsyncException (const decaf::lang::Exception &ex) |
| Event handler for dealing with async exceptions.
|
void | onClientInternalException (const decaf::lang::Exception &ex) |
| Handles async client internal exceptions which don't usually affect the connection itself.
|
void | checkClosed () const |
| Check for Closed State and Throw an exception if true.
|
void | checkClosedOrFailed () const |
| Check for Closed State and Failed State and Throw an exception if either is true.
|
void | ensureConnectionInfoSent () |
| If its not been sent, then send the ConnectionInfo to the Broker.
|
decaf::util::concurrent::ExecutorService * | getExecutor () const |
void | addTempDestination (Pointer< commands::ActiveMQTempDestination > destination) |
| Adds the given Temporary Destination to this Connections collection of known Temporary Destinations.
|
void | removeTempDestination (Pointer< commands::ActiveMQTempDestination > destination) |
| Removes the given Temporary Destination to this Connections collection of known Temporary Destinations.
|
void | deleteTempDestination (Pointer< commands::ActiveMQTempDestination > destination) |
| Removes the given Temporary Destination to this Connections collection of known Temporary Destinations.
|
void | cleanUpTempDestinations () |
| Removes any TempDestinations that this connection has cached, ignoring any exceptions generated because the destination is in use as they should not be removed.
|
bool | isDeleted (Pointer< commands::ActiveMQTempDestination > destination) const |
| Determines whether the supplied Temporary Destination has already been deleted from the Broker.
|