Class AMQ::Client::Async::Exchange
In: lib/amq/client/async/exchange.rb
lib/amq/client/async/extensions/rabbitmq/confirm.rb
Parent: Object

Methods

Included Modules

Entity ServerNamedEntity Extensions::RabbitMQ::Confirm::ExchangeMixin

Constants

BUILTIN_TYPES = [:fanout, :direct, :topic, :headers].freeze

Attributes

arguments  [R]  @return [Hash] Additional arguments given on queue declaration. Typically used by AMQP extensions.
channel  [R]  Channel this exchange belongs to.
name  [R]  Exchange name. May be server-generated or assigned directly. @return [String]
type  [R]  @return [Symbol] One of :direct, :fanout, :topic, :headers

Public Class methods

Public Instance methods

after_connection_interruption(&block)
after_recovery(&block)

Alias for on_recovery

Called by associated connection object when AMQP connection has been re-established (for example, after a network failure).

@api plugin

Defines a callback that will be executed after TCP connection is recovered after a network failure but before AMQP connection is re-opened. Only one callback can be defined (the one defined last replaces previously added ones).

@api public

@return [Boolean] true if this exchange is of a custom type (begins with x-) @api public

@return [Boolean] true if this exchange is of type `direct` @api public

@return [Boolean] true if this exchange is of type `fanout` @api public

@return [Boolean] true if this exchange is of type `headers` @api public

Defines a callback that will be executed after TCP connection is interrupted (typically because of a network failure). Only one callback can be defined (the one defined last replaces previously added ones).

@api public

Defines a callback that will be executed when AMQP connection is recovered after a network failure.. Only one callback can be defined (the one defined last replaces previously added ones).

@api public

@return [Boolean] true if this exchange is a pre-defined one (amq.direct, amq.fanout, amq.match and so on)

@return [Boolean] true if this exchange is of type `topic` @api public

[Validate]