Sha256: 9eead8d814b8eef6366fbd8fb13ca1076d8b430c7b3183f61c5404e452f027a3
Contents?: true
Size: 581 Bytes
Versions: 7
Compression:
Stored size: 581 Bytes
Contents
module Msgr
class Message
#
#
module Acknowledge
# Check if message is already acknowledged.
#
# @return [Boolean] True if message is acknowledged, false otherwise.
# @api public
#
def acked?
@acked ? true : false
end
# Send message acknowledge to broker unless message is
# already acknowledged.
#
# @api public
#
def ack
unless acked?
@acked = true
@connection.future(:ack, delivery_info.delivery_tag).value
end
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems