* Constructor * @param what */

* Construct based on incoming frame * * @param frame received frame to decode */

* Construct a queue bind frame * * @param channel channel identifier * @param String name name of the queue

* Construct a queuebindokframe * * @param channel channel identifier */

* Construct a channel flow frame * * @param channel channel identifier * @param String name Name of the queue

* Construct a channel flow frame * * @param channel channel identifier * @param code reply code * @param

* Construct a queuedeleteframe * * @param channel channel identifier * @param name name of the queue * @param

* Construct a queuedeleteokframe * * @param channel channel identifier * @param messageCount number of messages */

* Construct a queueframe * @param channel channel identifier * @param size size of the frame */

* Construct a QueuePurgeFrame * * @param channel channel identifier * @param name name of the queue * @param noWait

* Construct a queuepurgeokframe * * @param channel channel identifier * @param messageCount number of messages */

* Construct a queueunbindframe * * @param channel channel identifier * @param name name of the queue * @param

* Decode a queueunbindokframe from a received frame * * @param frame received frame to decode * @return shared pointer to created

* Constructor * @param buffer Binary buffer * @param max Max size for a frame */

* Constructor * @param buffer * @param skip */

* Constructor * @param frame */

* Control the SSL context * @param ctx * @param cmd * @param larg * @param parg * @return long */

* Obtain shutdown statue for TLS/SSL I/O operation * @param ssl SSL object * @return int returns error values */

* Increment refcount for a ssl structure * @param ctx SSL structure * @return int 1 for success, 0 for failure */

* Set the certificate file to be used by the connection * @param ssl ssl structure * @param file filename * @param type type of fi

* Constructor * @param state The previous state * @param ssl The SSL structure * @param buffer The buffer tha

* Constructor * @param method the connect method to use * @throws std::runtime_error */

* Constructor * @param retval return value of SSL_get_error (must be a proper error) */

* Constructor * @param state Earlier state * @param hostname The hostname to connect to * @param context SSL contex

* Constructor * @param state Previous state * @param ssl The SSL structure */

* Constructor * @param ctx * @param file */

* Initialize empty string */

* Decode the data from a received frame into a table * * @param frame received frame to decode */

* Constructor that creates an empty table */

* Constructor * @param channel */

* Deleted copy constructor, deleted move constructor * @param other */

* Constructor * * The passed in connection pointer must remain valid for the * lifetime of the channel. A constructor is thrown if

* Constructor * @param parent The parent object */

* Constructor * @param state The previous state * @param buffer The buffer that was already built */

* Constructor * @param handler User implemented handler object * @param hostname The address to connect to */

* No copying * @param that */

* Constructor * @param parent */

* Constructor * Note that we pass 0 to the constructor because the buffer seems to be empty * @param size initial size to allocat

* Regular constructor */

* Constructor * @param parent Parent connection object * @param hostname The hostname for the lookup * @param portnumber

* Protected constructor * @param parent The parent object * @param handler User-supplied handler class */

* Constructor * @param channel * @param throttle */

* Deleted copy constructor, deleted move constructor * @param other */

* Construct a transaction commit frame * * @param channel channel identifier * @return newly created transaction commit frame

* Construct a transaction commit ok frame * * @param channel channel identifier * @return newly created transaction commit o

* Constructor * @param channel channel identifier * @param size frame size */

* Decode a transaction rollback frame from a received frame * * @param frame received frame to decode */

* Decode a transaction rollback ok frame from a received frame * * @param frame received frame to decode */

* Decode a transaction select frame from a received frame * * @param frame received frame to decode */

* Constructor for an incoming frame * * @param frame received frame to decode */

* Default constructor */

* Constructor * @param loop The current event loop * @param connection The connection being watched *

* Constructor * @param loop The current event loop * @param object The object being watched * @pa

* Constructor- initialises the watcher and assigns the filedescriptor to * a boost socket for monitoring. * @param io_context

* Constructor * @param evbase The current event loop * @param connection The connection being watched *

* Constructor * @param loop The current event loop * @param connection The TCP connection * @param t

* Acknoldge a received message * * When a message is received in the DeferredConsumer::onReceived() method, * you must acknowledge i

* Is channel flow active? * @return bool */

* Is channel flow active or not? * @return bool */

* Wait until a filedescriptor becomes active (readable or writable) * @return bool */

* Add a monitor * @param monitor */

* Add a binary buffer to the buffer * @param string char* to the string * @param size size of string */

* Convert event flags from AMQP format to UV format */

* The method that adds the actual data * @param data * @param size */

* Is this an autodelete exchange? * @return bool */

* returns whether the queue is deleted if unused * @return bool */

* Is the auto-delete property set? * The entity is removed when the consumers and/or queues are unlinked from it * @return bool */

* Size of the body * @return uint64_t */

* Get access to a single byte * @param pos position in the buffer * @return char value of the byte in the buffer */

* Callback method that is called by libev when the timer expires * @param loop The loop in which the event was triggered * @param

* Callback method that is called by libuv when a filedescriptor becomes active * @param handle Internal poll handle * @param

* Callback method that is called by libev when a filedescriptor becomes active * @param loop The loop in which the event was trigge

* Callback method that is called by libev when the timer expires * @param loop The loop in which the event was triggered *

* Callback method that is called by libevent when a filedescriptor becomes active * @param fd The filedescriptor with an

* Return the channel identifier * @return uint16_t */

* Get a channel by its identifier * * This method only works if you had already created the channel before. * This is an internal me

* Proposed maximum number of channels * @return _uint16_t */

* Proposed maximum number of channels * @return _uint16_t */

* Retrieve the amount of channels this connection has * @return std::size_t */

* Retrieve the number of channels that are active for this connection * @return std::size_t */

* Return the number of channels this connection has. * @return std::size_t */

* Class id * @return uint16_t */

* returns the class id * @return uint16_t */

* Class id * @return uint16_t */

* Class id * @return uint16_t */

* Class id * @return uint16_t */

* The class ID * @return uint16_t */

* Class id * @return uint16_t */

* Class id * @return uint16_t */

* Clean-up the socket, and call the onClosed() method */

* Create a new instance of this object * @return unique_ptr */

* Create a new instance of this object * @return unique_ptr */

* Create a new instance of this object * @return std::unique_ptr<Field> */

* Create a new identical instance of this object * @return unique_ptr */

* Extending from field forces us to implement a clone function. * @return unique_ptr */

* Gracefully close the connection */

* Gracefully start closing the connection */

* Gracefully close the connection */

* Is this a closed / dead state? * @return bool */