Module: Msgr::Message::Acknowledge

Included in:
Msgr::Message
Defined in:
lib/msgr/message/acknowledge.rb

Instance Method Summary collapse

Instance Method Details

#ack ⇒ Object

Send message acknowledge to broker unless message is already acknowledged.



22
23
24
25
26
27
 
# File 'lib/msgr/message/acknowledge.rb', line 22

def ack
  unless acked?
    @acked = true
    @connection.future(:ack, delivery_info.delivery_tag).value
  end
end

#acked? ⇒ Boolean

Check if message is already acknowledged.

Returns:

  • (Boolean) —

    True if message is acknowledged, false otherwise.



13
14
15
 
# File 'lib/msgr/message/acknowledge.rb', line 13

def acked?
  @acked ? true : false
end