Class: Mutual::Messaging::TaskManager

Inherits:
Object
  • Object
show all
Defined in:
lib/messaging/task_manager.rb

Instance Method Summary collapse

Constructor Details

#initialize(messaging) ⇒ TaskManager

Returns a new instance of TaskManager.



5
6
7
8
 
# File 'lib/messaging/task_manager.rb', line 5

def initialize(messaging)
  @messaging = messaging
  @client = @messaging.create_redis_client
end

Instance Method Details

#create(options) ⇒ Object 



11
12
13
14
15
16
17
 
# File 'lib/messaging/task_manager.rb', line 11

def create(options)
  options[:task_id] = @messaging.generate_id
  if options.delete(:response)
    options[:return_address] = @messaging.id
  end
  Task.new(options)
end

#send(task) ⇒ Object 



19
20
21
 
# File 'lib/messaging/task_manager.rb', line 19

def send(task)
  @messaging.push_queue(task.queue, task)
end