Apache Qpid - AMQP Messaging for Java JMS, C++, Python, Ruby, and .NET Apache Qpid Documentation
Public Member Functions | Protected Attributes
qpid::client::SessionBase_0_10 Class Reference

Base class for handles to an AMQP session. More...

#include <qpid/client/SessionBase_0_10.h>

List of all members.

Public Member Functions

 SessionBase_0_10 ()
 ~SessionBase_0_10 ()
SessionId getId () const
 Get the session ID.
void close ()
 Close the session.
void sync ()
 Synchronize the session: sync() waits until all commands issued on this session so far have been completed by the broker.
uint32_t timeout (uint32_t seconds)
 Set the timeout for this session.
void suspend ()
 Suspend the session - detach it from its connection.
void resume (Connection)
 Resume a suspended session with a new connection.
uint16_t getChannel () const
 Get the channel associated with this session.
void flush ()
void markCompleted (const framing::SequenceSet &ids, bool notifyPeer)
void markCompleted (const framing::SequenceNumber &id, bool cumulative, bool notifyPeer)
void sendCompletion ()
bool isValid () const
Connection getConnection ()

Protected Attributes

boost::shared_ptr< SessionImpl > impl

Detailed Description

Base class for handles to an AMQP session.

Subclasses provide the AMQP commands for a given version of the protocol.

Definition at line 57 of file SessionBase_0_10.h.


Constructor & Destructor Documentation


Member Function Documentation

Close the session.

A session is automatically closed when all handles to it are destroyed.

Get the channel associated with this session.

Get the session ID.

void qpid::client::SessionBase_0_10::markCompleted ( const framing::SequenceSet ids,
bool  notifyPeer 
)
void qpid::client::SessionBase_0_10::markCompleted ( const framing::SequenceNumber id,
bool  cumulative,
bool  notifyPeer 
)

Resume a suspended session with a new connection.

Suspend the session - detach it from its connection.

Synchronize the session: sync() waits until all commands issued on this session so far have been completed by the broker.

Note sync() is always synchronous, even on an AsyncSession object because that's almost always what you want. You can call AsyncSession::executionSync() directly in the unusual event that you want to do an asynchronous sync.

Set the timeout for this session.


Member Data Documentation

boost::shared_ptr<SessionImpl> qpid::client::SessionBase_0_10::impl [protected]

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

Qpid C++ API Reference
Generated on Fri Dec 23 2011 22:49:39 for Qpid C++ Client API by doxygen 1.7.6.1