Class: ActiveHook::Server::MessageRunner

Inherits:
Object
  • Object
show all
Defined in:
lib/activehook/server/queue.rb

Instance Method Summary collapse

Constructor Details

#initialize(json) ⇒ MessageRunner 



37
38
39
40
41
 
# File 'lib/activehook/server/queue.rb', line 37

def initialize(json)
  @message = Message.new(JSON.parse(json))
  @post = Send.new(message: @message)
  start
end

Instance Method Details

#start ⇒ Object 



43
44
45
46
47
48
 
# File 'lib/activehook/server/queue.rb', line 43

def start
  @post.start
  ActiveHook::Server.redis.with do |conn|
    @post.success? ? message_success(conn) : message_failed(conn)
  end
end