input

Push a message onto the queue and notify any waiting senders

@private Convert a pn_data_t* containing a single value to a ruby object. @return [Object, nil] The ruby value extracted from +impl+ or nil if impl is

If the current value is a +UUID+, returns its value. Otherwise, it returns nil. @return [String] The string representation of the UUID.

Notify that this work item needs attention from the leader at the next opportunity */

Condition holds a local error condition.

NewDecoder returns a new decoder that reads from r. The decoder has it's own buffer and may read more data than required for the AMQP values requeste

Set the error if not already set

Source address that messages are coming from.

Wait waits for the connection to be disconnected.

Get the amount of free space for input following the transport's tail pointer. :return: Available space for input in bytes.

Clears the data object.

Close listener and force immediate close of socket

@private Clear a pn_data_t* and convert a ruby object into it. If x==nil leave it empty.

If the current node is a list, return the number of elements, otherwise return 0. List elements can be accessed by entering t

Get the value in milliseconds.

Create and open a {Receiver} link, see {Receiver#open} @param opts [Hash] receiver options, see {Receiver#open} @return [Receiver]

Settles the message delivery, and optionally updating the delivery state. :param delivery: The message delivery tracking obj

Send specified data as part of the current delivery. :param data: Data to send

@private

Get the message body, using the amqp.Unmarshal() rules for interface{}

Returns the value which must be Symbol, uint64 or nil

NewContainer creates a new container. The id must be unique in your distributed application, all connections created by the container will have this c

Session containing the Link

Send a request message, wait for and return the response message. :param request: Request message. If ``self.address`` is not set th

Raises an Proton-specific error if a return code is non-zero. Expects the class to provide an +error+ method.

Clears the state of the +Message+. This allows a single instance of +Message+ to be reused.

Result was a success, or failure is suppressed

@return [Message, nil] message for this event