activemq-cpp-3.6.0
|
#include <src/main/activemq/core/kernels/ActiveMQSessionKernel.h>
Public Member Functions | |
ActiveMQSessionKernel (ActiveMQConnection *connection, const Pointer< commands::SessionId > &id, cms::Session::AcknowledgeMode ackMode, const decaf::util::Properties &properties) | |
virtual | ~ActiveMQSessionKernel () |
virtual void | redispatch (MessageDispatchChannel &unconsumedMessages) |
Redispatches the given set of unconsumed messages to the consumers. | |
virtual void | start () |
Stops asynchronous message delivery. | |
virtual void | stop () |
Starts asynchronous message delivery. | |
bool | isStarted () const |
Indicates whether or not the session is currently in the started state. | |
virtual bool | isAutoAcknowledge () const |
virtual bool | isDupsOkAcknowledge () const |
virtual bool | isClientAcknowledge () const |
virtual bool | isIndividualAcknowledge () const |
void | fire (const exceptions::ActiveMQException &ex) |
Fires the given exception to the exception listener of the connection. | |
virtual void | dispatch (const Pointer< MessageDispatch > &message) |
Dispatches a message to a particular consumer. | |
virtual void | close () |
Closes this session as well as any active child consumers or producers. | |
virtual void | commit () |
Commits all messages done in this transaction and releases any locks currently held. | |
virtual void | rollback () |
Rolls back all messages done in this transaction and releases any locks currently held. | |
virtual void | recover () |
Stops message delivery in this session, and restarts message delivery with the oldest unacknowledged message. | |
virtual cms::MessageConsumer * | createConsumer (const cms::Destination *destination) |
Creates a MessageConsumer for the specified destination. | |
virtual cms::MessageConsumer * | createConsumer (const cms::Destination *destination, const std::string &selector) |
Creates a MessageConsumer for the specified destination, using a message selector. | |
virtual cms::MessageConsumer * | createConsumer (const cms::Destination *destination, const std::string &selector, bool noLocal) |
Creates a MessageConsumer for the specified destination, using a message selector. | |
virtual cms::MessageConsumer * | createDurableConsumer (const cms::Topic *destination, const std::string &name, const std::string &selector, bool noLocal=false) |
Creates a durable subscriber to the specified topic, using a Message selector. | |
virtual cms::MessageProducer * | createProducer (const cms::Destination *destination) |
Creates a MessageProducer to send messages to the specified destination. | |
virtual cms::QueueBrowser * | createBrowser (const cms::Queue *queue) |
Creates a new QueueBrowser to peek at Messages on the given Queue. | |
virtual cms::QueueBrowser * | createBrowser (const cms::Queue *queue, const std::string &selector) |
Creates a new QueueBrowser to peek at Messages on the given Queue. | |
virtual cms::Queue * | createQueue (const std::string &queueName) |
Creates a queue identity given a Queue name. | |
virtual cms::Topic * | createTopic (const std::string &topicName) |
Creates a topic identity given a Queue name. | |
virtual cms::TemporaryQueue * | createTemporaryQueue () |
Creates a TemporaryQueue object. | |
virtual cms::TemporaryTopic * | createTemporaryTopic () |
Creates a TemporaryTopic object. | |
virtual cms::Message * | createMessage () |
Creates a new Message. | |
virtual cms::BytesMessage * | createBytesMessage () |
Creates a BytesMessage. | |
virtual cms::BytesMessage * | createBytesMessage (const unsigned char *bytes, int bytesSize) |
Creates a BytesMessage and sets the payload to the passed value. | |
virtual cms::StreamMessage * | createStreamMessage () |
Creates a new StreamMessage. | |
virtual cms::TextMessage * | createTextMessage () |
Creates a new TextMessage. | |
virtual cms::TextMessage * | createTextMessage (const std::string &text) |
Creates a new TextMessage and set the text to the value given. | |
virtual cms::MapMessage * | createMapMessage () |
Creates a new MapMessage. | |
virtual cms::Session::AcknowledgeMode | getAcknowledgeMode () const |
Returns the acknowledgment mode of the session. | |
virtual bool | isTransacted () const |
Gets if the Sessions is a Transacted Session. | |
virtual void | unsubscribe (const std::string &name) |
Unsubscribes a durable subscription that has been created by a client. | |
void | send (kernels::ActiveMQProducerKernel *producer, Pointer< commands::ActiveMQDestination > destination, cms::Message *message, int deliveryMode, int priority, long long timeToLive, util::MemoryUsage *producerWindow, long long sendTimeout, cms::AsyncCallback *onComplete) |
Sends a message from the Producer specified using this session's connection the message will be sent using the best available means depending on the configuration of the connection. | |
cms::ExceptionListener * | getExceptionListener () |
This method gets any registered exception listener of this sessions connection and returns it. | |
virtual void | setMessageTransformer (cms::MessageTransformer *transformer) |
Set an MessageTransformer instance that is passed on to all MessageProducer and MessageConsumer objects created from this Session. | |
virtual cms::MessageTransformer * | getMessageTransformer () const |
Gets the currently configured MessageTransformer for this Session. | |
const commands::SessionInfo & | getSessionInfo () const |
Gets the Session Information object for this session, if the session is closed than this method throws an exception. | |
const commands::SessionId & | getSessionId () const |
Gets the Session Id object for this session, if the session is closed than this method throws an exception. | |
ActiveMQConnection * | getConnection () const |
Gets the ActiveMQConnection that is associated with this session. | |
Pointer< threads::Scheduler > | getScheduler () const |
Gets a Pointer to this Session's Scheduler instance. | |
long long | getLastDeliveredSequenceId () const |
Gets the currently set Last Delivered Sequence Id. | |
void | setLastDeliveredSequenceId (long long value) |
Sets the value of the Last Delivered Sequence Id. | |
void | oneway (Pointer< commands::Command > command) |
Sends a Command to the broker without requesting any Response be returned. | |
Pointer< commands::Response > | syncRequest (Pointer< commands::Command > command, unsigned int timeout=0) |
Sends a synchronous request and returns the response from the broker. | |
void | addConsumer (Pointer< ActiveMQConsumerKernel > consumer) |
Adds a MessageConsumerKernel to this session registering it with the Connection and store a reference to it so the session can ensure that all resources are closed when the session is closed. | |
void | removeConsumer (Pointer< ActiveMQConsumerKernel > consumer) |
Dispose of a MessageConsumer from this session. | |
void | addProducer (Pointer< ActiveMQProducerKernel > producer) |
Adds a MessageProducer to this session registering it with the Connection and store a reference to it so the session can ensure that all resources are closed when the session is closed. | |
void | removeProducer (Pointer< ActiveMQProducerKernel > producer) |
Dispose of a MessageProducer from this session. | |
virtual void | doStartTransaction () |
Starts if not already start a Transaction for this Session. | |
Pointer < ActiveMQTransactionContext > | getTransactionContext () |
Gets the Pointer to this Session's TransactionContext. | |
void | acknowledge () |
Request that the Session inform all its consumers to Acknowledge all Message's that have been received so far. | |
void | deliverAcks () |
Request that this Session inform all of its consumers to deliver their pending acks. | |
void | clearMessagesInProgress () |
Request that this Session inform all of its consumers to clear all messages that are currently in progress. | |
void | wakeup () |
Causes the Session to wakeup its executer and ensure all messages are dispatched. | |
Pointer< commands::ConsumerId > | getNextConsumerId () |
Get the Next available Consumer Id. | |
Pointer< commands::ProducerId > | getNextProducerId () |
Get the Next available Producer Id. | |
void | doClose () |
Performs the actual Session close operations. | |
void | dispose () |
Cleans up the Session object's resources without attempting to send the Remove command to the broker, this can be called from ActiveMQConnection when it knows that the transport is down and the doClose method would throw an exception when it attempt to send the Remove Command. | |
void | setPrefetchSize (Pointer< commands::ConsumerId > id, int prefetch) |
Set the prefetch level for the given consumer if it exists in this Session to the value specified. | |
void | close (Pointer< commands::ConsumerId > id) |
Close the specified consumer if present in this Session. | |
bool | isInUse (Pointer< commands::ActiveMQDestination > destination) |
Checks if the given destination is currently in use by any consumers in this Session. | |
Pointer< ActiveMQProducerKernel > | lookupProducerKernel (Pointer< commands::ProducerId > id) |
Pointer< ActiveMQConsumerKernel > | lookupConsumerKernel (Pointer< commands::ConsumerId > id) |
bool | iterateConsumers () |
Gives each consumer a chance to dispatch messages that have been enqueued by calling each consumers iterate method. | |
Public Member Functions inherited from cms::Session | |
virtual | ~Session () |
Public Member Functions inherited from cms::Closeable | |
virtual | ~Closeable () |
Public Member Functions inherited from cms::Startable | |
virtual | ~Startable () |
Public Member Functions inherited from cms::Stoppable | |
virtual | ~Stoppable () |
Public Member Functions inherited from activemq::core::Dispatcher | |
virtual | ~Dispatcher () |
Protected Attributes | |
SessionConfig * | config |
Pointer< commands::SessionInfo > | sessionInfo |
SessionInfo for this Session. | |
Pointer < ActiveMQTransactionContext > | transaction |
Transaction Management object. | |
ActiveMQConnection * | connection |
Connection. | |
AtomicBoolean | closed |
Indicates that this connection has been closed, it is no longer usable after this becomes true. | |
std::auto_ptr < ActiveMQSessionExecutor > | executor |
Sends incoming messages to the registered consumers. | |
cms::Session::AcknowledgeMode | ackMode |
This Sessions Acknowledgment mode. | |
util::LongSequenceGenerator | producerIds |
Next available Producer Id. | |
util::LongSequenceGenerator | producerSequenceIds |
Next available Producer Sequence Id. | |
util::LongSequenceGenerator | consumerIds |
Next available Consumer Id. | |
long long | lastDeliveredSequenceId |
Last Delivered Sequence Id. |
Friends | |
class | activemq::core::ActiveMQSessionExecutor |
Additional Inherited Members | |
Public Types inherited from cms::Session | |
enum | AcknowledgeMode { AUTO_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, SESSION_TRANSACTED, INDIVIDUAL_ACKNOWLEDGE } |
activemq::core::kernels::ActiveMQSessionKernel::ActiveMQSessionKernel | ( | ActiveMQConnection * | connection, |
const Pointer< commands::SessionId > & | id, | ||
cms::Session::AcknowledgeMode | ackMode, | ||
const decaf::util::Properties & | properties | ||
) |
|
virtual |
void activemq::core::kernels::ActiveMQSessionKernel::acknowledge | ( | ) |
Request that the Session inform all its consumers to Acknowledge all Message's that have been received so far.
void activemq::core::kernels::ActiveMQSessionKernel::addConsumer | ( | Pointer< ActiveMQConsumerKernel > | consumer | ) |
Adds a MessageConsumerKernel to this session registering it with the Connection and store a reference to it so the session can ensure that all resources are closed when the session is closed.
consumer | The ActiveMQConsumerKernel instance to add to this session. |
ActiveMQException | if an internal error occurs. |
void activemq::core::kernels::ActiveMQSessionKernel::addProducer | ( | Pointer< ActiveMQProducerKernel > | producer | ) |
Adds a MessageProducer to this session registering it with the Connection and store a reference to it so the session can ensure that all resources are closed when the session is closed.
producer | The ActiveMQProducerKernel instance to add to this session. |
ActiveMQException | if an internal error occurs. |
void activemq::core::kernels::ActiveMQSessionKernel::clearMessagesInProgress | ( | ) |
Request that this Session inform all of its consumers to clear all messages that are currently in progress.
|
virtual |
Closes this session as well as any active child consumers or producers.
CMSException | - If an internal error occurs. |
Implements cms::Session.
void activemq::core::kernels::ActiveMQSessionKernel::close | ( | Pointer< commands::ConsumerId > | id | ) |
Close the specified consumer if present in this Session.
id | The consumer Id to close. |
|
virtual |
Commits all messages done in this transaction and releases any locks currently held.
CMSException | - If an internal error occurs. |
IllegalStateException | - if the method is not called by a transacted session. |
Implements cms::Session.
Reimplemented in activemq::core::kernels::ActiveMQXASessionKernel.
|
virtual |
Creates a new QueueBrowser to peek at Messages on the given Queue.
queue | the Queue to browse |
CMSException | - If an internal error occurs. |
InvalidDestinationException | - if the destination given is invalid. |
Implements cms::Session.
|
virtual |
Creates a new QueueBrowser to peek at Messages on the given Queue.
queue | the Queue to browse |
selector | the Message selector to filter which messages are browsed. |
CMSException | - If an internal error occurs. |
InvalidDestinationException | - if the destination given is invalid. |
Implements cms::Session.
|
virtual |
Creates a BytesMessage.
CMSException | - If an internal error occurs. |
Implements cms::Session.
|
virtual |
Creates a BytesMessage and sets the payload to the passed value.
bytes | an array of bytes to set in the message |
bytesSize | the size of the bytes array, or number of bytes to use |
CMSException | - If an internal error occurs. |
Implements cms::Session.
|
virtual |
Creates a MessageConsumer for the specified destination.
destination | the Destination that this consumer receiving messages for. |
CMSException | - If an internal error occurs. |
InvalidDestinationException | - if an invalid destination is specified. |
Implements cms::Session.
|
virtual |
Creates a MessageConsumer for the specified destination, using a message selector.
destination | the Destination that this consumer receiving messages for. |
selector | the Message Selector to use |
CMSException | - If an internal error occurs. |
InvalidDestinationException | - if an invalid destination is specified. |
InvalidSelectorException | - if the message selector is invalid. |
Implements cms::Session.
|
virtual |
Creates a MessageConsumer for the specified destination, using a message selector.
destination | the Destination that this consumer receiving messages for. |
selector | the Message Selector to use |
noLocal | if true, and the destination is a topic, inhibits the delivery of messages published by its own connection. The behavior for NoLocal is not specified if the destination is a queue. |
CMSException | - If an internal error occurs. |
InvalidDestinationException | - if an invalid destination is specified. |
InvalidSelectorException | - if the message selector is invalid. |
Implements cms::Session.
|
virtual |
Creates a durable subscriber to the specified topic, using a Message selector.
Sessions that create durable consumers must use the same client Id as was used the last time the subscription was created in order to receive all messages that were delivered while the client was offline.
destination | the topic to subscribe to |
name | The name used to identify the subscription |
selector | the Message Selector to use |
noLocal | if true, and the destination is a topic, inhibits the delivery of messages published by its own connection. The behavior for NoLocal is not specified if the destination is a queue. |
CMSException | - If an internal error occurs. |
InvalidDestinationException | - if an invalid destination is specified. |
InvalidSelectorException | - if the message selector is invalid. |
Implements cms::Session.
|
virtual |
Creates a new MapMessage.
CMSException | - If an internal error occurs. |
Implements cms::Session.
|
virtual |
Creates a new Message.
CMSException | - If an internal error occurs. |
Implements cms::Session.
|
virtual |
Creates a MessageProducer to send messages to the specified destination.
destination | the Destination to send on |
CMSException | - If an internal error occurs. |
InvalidDestinationException | - if an invalid destination is specified. |
Implements cms::Session.
|
virtual |
Creates a queue identity given a Queue name.
queueName | the name of the new Queue |
CMSException | - If an internal error occurs. |
Implements cms::Session.
|
virtual |
Creates a new StreamMessage.
CMSException | - If an internal error occurs. |
Implements cms::Session.
|
virtual |
Creates a TemporaryQueue object.
CMSException | - If an internal error occurs. |
Implements cms::Session.
|
virtual |
Creates a TemporaryTopic object.
CMSException | - If an internal error occurs. |
Implements cms::Session.
|
virtual |
Creates a new TextMessage.
CMSException | - If an internal error occurs. |
Implements cms::Session.
|
virtual |
Creates a new TextMessage and set the text to the value given.
text | the initial text for the message |
CMSException | - If an internal error occurs. |
Implements cms::Session.
|
virtual |
Creates a topic identity given a Queue name.
topicName | the name of the new Topic |
CMSException | - If an internal error occurs. |
Implements cms::Session.
void activemq::core::kernels::ActiveMQSessionKernel::deliverAcks | ( | ) |
Request that this Session inform all of its consumers to deliver their pending acks.
|
virtual |
Dispatches a message to a particular consumer.
message | - the message to be dispatched |
Implements activemq::core::Dispatcher.
void activemq::core::kernels::ActiveMQSessionKernel::dispose | ( | ) |
Cleans up the Session object's resources without attempting to send the Remove command to the broker, this can be called from ActiveMQConnection when it knows that the transport is down and the doClose method would throw an exception when it attempt to send the Remove Command.
void activemq::core::kernels::ActiveMQSessionKernel::doClose | ( | ) |
Performs the actual Session close operations.
This method is meant for use by ActiveMQConnection, the connection object calls this when it has been closed to skip some of the extraneous processing done by the client level close method.
|
virtual |
Starts if not already start a Transaction for this Session.
If the session is not a Transacted Session then an exception is thrown. If a transaction is already in progress then this method has no effect.
ActiveMQException | if this is not a Transacted Session. |
Reimplemented in activemq::core::kernels::ActiveMQXASessionKernel.
void activemq::core::kernels::ActiveMQSessionKernel::fire | ( | const exceptions::ActiveMQException & | ex | ) |
Fires the given exception to the exception listener of the connection.
|
virtual |
Returns the acknowledgment mode of the session.
CMSException | - If an internal error occurs. |
Implements cms::Session.
|
inline |
Gets the ActiveMQConnection that is associated with this session.
cms::ExceptionListener* activemq::core::kernels::ActiveMQSessionKernel::getExceptionListener | ( | ) |
This method gets any registered exception listener of this sessions connection and returns it.
Mainly intended for use by the objects that this session creates so that they can notify the client of exceptions that occur in the context of another thread.
|
inline |
Gets the currently set Last Delivered Sequence Id.
|
virtual |
Gets the currently configured MessageTransformer for this Session.
Implements cms::Session.
Pointer<commands::ConsumerId> activemq::core::kernels::ActiveMQSessionKernel::getNextConsumerId | ( | ) |
Get the Next available Consumer Id.
Pointer<commands::ProducerId> activemq::core::kernels::ActiveMQSessionKernel::getNextProducerId | ( | ) |
Get the Next available Producer Id.
Pointer<threads::Scheduler> activemq::core::kernels::ActiveMQSessionKernel::getScheduler | ( | ) | const |
Gets a Pointer to this Session's Scheduler instance.
|
inline |
Gets the Session Id object for this session, if the session is closed than this method throws an exception.
|
inline |
Gets the Session Information object for this session, if the session is closed than this method throws an exception.
|
inline |
Gets the Pointer to this Session's TransactionContext.
|
inlinevirtual |
Reimplemented in activemq::core::kernels::ActiveMQXASessionKernel.
References cms::Session::AUTO_ACKNOWLEDGE.
|
inlinevirtual |
References cms::Session::CLIENT_ACKNOWLEDGE.
|
inlinevirtual |
References cms::Session::DUPS_OK_ACKNOWLEDGE.
|
inlinevirtual |
References cms::Session::INDIVIDUAL_ACKNOWLEDGE.
bool activemq::core::kernels::ActiveMQSessionKernel::isInUse | ( | Pointer< commands::ActiveMQDestination > | destination | ) |
Checks if the given destination is currently in use by any consumers in this Session.
bool activemq::core::kernels::ActiveMQSessionKernel::isStarted | ( | ) | const |
Indicates whether or not the session is currently in the started state.
|
virtual |
Gets if the Sessions is a Transacted Session.
CMSException | - If an internal error occurs. |
Implements cms::Session.
Reimplemented in activemq::core::kernels::ActiveMQXASessionKernel.
bool activemq::core::kernels::ActiveMQSessionKernel::iterateConsumers | ( | ) |
Gives each consumer a chance to dispatch messages that have been enqueued by calling each consumers iterate method.
Returns true if this method needs to be called again because a consumer requires further processing time to complete its dispatching. Once all consumers are done this method returns false.
Pointer<ActiveMQConsumerKernel> activemq::core::kernels::ActiveMQSessionKernel::lookupConsumerKernel | ( | Pointer< commands::ConsumerId > | id | ) |
Pointer<ActiveMQProducerKernel> activemq::core::kernels::ActiveMQSessionKernel::lookupProducerKernel | ( | Pointer< commands::ProducerId > | id | ) |
void activemq::core::kernels::ActiveMQSessionKernel::oneway | ( | Pointer< commands::Command > | command | ) |
Sends a Command to the broker without requesting any Response be returned.
command | The message to send to the Broker. |
ActiveMQException | if not currently connected, or if the operation fails for any reason. |
|
virtual |
Stops message delivery in this session, and restarts message delivery with the oldest unacknowledged message.
All consumers deliver messages in a serial order. Acknowledging a received message automatically acknowledges all messages that have been delivered to the client.
Restarting a session causes it to take the following actions:
CMSException | - if the CMS provider fails to stop and restart message delivery due to some internal error. |
IllegalStateException | - if the method is called by a transacted session. |
Implements cms::Session.
|
virtual |
Redispatches the given set of unconsumed messages to the consumers.
unconsumedMessages | - unconsumed messages to be redelivered. |
void activemq::core::kernels::ActiveMQSessionKernel::removeConsumer | ( | Pointer< ActiveMQConsumerKernel > | consumer | ) |
Dispose of a MessageConsumer from this session.
Removes it from the Connection and clean up any resources associated with it.
consumer | The ActiveMQConsumerKernel instance to remove from this session. |
ActiveMQException | if an internal error occurs. |
void activemq::core::kernels::ActiveMQSessionKernel::removeProducer | ( | Pointer< ActiveMQProducerKernel > | producer | ) |
Dispose of a MessageProducer from this session.
Removes it from the Connection and clean up any resources associated with it.
producer | The Producer kernel instance to remove from this session. |
ActiveMQException | if an internal error occurs. |
|
virtual |
Rolls back all messages done in this transaction and releases any locks currently held.
CMSException | - If an internal error occurs. |
IllegalStateException | - if the method is not called by a transacted session. |
Implements cms::Session.
Reimplemented in activemq::core::kernels::ActiveMQXASessionKernel.
void activemq::core::kernels::ActiveMQSessionKernel::send | ( | kernels::ActiveMQProducerKernel * | producer, |
Pointer< commands::ActiveMQDestination > | destination, | ||
cms::Message * | message, | ||
int | deliveryMode, | ||
int | priority, | ||
long long | timeToLive, | ||
util::MemoryUsage * | producerWindow, | ||
long long | sendTimeout, | ||
cms::AsyncCallback * | onComplete | ||
) |
Sends a message from the Producer specified using this session's connection the message will be sent using the best available means depending on the configuration of the connection.
Asynchronous sends will be chosen if at all possible.
producer | The sending Producer |
destination | The target destination for the Message. |
message | The message to send to the broker. |
deliveryMode | The delivery mode to assign to the outgoing message. |
priority | The priority value to assign to the outgoing message. |
timeToLive | The time to live for the outgoing message. |
usage | Pointer to a Usage tracker which if set will be increased by the size of the given message. |
sendTimeout | The amount of time to block during send before failing, or 0 to wait forever. |
CMSException | if an error occurs while sending the message. |
|
inline |
Sets the value of the Last Delivered Sequence Id.
value | The new value to assign to the Last Delivered Sequence Id property. |
|
virtual |
Set an MessageTransformer instance that is passed on to all MessageProducer and MessageConsumer objects created from this Session.
transformer | Pointer to the cms::MessageTransformer to set on all MessageConsumers and MessageProducers. |
Implements cms::Session.
void activemq::core::kernels::ActiveMQSessionKernel::setPrefetchSize | ( | Pointer< commands::ConsumerId > | id, |
int | prefetch | ||
) |
Set the prefetch level for the given consumer if it exists in this Session to the value specified.
id | The consumer Id to search for and set prefetch level. |
prefetch | The new prefetch value. |
|
virtual |
Stops asynchronous message delivery.
Implements cms::Startable.
|
virtual |
Starts asynchronous message delivery.
Implements cms::Stoppable.
Pointer<commands::Response> activemq::core::kernels::ActiveMQSessionKernel::syncRequest | ( | Pointer< commands::Command > | command, |
unsigned int | timeout = 0 |
||
) |
Sends a synchronous request and returns the response from the broker.
Converts any error responses into an exception.
command | The command to send to the broker. |
timeout | The time to wait for a response, default is zero or infinite. |
ActiveMQException | thrown if an error response was received from the broker, or if any other error occurred. |
|
virtual |
Unsubscribes a durable subscription that has been created by a client.
This method deletes the state being maintained on behalf of the subscriber by its provider. It is erroneous for a client to delete a durable subscription while there is an active MessageConsumer or Subscriber for the subscription, or while a consumed message is part of a pending transaction or has not been acknowledged in the session.
name | The name used to identify this subscription |
CMSException | - If an internal error occurs. |
Implements cms::Session.
void activemq::core::kernels::ActiveMQSessionKernel::wakeup | ( | ) |
Causes the Session to wakeup its executer and ensure all messages are dispatched.
|
friend |
|
protected |
This Sessions Acknowledgment mode.
|
protected |
Indicates that this connection has been closed, it is no longer usable after this becomes true.
|
protected |
|
protected |
Connection.
|
protected |
Next available Consumer Id.
|
protected |
Sends incoming messages to the registered consumers.
|
protected |
Last Delivered Sequence Id.
|
protected |
Next available Producer Id.
|
protected |
Next available Producer Sequence Id.
|
protected |
SessionInfo for this Session.
|
protected |
Transaction Management object.