* Process the filedescriptor in the object * @param monitor Object to check if connection still exists * @param fd The

* Process the filedescriptor in the object * @param monitor Monitor to check if the object is still alive * @param fd File

* Process the TCP connection * This method should be called when the filedescriptor that is registered * in the event loop becomes active. You sh

* Process a basic frame * @param connection * @return bool */

* Process a channel frame * @param connection * @return bool */

* Process a confirm frame * @param connection * @return bool */

* Process a connection frame * @param connection * @return bool */

* Process an exchange frame * @param connection * @return bool */

* Process a header frame * @param connection * @return bool */

* Process a method frame * @param connection * @return bool */

* Process a queue frame * @param connection * @return bool */

* Process a transaction frame * @param connection * @return bool */

* return the protocol major version, should be 0 * @return uint8_t */

* return the protocol minor version, should be 9 * @return uint8_t */

* What is the state of the connection - is the protocol handshake completed? * @return bool */

* Publish a message to an exchange * * @param exchange the exchange to publish to * @param routingkey the routing key * @param envelope

* Publish a message to an exchange * * You have to supply the name of an exchange and a routing key. RabbitMQ will then try * to se

* Number of bytes in the outgoing buffer * @return std::size_t */

* Number of bytes in the outgoing buffer * @return std::size_t */

* The number of outgoing bytes queued on this connection. * @return size_t */

* Number of bytes in the outgoing buffer * @return std::size_t */

* Number of bytes in the outgoing buffer * @return std::size_t */

* The number of outgoing bytes queued on this connection. * @return std::size_t */

* Handler method that is called by boost's io_context when the socket pumps a read event. * @param ec The status of the callback.

* Is the channel ready / has it passed the initial handshake? * @return bool */

* Are we fully connected and ready for instructions? This is true after the initial * protocol and login handshake were completed and the conne

* Is the connection ready to accept instructions / has passed the login handshake and not closed? * @return bool */

* Is the connection connected, meaning: it has passed the login handshake * and isn't closed yet? * @return bool */

* Perform a receive operation * @param monitor object to check the existance of the connection object * @return TcpState */

* Return whether the message has been previously delivered to (another) client * @return bool */

* Reject a message * @param deliveryTag the delivery tag * @param flags optional flags * @return bool */

* Reject or nack a message * * When a message was received in the DeferredConsumer::onReceived() method, * and you don't want to ack

* Methods to remove properties from the header */

* Helper function to order the vector of addrinfo based on the ordering received * This may be useful since getaddrinfo is sorting the addresses

* Method to repeat the previous call * @param monitor monitor to check if connection object still exists * @param state the s

* Method to repeat the previous call * @param monitor object to check if connection still exists * @param result result of an

* Report that the server has cancelled this consumer * @param namae The consumer tag */

* Report that the connection is closed */

* Report an error message on a channel * @param message the error message * @param notifyhandler should the channel-wide hand

* Method that is called to report an error * @param message */

* Helper method to report an error * @param monitor * @param retval return value of SSL_get_error * @return TcpState* */

* Helper method to report an error * This method also assumes that result <= 0 is an error, unless the operation can be retried. * @param

* Indicate failure * @param error Description of the error that occured */

* Method that is called to report an error * @param message */

* Return whether the server will try to requeue * @return bool */

* Return whether the server will try to requeue * @return bool */

* Return whether the server will try to requeue * @return bool */

* Reverse the order */

* return the protocol revision, should be 1 * @return uint8_t */

* Send a frame over the connection * @param frame The frame to send * @return bool Was the frame succesfully sent */

* Send data over the connection * @param buffer buffer to send * @param size size of the buffer */

* Send data over the connection * @param buffer buffer to send * @param size size of the buffer */

* Send data over the connection * @param buffer buffer to send * @param size size of the buffer */

* Send data over the connection * @param buffer buffer to send * @param size size of the buffer */

* Method to send the close frames * Returns true if object still exists * @return bool */

* Set a boolean in the set * @param index * @param value */

* Set a custom argument * @param name Name of the argument * @param value Value of the argument */

* Update the auto-delete bit * @param bool */

* Mark the object as durable * @param bool */

* Set the various supported fields * @param value */

* Change the name * You must declare the entity before this has effect * @param string */

* Change the passive bit * @param bool */

* Set whether storage should be persistent or not * @param bool */

* Shrink the buffer with a number of bytes * @param toremove */

* Shuffle the addresses */

* Total size of the buffer * @return size_t */

* Size of the array * @return size_t */

* Total size of the buffer * @return size_t */

* Get the size this field will take when * encoded in the AMQP wire-frame format * @return size_t */

* Get the size this field will take when * encoded in the AMQP wire-frame format * @return size_t */

* Current size of the output buffer * @return size_t */

* Get the size this field will take when * encoded in the AMQP wire-frame format */

* Get the size this field will take when * encoded in the AMQP wire-frame format */