Contents

module HotBunnies
  # Wraps a delivery tag (which is an integer) so that {Bunny::Channel} could
  # detect stale tags after connection recovery.
  #
  # @private
  class VersionedDeliveryTag
    attr_reader :tag
    attr_reader :version

    def initialize(tag, version)
      raise ArgumentError.new("tag cannot be nil") unless tag
      raise ArgumentError.new("version cannot be nil") unless version

      @tag     = tag
      @version = version
    end

    def to_i
      @tag
    end

    def stale?(version)
      raise ArgumentError.new("version cannot be nil") unless version

      @version < version
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
hot_bunnies-2.0.0.pre13-java	lib/hot_bunnies/versioned_delivery_tag.rb
hot_bunnies-2.0.0.pre12-java	lib/hot_bunnies/versioned_delivery_tag.rb