Public Member Functions |
| ActiveMQXASession (Pointer< activemq::core::kernels::ActiveMQXASessionKernel > kernel) |
virtual | ~ActiveMQXASession () |
virtual bool | isTransacted () const |
| Gets if the Sessions is a Transacted Session.
|
virtual bool | isAutoAcknowledge () const |
virtual void | doStartTransaction () |
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 cms::XAResource * | getXAResource () const |
| Returns the XA resource associated with this Session to the caller.
|
virtual | ~XASession () |
virtual | ~Session () |
virtual | ~Closeable () |
virtual | ~Startable () |
virtual | ~Stoppable () |
| ActiveMQSession (Pointer< activemq::core::kernels::ActiveMQSessionKernel > kernel) |
virtual | ~ActiveMQSession () |
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 void | close () |
| Closes this session as well as any active child consumers or producers.
|
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 void | unsubscribe (const std::string &name) |
| Unsubscribes a durable subscription that has been created by a client.
|
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.
|