Returns the priority.

The receiver link associated with the event, or ``None`` if none is associated with it. This is essentially an alias for ``li

NO IDEA! :param handler: no idea :type handler: ? :param delegate: no idea :type delegate: ?

Returns a new session on this connection. :return: New session :raises: :class:`SessionException`

Copies output from first connection driver into input of the second. */

If the current node is a symbol, returns its value. Otherwise, it returns an empty string (""). @return [Symbol] The symbol value.

Request that the given event be dispatched on the event thread of the container to which this EventInjector was added. :para

Encode encodes the message as AMQP data. If buffer is non-nil and is large enough the message is encoded into it, otherwise a new buffer is created. R

Errorf makes a Error with name and formatted description as per fmt.Sprintf

NewConnection creates a connection with the given options. Options are applied in order.

Run the engine. Engine.Run() will exit when the engine is closed or disconnected. You can check for errors after exit with Engine.Error().

SASLAllowedMechs returns a ConnectionOption to set the list of allowed SASL mechanisms. Can be used on the client or the server to restrict the SASL

State is the open/closed state.

Unmarshal the message body, using amqp.Unmarshal()

All new tasks are added here

Apply options to this terminus. @option opts [String] :address the node address @option opts [Boolean] :dynamic (false) if true, request a new node wi

Close the link.

Indicate that the output has closed. This tells the transport that no more output will be popped. :raise: :exc:`TransportEx

Commit this transaction. Closes the transaction as a success.

Copy the contents of another pn_data_t object. Any values in the data object will be lost. :param src: The source object fro

Returns the delivery count for the message. This is the number of delivery attempts for the given message.

@private

return a list of 'count' TCP ports that are free to used (ie. unbound)

Returns a string that contains the value of the sub field of the subject field in the ssl certificate. The subject field usua