Class Qpid::Proton::Transport
In: lib/core/transport.rb
Parent: Object

@deprecated all important features are available from {Connection}

Methods

apply   bind   close_head   close_tail   condition   condition=   connection   log   new   peek   pop   process   push   quiesced?   sasl   set_server   ssl   ssl?   tick   trace   unbind   wrap  

Included Modules

Util::Deprecation Util::Wrapper Util::ErrorHandler

Constants

PROTON_METHOD_PREFIX = "pn_transport"   @private
TRACE_OFF = Cproton::PN_TRACE_OFF   Turn logging off entirely.
TRACE_RAW = Cproton::PN_TRACE_RAW   Log raw binary data into/out of the transport.
TRACE_FRM = Cproton::PN_TRACE_FRM   Log frames into/out of the transport.
TRACE_DRV = Cproton::PN_TRACE_DRV   Log driver related events; i.e., initialization, end of stream, etc.

Public Class methods

Creates a new transport instance.

@private

Public Instance methods

@private Options are documented {Connection#open}, keep that consistent with this

Indicate that the output has closed.

Tells the transport that no more output will be popped.

@raise [TransportError] If an error occurs.

Indicate that the input has reached EOS (end of stream).

This tells the transport that no more input will be forthcoming.

@raise [TransportError] If an error occurs.

@return [Condition, nil] transport error condition or nil if there is no error.

Set the error condition for the transport. @param c [Condition] The condition to set

Return the AMQP connection associated with the transport.

@return [Connection, nil] The bound connection, or nil.

Log a message to the transport‘s logging mechanism.

This can be using in a debugging scenario as the message will be prepended with the transport‘s identifier.

@param message [String] The message to be logged.

Returns the specified number of bytes from the transport‘s buffers.

@param size [Integer] The number of bytes to return.

@return [String] The data peeked.

@raise [TransportError] If an error occurs.

Removes the specified number of bytes from the pending output queue following the transport‘s head pointer.

@param size [Integer] The number of bytes to remove.

Process input data following the tail pointer.

Calling this function will cause the transport to consume the specified number of bytes of input occupying the free space following the tail pointer. It may also change the value for tail, as well as the amount of free space reported by capacity.

@param size [Integer] The number of bytes to process.

@raise [TransportError] If an error occurs.

Pushes the supplied bytes into the tail of the transport.

@param data [String] The bytes to be pushed.

@return [Integer] The number of bytes pushed.

Returns whether the transport has any buffered data.

@return [Boolean] True if the transport has no buffered data.

Create, or return existing, SSL object for the transport. @return [SASL] the SASL object

Set server mode for this tranport - enables protocol detection and server-side authentication for incoming connections

Creates, or returns an existing, SSL object for the transport.

@param domain [SSLDomain] The SSL domain. @param session_details [SSLDetails] The SSL session details.

@return [SSL] The SSL object.

@private

Process any pending transport timer events.

This method should be called after all pending input has been processed by the transport (see input), and before generating output (see output).

It returns the deadline for the next pending timer event, if any art present.

@param now [Time] The timestamp.

@return [Integer] If non-zero, the expiration time of the next pending

  timer event for the transport. The caller must invoke #tick again at
  least once at or before this deadline occurs.

Updates the transports trace flags.

@param level [Integer] The trace level.

@see TRACE_OFF @see TRACE_RAW @see TRACE_FRM @see TRACE_DRV

Unbinds from the previous connection.

[Validate]