Apache Qpid - AMQP Messaging for Java JMS, C++, Python, Ruby, and .NET | Apache Qpid Documentation |
#include <ConnectionImpl.h>
Public Types | |
typedef AMQFrame & | HandledType |
typedef void | result_type |
Public Member Functions | |
ConnectionImpl (framing::ProtocolVersion version, const ConnectionSettings &settings) | |
~ConnectionImpl () | |
void | open () |
bool | isOpen () const |
boost::shared_ptr< SessionImpl > | newSession (const std::string &name, uint32_t timeout, uint16_t channel=NEXT_CHANNEL) |
void | addSession (const boost::shared_ptr< SessionImpl > &, uint16_t channel=NEXT_CHANNEL) |
void | close () |
void | handle (framing::AMQFrame &frame) |
void | erase (uint16_t channel) |
const ConnectionSettings & | getNegotiatedSettings () |
std::vector< Url > | getKnownBrokers () |
void | registerFailureCallback (boost::function< void()> fn) |
void | stopFailoverListener () |
framing::ProtocolVersion | getVersion () |
bool | expand (size_t, bool block) |
void | reduce (size_t) |
size_t | getCurrentSize () |
void | setException (const sys::ExceptionHolder &) |
typedef void | handleFptr (AMQFrame &) |
void | operator() (AMQFrame &t) |
Allow functor syntax for calling handle. | |
Public Attributes | |
Handler< AMQFrame & > * | next |
Pointer to next handler in a linked list. |
Definition at line 47 of file ConnectionImpl.h.
typedef AMQFrame & qpid::framing::Handler< AMQFrame & >::HandledType [inherited] |
typedef void qpid::framing::Handler< AMQFrame & >::result_type [inherited] |
qpid::client::ConnectionImpl::ConnectionImpl | ( | framing::ProtocolVersion | version, | |
const ConnectionSettings & | settings | |||
) |
qpid::client::ConnectionImpl::~ConnectionImpl | ( | ) |
void qpid::client::ConnectionImpl::addSession | ( | const boost::shared_ptr< SessionImpl > & | , | |
uint16_t | channel = NEXT_CHANNEL | |||
) |
void qpid::client::ConnectionImpl::close | ( | ) |
void qpid::client::ConnectionImpl::erase | ( | uint16_t | channel | ) |
bool qpid::client::Bounds::expand | ( | size_t | , | |
bool | block | |||
) | [inherited] |
size_t qpid::client::Bounds::getCurrentSize | ( | ) | [inherited] |
std::vector<Url> qpid::client::ConnectionImpl::getKnownBrokers | ( | ) |
const ConnectionSettings& qpid::client::ConnectionImpl::getNegotiatedSettings | ( | ) |
framing::ProtocolVersion qpid::client::ConnectionImpl::getVersion | ( | ) | [inline] |
Definition at line 97 of file ConnectionImpl.h.
void qpid::client::ConnectionImpl::handle | ( | framing::AMQFrame & | frame | ) | [virtual] |
Implements qpid::framing::Handler< AMQFrame & >.
typedef void qpid::framing::Handler< AMQFrame & >::handleFptr | ( | AMQFrame & | ) | [inherited] |
bool qpid::client::ConnectionImpl::isOpen | ( | ) | const |
boost::shared_ptr<SessionImpl> qpid::client::ConnectionImpl::newSession | ( | const std::string & | name, | |
uint32_t | timeout, | |||
uint16_t | channel = NEXT_CHANNEL | |||
) |
void qpid::client::ConnectionImpl::open | ( | ) |
void qpid::framing::Handler< AMQFrame & >::operator() | ( | AMQFrame & | t | ) | [inline, inherited] |
Allow functor syntax for calling handle.
Definition at line 42 of file Handler.h.
References qpid::framing::Handler< T >::handle().
void qpid::client::Bounds::reduce | ( | size_t | ) | [inherited] |
void qpid::client::ConnectionImpl::registerFailureCallback | ( | boost::function< void()> | fn | ) | [inline] |
Definition at line 94 of file ConnectionImpl.h.
void qpid::client::Bounds::setException | ( | const sys::ExceptionHolder & | ) | [inherited] |
void qpid::client::ConnectionImpl::stopFailoverListener | ( | ) |
Handler<AMQFrame & >* qpid::framing::Handler< AMQFrame & >::next [inherited] |
Pointer to next handler in a linked list.
Definition at line 46 of file Handler.h.
Referenced by qpid::framing::ChannelHandler::handle().