lib/bbk/amqp/consumer.rb
# Ack incoming message and not send answer.
# @note answer should processing amqp publisher
# @param incoming [BBK::AMQP::Message] consumed message from amqp channel
# @param answer [BBK::App::Dispatcher::Result] answer message
Ack incoming message and not send answer.
Ack incoming message and not send answer .
def ack(incoming, *args, answer: nil, **kwargs)
        logger.debug "Ack message #{incoming.headers[:type]}[#{incoming.headers[:message_id]}]  delivery tag: #{incoming.delivery_info[:delivery_tag].to_i}"
        incoming.delivery_info[:channel].ack incoming.delivery_info[:delivery_tag]
      end
def ack ( incoming , * args , answer : nil , ** kwargs ) logger . debug "Ack message #{incoming.headers[:type]}[#{incoming.headers[:message_id]}]  delivery tag: #{incoming.delivery_info[:delivery_tag].to_i}" incoming . delivery_info [ :channel ] . ack incoming . delivery_info [ :delivery_tag ] end
Ack incoming message and not send answer.
Ack incoming message and not send answer .
# [] - для работы тестов. В реальности вернется объект VersionedDeliveryTag у #  которого to_i (вызывается внутри channel.ack) вернет фактическоe число # logger.debug "Ack message #{incoming.headers[:type]}[#{incoming.headers[:message_id]}] on channel: #{incoming.delivery_info[:channel]&.id}[#{incoming.delivery_info[:channel]&.object_id}] delivery tag: #{incoming.delivery_info[:delivery_tag].to_i}"
incoming
consumed message from amqp channel
consumed message from amqp channel
args
<not_specific>
answer
None
kwargs
<not_specific>
note
answer should processing amqp publisher
answer should processing amqp publisher