class DispatchRider::NotificationServices::FileSystem::Channel
Public Class Methods
new(path)
click to toggle source
# File lib/dispatch-rider/notification_services/file_system/channel.rb, line 8 def initialize(path) @file_system_queue = DispatchRider::QueueServices::FileSystem::Queue.new(path) end
Public Instance Methods
publish(message)
click to toggle source
# File lib/dispatch-rider/notification_services/file_system/channel.rb, line 12 def publish(message) @file_system_queue.add(message[:message]) end