Qpid Proton C++
0.14.0
|
This is an header only class that can be used to help using containers more natural by allowing them to be treated as value types. More...
#include <container.hpp>
Public Member Functions | |
container_ref (Ptr p) | |
returned< connection > | connect (const std::string &url, const connection_options &opts) |
Connect to url and send an open request to the remote peer. More... | |
returned< connection > | connect (const std::string &url) |
Connect to url and send an open request to the remote peer. | |
listener | listen (const std::string &url, listen_handler &l) |
Start listening on url. More... | |
listener | listen (const std::string &url, const connection_options &opts) |
Listen with a fixed set of options for all accepted connections. More... | |
listener | listen (const std::string &url) |
Start listening on URL. More... | |
void | stop_listening (const std::string &url) |
void | run () |
Run the container in this thread. More... | |
void | auto_stop (bool set) |
If true, stop the container when all active connections and listeners are closed. More... | |
void | stop (const error_condition &err) |
Experimental - Stop the container with an error_condition err. More... | |
void | stop () |
Experimental - Stop the container with an empty error condition. More... | |
returned< sender > | open_sender (const std::string &url, const class sender_options &o, const connection_options &c) |
returned< sender > | open_sender (const std::string &url, const class connection_options &o) |
returned< sender > | open_sender (const std::string &url, const class sender_options &o) |
returned< sender > | open_sender (const std::string &url) |
Open a connection and sender for url . | |
returned< receiver > | open_receiver (const std::string &url, const class receiver_options &o, const connection_options &c) |
returned< receiver > | open_receiver (const std::string &url, const class receiver_options &o) |
returned< receiver > | open_receiver (const std::string &url, const class connection_options &o) |
returned< receiver > | open_receiver (const std::string &url) |
Open a connection and receiver for url . | |
std::string | id () const |
A unique identifier for the container. | |
void | schedule (duration d, void_function0 &f) |
Schedule a function to be called after the duration. More... | |
void | client_connection_options (const connection_options &c) |
Connection options that will be to outgoing connections. More... | |
connection_options | client_connection_options () const |
Connection options that will be to outgoing connections. More... | |
void | server_connection_options (const connection_options &o) |
Connection options that will be applied to incoming connections. More... | |
connection_options | server_connection_options () const |
Connection options that will be applied to incoming connections. More... | |
void | sender_options (const class sender_options &o) |
Sender options applied to senders created by this container. More... | |
class sender_options | sender_options () const |
Sender options applied to senders created by this container. More... | |
void | receiver_options (const class receiver_options &o) |
Receiver options applied to receivers created by this container. More... | |
class receiver_options | receiver_options () const |
Receiver options applied to receivers created by this container. More... | |
virtual returned< sender > | open_sender (const std::string &url, const proton::sender_options &o)=0 |
Open a connection and sender for url . More... | |
virtual returned< sender > | open_sender (const std::string &url, const connection_options &c)=0 |
Open a connection and sender for url . More... | |
virtual returned< sender > | open_sender (const std::string &url, const proton::sender_options &o, const connection_options &c)=0 |
Open a connection and sender for url . More... | |
virtual returned< receiver > | open_receiver (const std::string &url, const proton::receiver_options &o)=0 |
Open a connection and receiver for url . More... | |
virtual returned< receiver > | open_receiver (const std::string &url, const connection_options &c)=0 |
Open a connection and receiver for url . More... | |
virtual returned< receiver > | open_receiver (const std::string &url, const proton::receiver_options &o, const connection_options &c)=0 |
Open a connection and receiver for url . More... | |
This is an header only class that can be used to help using containers more natural by allowing them to be treated as value types.
|
inlinevirtual |
|
inlinevirtual |
Connection options that will be to outgoing connections.
These are applied first and overriden by options provided in connect() and messaging_handler::on_connection_open().
Implements container.
|
inlinevirtual |
Connection options that will be to outgoing connections.
These are applied first and overriden by options provided in connect() and messaging_handler::on_connection_open().
Implements container.
|
inlinevirtual |
Connect to url
and send an open request to the remote peer.
Options are applied to the connection as follows, values in later options override earlier ones:
The handler in the composed options is used to call proton::messaging_handler::on_connection_open() when the remote peer's open response is received.
Implements container.
|
inlinevirtual |
Start listening on url.
Calls to the listen_handler are serialized for this listener, but handlers attached to separate listeners may be called concurrently.
url | identifies a listening url. |
lh | handles listening events |
Implements container.
|
inlinevirtual |
Listen with a fixed set of options for all accepted connections.
See listen(const std::string&, listen_handler&)
Implements container.
|
inlinevirtual |
Start listening on URL.
New connections will use the handler from server_connection_options()
Implements container.
|
pure virtualinherited |
Open a connection and receiver for url
.
Supplied receiver options will override the container's template options.
|
pure virtualinherited |
Open a connection and receiver for url
.
Supplied receiver or connection options will override the container's template options.
|
pure virtualinherited |
Open a connection and receiver for url
.
Supplied receiver or connection options will override the container's template options.
|
pure virtualinherited |
Open a connection and sender for url
.
Supplied sender options will override the container's template options.
|
pure virtualinherited |
Open a connection and sender for url
.
Supplied connection options will override the container's template options.
|
pure virtualinherited |
Open a connection and sender for url
.
Supplied sender or connection options will override the container's template options.
|
inlinevirtual |
Receiver options applied to receivers created by this container.
They are applied before messaging_handler::on_receiver_open() and can be overridden.
Implements container.
|
inlinevirtual |
Receiver options applied to receivers created by this container.
They are applied before messaging_handler::on_receiver_open() and can be overridden.
Implements container.
|
inlinevirtual |
Run the container in this thread.
Returns when the container stops.
With a multithreaded container, call run() in multiple threads to create a thread pool.
Implements container.
|
inlinevirtual |
Schedule a function to be called after the duration.
C++03 compatible, for C++11 use the schedule(duration, std::function<void()>)
Implements container.
|
inlinevirtual |
Sender options applied to senders created by this container.
They are applied before messaging_handler::on_sender_open() and can be overridden.
Implements container.
|
inlinevirtual |
Sender options applied to senders created by this container.
They are applied before messaging_handler::on_sender_open() and can be overridden.
Implements container.
|
inlinevirtual |
Connection options that will be applied to incoming connections.
These are applied first and overridden by options provided in listen(), listen_handler::on_accept() and messaging_handler::on_connection_open().
Implements container.
|
inlinevirtual |
Connection options that will be applied to incoming connections.
These are applied first and overridden by options provided in listen(), listen_handler::on_accept() and messaging_handler::on_connection_open().
Implements container.
|
inlinevirtual |
Experimental - Stop the container with an error_condition err.
!err.empty()
, handlers will receive on_transport_errorImplements container.
|
inlinevirtual |
Experimental - Stop the container with an empty error condition.
Implements container.