Class: ActiveHook::Server::MessageRunner

Inherits:

Object

• Object
• ActiveHook::Server::MessageRunner

Defined in:

lib/activehook/server/queue.rb

Instance Method Summary

• #initialize(json) ⇒ MessageRunner constructor

  A new instance of MessageRunner.

• #start ⇒ Object

Constructor Details

#initialize(json) ⇒ MessageRunner

Returns a new instance of MessageRunner.

# File 'lib/activehook/server/queue.rb', line 39

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

Instance Method Details

#start ⇒ Object

# File 'lib/activehook/server/queue.rb', line 45

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