Sha256: 092b6a1f7e908c9bf049d7c0d8621d497b8e670de1802fabf373eef544aa52c9
Contents?: true
Size: 1.76 KB
Versions: 6
Compression:
Stored size: 1.76 KB
Contents
require "thread"
require "amq/int_allocator"
module Bunny
class ChannelIdAllocator
#
# API
#
# @param [Integer] max_channel Max allowed channel id
def initialize(max_channel = ((1 << 16) - 1))
@allocator = AMQ::IntAllocator.new(1, max_channel)
@mutex = Mutex.new
end
# Returns next available channel id. This method is thread safe.
#
# @return [Fixnum]
# @api public
# @see ChannelManager#release_channel_id
# @see ChannelManager#reset_channel_id_allocator
def next_channel_id
@mutex.synchronize do
@allocator.allocate
end
end
# Releases previously allocated channel id. This method is thread safe.
#
# @param [Fixnum] i Channel id to release
# @api public
# @see ChannelManager#next_channel_id
# @see ChannelManager#reset_channel_id_allocator
def release_channel_id(i)
@mutex.synchronize do
@allocator.release(i)
end
end
# Returns true if given channel id has been previously allocated and not yet released.
# This method is thread safe.
#
# @param [Fixnum] i Channel id to check
# @return [Boolean] true if given channel id has been previously allocated and not yet released
# @api public
# @see ChannelManager#next_channel_id
# @see ChannelManager#release_channel_id
def allocated_channel_id?(i)
@mutex.synchronize do
@allocator.allocated?(i)
end
end
# Resets channel allocator. This method is thread safe.
# @api public
# @see Channel.next_channel_id
# @see Channel.release_channel_id
def reset_channel_id_allocator
@mutex.synchronize do
@allocator.reset
end
end
def synchronize(&block)
@mutex.synchronize(&block)
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems