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.



8
9
10
# 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

Instance Method Details

#publish(message) ⇒ Object



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

def publish(message)
  @file_system_queue.add(message[:message])
end