Call with task lock held.

Access and modify the AMQP properties data for the Terminus. This operation will return an instance of Data that is valid until the Terminus is freed

Returns a representation of the remotely defined source terminus. @return [Terminus] The terminus.

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

Returns the subject

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

Returns the time-to-live, in milliseconds.

Call with sched lock. If true returned, caller must call notify_poller() after releasing the lock. If resume_thread is set, the caller must call resum

Unbinds a transport from its AMQP connection. :raise: :exc:`TransportException` if there is any Proton error.

@private

Decode data into this message. Overwrites an existing message content.

Has is True if bits & state is non 0.

Inject a function into the Engine's event loop. f() will be called in the same event-processing goroutine that calls Handler methods. f() can safely

ParseUrl parses an AMQP URL string and returns a net/url.Url. It is more forgiving than net/url.Parse and allows most of the parts of the URL to be m

RemoteCondition holds a remote error condition.

SendSync sends a message and blocks until the message is acknowledged by the remote receiver. Returns an Outcome, which may contain an error if the me

Source returns a LinkOption that sets address that messages are coming from.

Sync() waits for the remote peer to confirm the endpoint is active or reject it with an error. You can call it immediately on new endpoints for more p

Connection or listener lock must also be held by caller.

Sets flag when parse() is called if option is present. */

Get the name of the Cipher that is currently in use. Gets a text description of the cipher that is currently active, or retu

Close the connection.

Returns the content type

Returns the correlation id.

Returns the creation time.

Shorthand for debugging an action using id as identifier */

Process this event by sending it to all known handlers that are valid for this event type. :param handler: Parent handler to

Returns the expiration time.

Grants credit for incoming deliveries. @param n [Integer] The amount to increment the link credit.

==== get message from pn_message_t

Returns the group id.

Returns the message id.

Listen for incoming AMQP connections on an existing server socket. @param io A server socket, for example a {TCPServer} @param handler [Listener::Hand