Class | AMQ::Client::Async::Exchange |
In: |
lib/amq/client/async/exchange.rb
|
Parent: | Object |
BUILTIN_TYPES | = | [:fanout, :direct, :topic, :headers].freeze |
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 |
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
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)