Apache Qpid C++ API
Apache Qpid - AMQP Messaging for Java JMS, C++, Python, Ruby, and .NET Apache Qpid Documentation

qpid::client::SessionImpl Class Reference

#include <SessionImpl.h>

Inherits qpid::client::Execution, qpid::framing::AMQP_ClientOperations::SessionHandler, qpid::framing::AMQP_ClientOperations::ExecutionHandler, and qpid::framing::AMQP_ClientOperations::MessageHandler.

List of all members.

Public Member Functions

 SessionImpl (const std::string &name, shared_ptr< ConnectionImpl >)
 ~SessionImpl ()
framing::FrameSet::shared_ptr get ()
const SessionId getId () const
uint16_t getChannel () const
void setChannel (uint16_t channel)
void open (uint32_t detachedLifetime)
void close ()
void resume (shared_ptr< ConnectionImpl >)
void suspend ()
void assertOpen () const
Future send (const framing::AMQBody &command)
Future send (const framing::AMQBody &command, const framing::MethodContent &content)
Future send (const framing::AMQBody &command, const framing::FrameSet &content)
void sendRawFrame (framing::AMQFrame &frame)
DemuxgetDemux ()
 Provides access to the demultiplexing function within the session implementation.
void markCompleted (const framing::SequenceNumber &id, bool cumulative, bool notifyPeer)
void markCompleted (const framing::SequenceSet &ids, bool notifyPeer)
bool isComplete (const framing::SequenceNumber &id)
bool isCompleteUpTo (const framing::SequenceNumber &id)
void waitForCompletion (const framing::SequenceNumber &id)
 Wait until notification has been received of completion of the outgoing command with the specified id.
void sendCompletion ()
void sendFlush ()
void setException (const sys::ExceptionHolder &)
void connectionClosed (uint16_t code, const std::string &text)
void connectionBroke (const std::string &text)
uint32_t setTimeout (uint32_t requestedSeconds)
 Set timeout in seconds, returns actual timeout allowed by broker.
uint32_t getTimeout () const
 Get timeout in seconds.
void setWeakPtr (bool weak=true)
 Make this session use a weak_ptr to the ConnectionImpl.
shared_ptr< ConnectionImplgetConnection ()
 get the Connection associated with this connection
void disableAutoDetach ()
 Suppress sending detach in destructor.


Detailed Description

Definition at line 61 of file SessionImpl.h.


Constructor & Destructor Documentation

qpid::client::SessionImpl::SessionImpl ( const std::string &  name,
shared_ptr< ConnectionImpl  
)

qpid::client::SessionImpl::~SessionImpl (  ) 


Member Function Documentation

void qpid::client::SessionImpl::assertOpen (  )  const

void qpid::client::SessionImpl::close (  ) 

void qpid::client::SessionImpl::connectionBroke ( const std::string &  text  ) 

void qpid::client::SessionImpl::connectionClosed ( uint16_t  code,
const std::string &  text 
)

void qpid::client::SessionImpl::disableAutoDetach (  ) 

Suppress sending detach in destructor.

Used by cluster to build session state

framing::FrameSet::shared_ptr qpid::client::SessionImpl::get (  ) 

uint16_t qpid::client::SessionImpl::getChannel (  )  const

shared_ptr<ConnectionImpl> qpid::client::SessionImpl::getConnection (  ) 

get the Connection associated with this connection

Demux& qpid::client::SessionImpl::getDemux (  )  [virtual]

Provides access to the demultiplexing function within the session implementation.

Implements qpid::client::Execution.

const SessionId qpid::client::SessionImpl::getId (  )  const

uint32_t qpid::client::SessionImpl::getTimeout (  )  const

Get timeout in seconds.

bool qpid::client::SessionImpl::isComplete ( const framing::SequenceNumber id  ) 

bool qpid::client::SessionImpl::isCompleteUpTo ( const framing::SequenceNumber id  ) 

void qpid::client::SessionImpl::markCompleted ( const framing::SequenceSet ids,
bool  notifyPeer 
)

void qpid::client::SessionImpl::markCompleted ( const framing::SequenceNumber id,
bool  cumulative,
bool  notifyPeer 
)

void qpid::client::SessionImpl::open ( uint32_t  detachedLifetime  ) 

void qpid::client::SessionImpl::resume ( shared_ptr< ConnectionImpl  ) 

Future qpid::client::SessionImpl::send ( const framing::AMQBody command,
const framing::FrameSet content 
)

Future qpid::client::SessionImpl::send ( const framing::AMQBody command,
const framing::MethodContent content 
)

Future qpid::client::SessionImpl::send ( const framing::AMQBody command  ) 

void qpid::client::SessionImpl::sendCompletion (  ) 

void qpid::client::SessionImpl::sendFlush (  ) 

void qpid::client::SessionImpl::sendRawFrame ( framing::AMQFrame frame  ) 

void qpid::client::SessionImpl::setChannel ( uint16_t  channel  ) 

void qpid::client::SessionImpl::setException ( const sys::ExceptionHolder &   ) 

uint32_t qpid::client::SessionImpl::setTimeout ( uint32_t  requestedSeconds  ) 

Set timeout in seconds, returns actual timeout allowed by broker.

void qpid::client::SessionImpl::setWeakPtr ( bool  weak = true  ) 

Make this session use a weak_ptr to the ConnectionImpl.

Used for sessions created by the ConnectionImpl itself.

void qpid::client::SessionImpl::suspend (  ) 

void qpid::client::SessionImpl::waitForCompletion ( const framing::SequenceNumber id  ) 

Wait until notification has been received of completion of the outgoing command with the specified id.

Reimplemented from qpid::client::Execution.


The documentation for this class was generated from the following file:
Qpid C++ API Reference
Generated on Tue Dec 8 15:39:37 2009 for Qpid C++ Client API by doxygen 1.4.7