activemq::core::ActiveMQXASession Class Reference

#include <src/main/activemq/core/ActiveMQXASession.h>

Inheritance diagram for activemq::core::ActiveMQXASession:

Public Member Functions
	ActiveMQXASession (Pointer< activemq::core::kernels::ActiveMQXASessionKernel > kernel)
virtual	~ActiveMQXASession ()
virtual bool	isTransacted () const
	Gets if the Sessions is a Transacted Session. More...
virtual bool	isAutoAcknowledge () const
virtual void	doStartTransaction ()
virtual void	commit ()
	Commits all messages done in this transaction and releases any locks currently held. More...
virtual void	rollback ()
	Rolls back all messages done in this transaction and releases any locks currently held. More...
virtual cms::XAResource *	getXAResource () const
	Returns the XA resource associated with this Session to the caller. More...
Public Member Functions inherited from cms::XASession
virtual	~XASession ()
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::ActiveMQSession
	ActiveMQSession (Pointer< activemq::core::kernels::ActiveMQSessionKernel > kernel)
virtual	~ActiveMQSession ()
virtual void	start ()
	Stops asynchronous message delivery. More...
virtual void	stop ()
	Starts asynchronous message delivery. More...
bool	isStarted () const
	Indicates whether or not the session is currently in the started state. More...
virtual void	close ()
	Closes this session as well as any active child consumers or producers. More...
virtual void	recover ()
	Stops message delivery in this session, and restarts message delivery with the oldest unacknowledged message. More...
virtual cms::MessageConsumer *	createConsumer (const cms::Destination *destination)
	Creates a MessageConsumer for the specified destination. More...
virtual cms::MessageConsumer *	createConsumer (const cms::Destination *destination, const std::string &selector)
	Creates a MessageConsumer for the specified destination, using a message selector. More...
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. More...
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. More...
virtual cms::MessageProducer *	createProducer (const cms::Destination *destination)
	Creates a MessageProducer to send messages to the specified destination. More...
virtual cms::QueueBrowser *	createBrowser (const cms::Queue *queue)
	Creates a new QueueBrowser to peek at Messages on the given Queue. More...
virtual cms::QueueBrowser *	createBrowser (const cms::Queue *queue, const std::string &selector)
	Creates a new QueueBrowser to peek at Messages on the given Queue. More...
virtual cms::Queue *	createQueue (const std::string &queueName)
	Creates a queue identity given a Queue name. More...
virtual cms::Topic *	createTopic (const std::string &topicName)
	Creates a topic identity given a Queue name. More...
virtual cms::TemporaryQueue *	createTemporaryQueue ()
	Creates a TemporaryQueue object. More...
virtual cms::TemporaryTopic *	createTemporaryTopic ()
	Creates a TemporaryTopic object. More...
virtual cms::Message *	createMessage ()
	Creates a new Message. More...
virtual cms::BytesMessage *	createBytesMessage ()
	Creates a BytesMessage. More...
virtual cms::BytesMessage *	createBytesMessage (const unsigned char *bytes, int bytesSize)
	Creates a BytesMessage and sets the payload to the passed value. More...
virtual cms::StreamMessage *	createStreamMessage ()
	Creates a new StreamMessage. More...
virtual cms::TextMessage *	createTextMessage ()
	Creates a new TextMessage. More...
virtual cms::TextMessage *	createTextMessage (const std::string &text)
	Creates a new TextMessage and set the text to the value given. More...
virtual cms::MapMessage *	createMapMessage ()
	Creates a new MapMessage. More...
virtual cms::Session::AcknowledgeMode	getAcknowledgeMode () const
	Returns the acknowledgment mode of the session. More...
virtual void	unsubscribe (const std::string &name)
	Unsubscribes a durable subscription that has been created by a client. More...
cms::ExceptionListener *	getExceptionListener ()
	This method gets any registered exception listener of this sessions connection and returns it. More...
virtual void	setMessageTransformer (cms::MessageTransformer *transformer)
	Set an MessageTransformer instance that is passed on to all MessageProducer and MessageConsumer objects created from this Session. More...
virtual cms::MessageTransformer *	getMessageTransformer () const
	Gets the currently configured MessageTransformer for this Session. More...
const commands::SessionInfo &	getSessionInfo () const
	Gets the Session Information object for this session, if the session is closed than this method throws an exception. More...
const commands::SessionId &	getSessionId () const
	Gets the Session Id object for this session, if the session is closed than this method throws an exception. More...
ActiveMQConnection *	getConnection () const
	Gets the ActiveMQConnection that is associated with this session. More...

Additional Inherited Members
Public Types inherited from cms::Session
enum	AcknowledgeMode {   AUTO_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, SESSION_TRANSACTED,   INDIVIDUAL_ACKNOWLEDGE }
Protected Attributes inherited from activemq::core::ActiveMQSession
Pointer< activemq::core::kernels::ActiveMQSessionKernel >	kernel

Constructor & Destructor Documentation

ActiveMQXASession()

activemq::core::ActiveMQXASession::ActiveMQXASession

(

Pointer< activemq::core::kernels::ActiveMQXASessionKernel >

kernel

)

~ActiveMQXASession()

virtual activemq::core::ActiveMQXASession::~ActiveMQXASession ( )

virtual

Member Function Documentation

commit()

virtual void activemq::core::ActiveMQXASession::commit ( )

virtual

Commits all messages done in this transaction and releases any locks currently held.

Exceptions

CMSException	- If an internal error occurs.
IllegalStateException	- if the method is not called by a transacted session.

Reimplemented from activemq::core::ActiveMQSession.

doStartTransaction()

virtual void activemq::core::ActiveMQXASession::doStartTransaction ( )

virtual

getXAResource()

virtual cms::XAResource* activemq::core::ActiveMQXASession::getXAResource ( ) const

virtual

Returns the XA resource associated with this Session to the caller.

The client can use the provided XA resource to interact with the XA Transaction Manager in use in the client application.

Returns

an XAResouce instance to the caller, the caller does not own this pointer and should not delete it.

Implements cms::XASession.

isAutoAcknowledge()

virtual bool activemq::core::ActiveMQXASession::isAutoAcknowledge ( ) const

virtual

isTransacted()

virtual bool activemq::core::ActiveMQXASession::isTransacted ( ) const

virtual

Gets if the Sessions is a Transacted Session.

Returns

transacted true - false.

Exceptions

CMSException

- If an internal error occurs.

Reimplemented from activemq::core::ActiveMQSession.

rollback()

virtual void activemq::core::ActiveMQXASession::rollback ( )

virtual

Rolls back all messages done in this transaction and releases any locks currently held.

Exceptions

CMSException	- If an internal error occurs.
IllegalStateException	- if the method is not called by a transacted session.

Reimplemented from activemq::core::ActiveMQSession.

---

The documentation for this class was generated from the following file:

• src/main/activemq/core/ActiveMQXASession.h