Qpid Proton C++ API
0.32.0
|
|
Go to the documentation of this file. 1 #ifndef PROTON_IO_CONNECTION_DRIVER_HPP
2 #define PROTON_IO_CONNECTION_DRIVER_HPP
25 #include "../connection_options.hpp"
26 #include "../error_condition.hpp"
28 #include "../internal/config.hpp"
29 #include "../types_fwd.hpp"
31 #include <proton/connection_driver.h>
200 std::string container_id_;
202 pn_connection_driver_t driver_;
208 #endif // PROTON_IO_CONNECTION_DRIVER_HPP
Describes an endpoint error state.
Definition: error_condition.hpp:40
void connect(const connection_options &opts)
Call configure() with client options and call connection::open() Options applied: container::id(),...
Unsettled API - An AMQP driver for a single connection.
Definition: connection_driver.hpp:94
proton::transport transport() const
Get the transport associated with this connection_driver.
Unsettled API - A pointer to an immutable memory region with a size.
Definition: connection_driver.hpp:57
A top-level container of connections, sessions, and links.
Definition: container.hpp:50
bool has_events() const
There are events to be dispatched by dispatch()
void accept(const connection_options &opts)
Call configure() with server options.
void configure(const connection_options &opts=connection_options(), bool server=false)
Configure a connection by applying exactly the options in opts (including proton::messaging_handler) ...
mutable_buffer(char *data_=0, size_t size_=0)
Construct a buffer starting at data_ with size_ bytes.
Definition: connection_driver.hpp:52
bool dispatch()
Dispatch all available events and call the corresponding messaging_handler methods.
const char * data
Beginning of the buffered data.
Definition: connection_driver.hpp:58
connection_driver()
An engine without a container id.
A connection to a remote AMQP peer.
Definition: connection.hpp:45
Options for creating a connection.
Definition: connection_options.hpp:67
char * data
Beginning of the buffered data.
Definition: connection_driver.hpp:48
connection_driver(const std::string &)
Create a connection driver associated with a container id.
void read_close()
Indicate that the read side of the transport is closed and no more data will be read.
proton::connection connection() const
Get the AMQP connection associated with this connection_driver.
void write_done(size_t n)
Indicate that the first n bytes of write_buffer() have been written successfully.
Handler for Proton messaging events.
Definition: messaging_handler.hpp:69
void disconnected(const error_condition &=error_condition())
Inform the engine that the transport been disconnected unexpectedly, without completing the AMQP conn...
Unsettled API - A pointer to a mutable memory region with a size.
Definition: connection_driver.hpp:47
mutable_buffer read_buffer()
The engine's read buffer.
const_buffer(const char *data_=0, size_t size_=0)
Construct a buffer starting at data_ with size_ bytes.
Definition: connection_driver.hpp:62
void read_done(size_t n)
Indicate that the first n bytes of read_buffer() have valid data.
A network channel supporting an AMQP connection.
Definition: transport.hpp:37
timestamp tick(timestamp now)
Indicate that time has passed.
size_t size
Number of bytes in the buffer.
Definition: connection_driver.hpp:49
The main Proton namespace.
Definition: annotation_key.hpp:33
proton::container * container() const
Get the container associated with this connection_driver, if there is one.
void write_close()
Indicate that the write side of the transport has closed and no more data can be written.
size_t size
Number of bytes in the buffer.
Definition: connection_driver.hpp:59
A 64-bit timestamp in milliseconds since the Unix epoch.
Definition: timestamp.hpp:35
const_buffer write_buffer()
The engine's write buffer.