lib/bbk/amqp/publisher.rb
# Configure on return callback for exchange
Configure on return callback for exchange
Configure on return callback for exchange
def configure_exchange(exchange_name)
          return if @configured_exchanges.include?(exchange_name)
          logger.debug "Configure on_return callback for exchange #{exchange_name}"
          exchange = channel.exchange(exchange_name, passive: true)
          exchange.on_return(&method(:on_return).curry(4).call(exchange))
          @configured_exchanges << exchange_name
        end
def configure_exchange ( exchange_name ) return if @configured_exchanges . include? ( exchange_name ) logger . debug "Configure on_return callback for exchange #{exchange_name}" exchange = channel . exchange ( exchange_name , passive : true ) exchange . on_return ( & method ( :on_return ) . curry ( 4 ) . call ( exchange ) ) @configured_exchanges << exchange_name end
Configure on return callback for exchange
Configure on return callback for exchange
exchange_name
<not_specific>