Class: DispatchRider::NotificationServices::FileSystem::Channel

Inherits:
Object
  • Object
show all
Defined in:
lib/dispatch-rider/notification_services/file_system/channel.rb

Instance Method Summary collapse

Constructor Details

#initialize(path) ⇒ Channel

Returns a new instance of Channel.



7
8
9
# File 'lib/dispatch-rider/notification_services/file_system/channel.rb', line 7

def initialize(path)
  @file_system_queue = DispatchRider::QueueServices::FileSystem::Queue.new(path)
end

Instance Method Details

#publish(message) ⇒ Object



11
12
13
# File 'lib/dispatch-rider/notification_services/file_system/channel.rb', line 11

def publish(message)
  @file_system_queue.add(message)
end