Return a proxy handler that dispatches to the provided handler. If handler throws an exception then on_error is called with info

Accept the receiveed message.

merge a comma-separated list of addresses

@name Array operators @{

If the current node is binary, returns its value. Otherwise, it returns an empty string (""). @return [String] The binary string. @see #string

Buffer is "in use" if ownership transferred to raw connection or TLS until a future event.

XXX: assuming numeric - if we get a symbol we should map it to the numeric value and dispatch on that

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

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

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

decode from bytes. Return bytes decoded or 0 if we could not decode a complete object.

Returns the durable property. The durable property indicates that the emessage should be held durably by any intermediaries taking responsibility for

Checked versions of pn_data functions

Check for support of extended SASL negotiation. All implementations of Proton support ``ANONYMOUS`` and ``EXTERNAL`` on both

Return the next event batch or NULL if no events are available */

A convenience method for decoding an AMQP described value. :returns: The decoded AMQP descriptor.

Returns the group sequence number.

Idle-timeout advertised by the remote peer, in seconds. @return [Numeric] Idle-timeout advertised by the remote peer, in seconds. @return [nil] if the

Test if local ``endpoint`` is open (ie has state :const:`proton.Endpoint.LOCAL_ACTIVE`). :param endpoint: The local endpoint

Retrieve the first link that matches the given state mask. Examines the state of each link owned by the connection and returns

Listen for incoming AMQP connections @param url [String,URI] Listen on host:port of the AMQP URL @param handler [Listener::Handler] A {Listener::Hand

Call in proton goroutine to initiate closing an endpoint locally handler will complete the close when remote end closes.

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

This sets the reactor now instant to the current time

call without lock

Set the error condition and close the driver. */

Convert std::string to pn_bytes_t