Module Qpid::Proton
In: lib/qpid_proton.rb
lib/reactor/container.rb
lib/core/messaging_handler.rb
lib/core/sasl.rb
lib/core/terminus.rb
lib/core/session.rb
lib/core/ssl_details.rb
lib/core/container.rb
lib/core/ssl.rb
lib/core/disposition.rb
lib/core/sender.rb
lib/core/transport.rb
lib/core/endpoint.rb
lib/core/message.rb
lib/core/work_queue.rb
lib/core/tracker.rb
lib/core/delivery.rb
lib/core/listener.rb
lib/core/event.rb
lib/core/condition.rb
lib/core/exceptions.rb
lib/core/link.rb
lib/core/uri.rb
lib/core/ssl_domain.rb
lib/core/url.rb
lib/core/receiver.rb
lib/core/connection.rb
lib/core/transfer.rb
lib/core/connection_driver.rb
lib/handler/messaging_adapter.rb
lib/handler/messaging_handler.rb
lib/handler/reactor_messaging_adapter.rb
lib/handler/adapter.rb
lib/types/type.rb
lib/types/array.rb
lib/util/schedule.rb
lib/util/wrapper.rb
lib/codec/mapping.rb
lib/codec/data.rb

Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file to you under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

  http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Methods

_context   condition   connection   container   context   delivery   dispatch   get   inspect   link   message   new   receiver   sender   session   to_s   tracker   transport   uri  

Classes and Modules

Module Qpid::Proton::Codec
Module Qpid::Proton::Error
Module Qpid::Proton::Handler
Module Qpid::Proton::Reactor
Module Qpid::Proton::TimeCompare
Module Qpid::Proton::Types
Module Qpid::Proton::Util
Class Qpid::Proton::AbortedError
Class Qpid::Proton::ArgumentError
Class Qpid::Proton::AttributeError
Class Qpid::Proton::Condition
Class Qpid::Proton::Connection
Class Qpid::Proton::ConnectionDriver
Class Qpid::Proton::Container
Class Qpid::Proton::Delivery
Class Qpid::Proton::Disposition
Class Qpid::Proton::EOSError
Class Qpid::Proton::Endpoint
Class Qpid::Proton::Event
Class Qpid::Proton::HandlerDriver
Class Qpid::Proton::InProgressError
Class Qpid::Proton::InterruptedError
Class Qpid::Proton::Link
Class Qpid::Proton::LinkError
Class Qpid::Proton::Listener
Class Qpid::Proton::Message
Class Qpid::Proton::MessagingHandler
Class Qpid::Proton::OverflowError
Class Qpid::Proton::ProtonError
Class Qpid::Proton::Receiver
Class Qpid::Proton::Reject
Class Qpid::Proton::Release
Class Qpid::Proton::SASL
Class Qpid::Proton::SASLError
Class Qpid::Proton::SSL
Class Qpid::Proton::SSLDomain
Class Qpid::Proton::SSLError
Class Qpid::Proton::SSLSessionDetails
Class Qpid::Proton::SSLUnavailableError
Class Qpid::Proton::Schedule
Class Qpid::Proton::Sender
Class Qpid::Proton::Session
Class Qpid::Proton::SessionError
Class Qpid::Proton::StateError
Class Qpid::Proton::StopAutoResponse
Class Qpid::Proton::StoppedError
Class Qpid::Proton::Terminus
Class Qpid::Proton::TimeoutError
Class Qpid::Proton::Tracker
Class Qpid::Proton::Transfer
Class Qpid::Proton::Transport
Class Qpid::Proton::TransportError
Class Qpid::Proton::URL
Class Qpid::Proton::UnderflowError
Class Qpid::Proton::WorkQueue

Constants

Event = self   @private
DEFAULT_URI_PARSER = URI::Parser.new(:HOSTNAME => /(?:#{URI::PATTERN::HOSTNAME})|/)   Make sure to allow empty hostnames, Ruby 2.0.0 does not.

External Aliases

method -> type

Attributes

method  [RW]  @return [Symbol] method name that this event will call in {dispatch}

Public Class methods

Use Event.new(impl) to wrap a C event, or Event.new(nil, method, context) to create a pure-ruby event.

Convert s to an amqp: or amqps: URI

This does not give the same result as the standard URI parser in all cases. Short-cut strings like "host:port" are allowed, an "amqp://" prefix is added if s does not already look like an ‘amqp:’ or ‘amqps:’ URI.

@param s [String,URI] String to convert to a URI, or a URI object. @return [URI] A valid AMQP or AMQPS URI @raise [URI::BadURIError] s is a URI object with a non-AMQP scheme @raise [URI::InvalidURIError] s cannot be parsed as a URI or shortcut @raise [::ArgumentError] s is not a string or URI

Public Instance methods

@return [Condition] Error condition associated with this event or nil if none.

@return [Connection, nil] the connection for this event

@return [Container, nil] container for this event

@return [Object] the event context object

@return [Delivery, nil] delivery for this event

Call handler.{method}(self) if handler.respond_to? {method} @return [Boolean] true if handler responded to the method, nil if not.

Get the context if it is_a?(clazz), else call method on the context

@return [Link, nil] link for this event

@return [Message, nil] message for this event

@return [Receiver, nil] receiver associated with this event

@return [Sender, nil] sender associated with this event

@return [Session, nil] session for this event

@return [Tracker, nil] delivery for this event

@return [Transport, nil] transport for this event

[Validate]