Get the value in milliseconds.

Pushes the supplied bytes into the tail of the transport. Only some of the bytes will be copied if there is insufficient capa

Sets the parent node to the current node and clears the current node. Clearing the current node sets it *before* the first child,

Returns a binary representation of the data encoded in AMQP format. :return: The encoded data :raise: :exc:`DataException` i

checkDecode: want is the expected value, gotPtr is a pointer to a instance of the same type for Decode.

Sets the current node to the parent node and the parent node to its own parent. :return: ``True`` iff the pointers to the cu

Thread safe

Convert python string into bytes compatible with char* C string

Convert char* C strings returned from proton-c into python unicode

Close an endpoint.

part2: unblock epoll_wait(). Make OS call without lock held.

@return [Link, nil] link for this event

invokes a test-phase method (which can be the test method itself or a setUp/tearDown method). If the method raises an exception the except

Formats the contents of this :class:`Data` object in a human readable way. :return: A Formatted string containing contents of this :

Initiates the establishment of an AMQP connection. An optional JSON configuration file may be used to specify some connection

Open an AMQP connection. @param url [String, URI] Open a {TCPSocket} to url.host, url.port. url.scheme must be "amqp" or "amqps", url.scheme.nil? is

The amount of pending message data for a delivery.

handle state changes of the endpoints