A connection to a remote AMQP peer. More...
#include <connection.hpp>
Public Member Functions | |
connection () | |
bool | uninitialized () const |
True if the local end is uninitialized. | |
bool | active () const |
True if the local end is active. | |
bool | closed () const |
True if the local and remote ends are closed. | |
class error_condition | error () const |
Get the error condition of the remote endpoint. | |
class container & | container () const |
Get the container. | |
class transport | transport () const |
Get the transport for the connection. | |
std::string | virtual_host () const |
Return the AMQP hostname attribute for the connection. | |
std::string | container_id () const |
Return the container ID for the connection. | |
std::string | user () const |
Return authenticated user for the connection Note: The value returned is not stable until the on_transport_open event is received. | |
void | open () |
Open the connection. | |
void | open (const connection_options &) |
void | close () |
Close the endpoint. | |
void | close (const error_condition &) |
Close the endpoint with an error condition. | |
session | open_session () |
Open a new session. | |
session | open_session (const session_options &) |
session | default_session () |
Get the default session. | |
sender | open_sender (const std::string &addr) |
Open a sender for `addr` on default_session(). | |
sender | open_sender (const std::string &addr, const sender_options &) |
receiver | open_receiver (const std::string &addr) |
Open a receiver for `addr` on default_session(). | |
receiver | open_receiver (const std::string &addr, const receiver_options &) |
session_range | sessions () const |
Return all sessions on this connection. | |
receiver_range | receivers () const |
Return all receivers on this connection. | |
sender_range | senders () const |
Return all senders on this connection. | |
uint32_t | max_frame_size () const |
Get the maximum frame size. | |
uint16_t | max_sessions () const |
Get the maximum number of open sessions. | |
uint32_t | idle_timeout () const |
Get the idle timeout. |
A connection to a remote AMQP peer.
broker.cpp, broker.hpp, helloworld.cpp, helloworld_direct.cpp, mt/broker.cpp, mt/epoll_container.cpp, server.cpp, and service_bus.cpp.
connection | ( | ) | [inline] |
Create an empty connection.
void close | ( | const error_condition & | ) | [virtual] |
Get the container.
proton::error | if this connection is not managed by a container |
session default_session | ( | ) |
Get the default session.
A default session is created on the first call and reused for the lifetime of the connection.
uint32_t idle_timeout | ( | ) | const |
Get the idle timeout.
uint32_t max_frame_size | ( | ) | const |
Get the maximum frame size.
uint16_t max_sessions | ( | ) | const |
Get the maximum number of open sessions.
void open | ( | const connection_options & | ) |
Open the connection.
void open | ( | ) |
Open the connection.
receiver open_receiver | ( | const std::string & | addr, | |
const receiver_options & | ||||
) |
Open a receiver for `addr` on default_session().
sender open_sender | ( | const std::string & | addr, | |
const sender_options & | ||||
) |
Open a sender for `addr` on default_session().
session open_session | ( | const session_options & | ) |
Open a new session.