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