Get the error.

Marshal a Go value into the message body, synonym for SetBody()

Message decodes the message contained in a delivery. Must be called in the correct link context with this delivery as the current message, handling a

Password returns a ConnectionOption to set the password used to establish a connection. Only applies to outbound client connection. The connection w

Prefetch returns a LinkOption that sets a receivers pre-fetch flag. Not relevant for a sender.

ReceiveTimeout is like Receive but gives up after timeout, see Timeout. Note that that if Prefetch is false, after a Timeout the credit issued by Rec

Reject the endpoint with an error

Server returns a ConnectionOption to put the connection in server mode for incoming connections. A server connection will do protocol negotiation to

Server puts the Engine in server mode, meaning it will auto-detect security settings on the incoming connection such as use of SASL and SSL. Must be c

SetCapacity sets the capacity of the incoming receiver, call before Accept()

SetPrefetch sets the pre-fetch mode of the incoming receiver, call before Accept()

Authenticated user name associated with the connection.

Check all items in list are :class:`symbol`s (or are converted to symbols).

Send N messages to a receiver. Parameters: iterations - repeat the senders this many times target_count = # of targets to sen

Acknowledge a ReceivedMessage with the given delivery status.

Total count of listener and connections for PN_PROACTOR_INACTIVE */

Assumes listener lock is held

If the current node is a character, returns its value. Otherwise, returns 0. @return [Integer] The character value.

If want has port=0 and got has port > 0 then return port of got, else return 0 */

Thread safe

Close the connection and the listener so so we will get a * PN_PROACTOR_INACTIVE event and exit, once all outstanding events * are processed. */

Deprecated: use connection_to_host() instead

@return AMQP container ID advertised by the remote peer. To get the local container ID use {#container} and {Container#id}

Create a blocking receiver. :param address: Address of source node. :param credit: Initial link flow credit. If not set, wil

Decodes a message from AMQP binary data. @param encoded [String] the encoded bytes @return[Integer] the number of bytes consumed

Fill in missing values (scheme, host or port) with defaults :return: self

Encodes the message.