Fully closed for read/write - sent both closed events

Transfer all pending bytes between two Proton engines by repeatedly calling peek/pop and push. Asserts that each engine accepts some

Release a message, indicating to the sender that it was not processed but may be delivered again to this or another receiver. @param opts [Hash] Inst

Returns the reply-to address

Call with no lock

Get the :class:`SASL` object associated with this transport. :return: SASL object associated with this transport.

Returns the parent session. @return [Session] The session.

Returns the locally defined source terminus. @return [Terminus] The terminus

@return [WorkQueue] The parent connection's work-queue.

CloseError sets an error condition (if err != nil) on an endpoint and closes the endpoint if not already closed

Decode reads the next AMQP value from the Reader and stores it in the value pointed to by v. See the documentation for Unmarshal for details about th

Dial is shorthand for conn, err := net.Dial(); c, err := Connection(conn, opts...) See net.Dial() for the meaning of the network, address arguments.

HandleEvent is called with an event. Typically HandleEvent() is implemented as a switch on e.Type()

SASLAllowInsecure returns a ConnectionOption that allows or disallows clear text SASL authentication mechanisms By default the SASL layer is configur

String returns Id()

Target address that messages are going to.

Call with sched lock

Convert an object to a condition. @param obj the object to turn into a condition @param default_name name to use if obj does not imply a name @return

Wrap an existing Proton-C data object.

Declare a local transaction. :param context: Context for the transaction, usually the connection. :param handler: Handler fo

If the current node is a double, returns its value. Otherwise, returns 0. @return [Float] The double precision floating point value.

Check if a link is currently draining. A link is defined to be draining when drain mode is set to ``True``, and the sender st

Additional error information associated with the connection. Whenever a connection operation fails (i.e. returns an error code),

If the current node is a float, returns its value. Otherwise, returns 0. @return [Float] The floating point value.

goTime converts a pn_timestamp_t to a Go time.Time. Take care to convert zero values to zero values.

@param at [Time] Insert item at time +at+ @param at [Numeric] Insert item at +Time.now \+ at+ @param at [0] Insert item at Time.at(0)

Return true with given probability */

Opens the connection. In more detail, this moves the local state of the connection to the ``ACTIVE`` state and triggers an o

pnTime converts Go time.Time to Proton millisecond Unix time. Take care to convert zero values to zero values.