part1: call with tsk->owner lock held, return true if notify_poller required by caller. Nothing to do if the task is currently at work or work is alre

Settle the next message previously taken with :meth:`pop`. :param state: :type state:

Accept and open the endpoint.

* Unmarshal decodes AMQP-encoded bytes and stores the result in the Go value pointed to by v. Legal conversions from the source AMQP type to the targ

@return [Condition] Error condition associated with this event or nil if none.

@return [Object] the event context object

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

Returns the annotations for the disposition. @return [Codec::Data] The annotations.

Delivery annotations as a dictionary of key/values. The AMQP 1.0 specification restricts this dictionary to have keys that are either

Set the full path to the certificate,keyfile, etc. for the test.

transfer all available data between two transports

If the current node is a string, returns its value. Otherwise, it returns an empty string (""). @return [String] The UTF-8 encoded string. @see #bin

Return the full path to the certificate, keyfile, etc.

Decodes the first value from supplied AMQP data and returns the number of bytes consumed. :param encoded: AMQP encoded binar

Drain excess credit for this link. When a link is in drain mode (see :attr:`drain_mode`), the sender must use all excess cre

Parse the command line, return the index of the first non-option argument. *@throws bad_option if there is a parsing error or unknown option.

Generates a random hash of values.

NewMessage creates a new message instance.

Pop a message off the queue. If no messages available, record sender as waiting and return nil.