Apache Qpid - AMQP Messaging for Java JMS, C++, Python, Ruby, and .NET | Apache Qpid Documentation |
#include <SessionImpl.h>
Public Member Functions | |
SessionImpl (const std::string &name, boost::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 (boost::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) |
Demux & | getDemux () |
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. | |
boost::shared_ptr< ConnectionImpl > | getConnection () |
get the Connection associated with this connection | |
virtual void | handleIn (T)=0 |
virtual void | handleOut (T)=0 |
Public Attributes | |
MemFunRef < InOutHandlerInterface,&InOutHandlerInterface::handleIn > | in |
MemFunRef < InOutHandlerInterface,&InOutHandlerInterface::handleOut > | out |
Definition at line 61 of file SessionImpl.h.
qpid::client::SessionImpl::SessionImpl | ( | const std::string & | name, | |
boost::shared_ptr< ConnectionImpl > | ||||
) |
qpid::client::SessionImpl::~SessionImpl | ( | ) |
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 | |||
) |
framing::FrameSet::shared_ptr qpid::client::SessionImpl::get | ( | ) |
uint16_t qpid::client::SessionImpl::getChannel | ( | ) | const |
boost::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.
virtual void qpid::framing::Handler< T >::Handler::InOutHandlerInterface::handleIn | ( | T | ) | [pure virtual, inherited] |
virtual void qpid::framing::Handler< T >::Handler::InOutHandlerInterface::handleOut | ( | T | ) | [pure virtual, inherited] |
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 | ( | boost::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.
MemFunRef<InOutHandlerInterface, &InOutHandlerInterface::handleIn> qpid::framing::Handler< T >::Handler::InOutHandler::in [inherited] |
MemFunRef<InOutHandlerInterface, &InOutHandlerInterface::handleOut> qpid::framing::Handler< T >::Handler::InOutHandler::out [inherited] |