class FileChannel
FileChannel
- channel to hold queues and topics
Attributes
channel_name[R]
Public Class Methods
new(root_location)
click to toggle source
# File lib/file_channel.rb, line 9 def initialize(root_location) @channel_name = SecureRandom.hex(20).to_s @channel_location = root_location + '/' + @channel_name FileUtils.mkdir_p @channel_location @topics = {} end
Public Instance Methods
queue()
click to toggle source
# File lib/file_channel.rb, line 21 def queue FileQueue.new end
topic(topic_name)
click to toggle source
# File lib/file_channel.rb, line 17 def topic(topic_name) @topics[topic_name] = FileTopic.new(@channel_location, topic_name) end