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.
1.6.1