Class: Pubilion::Worker::MessageHandler

Inherits:
Object
  • Object
show all
Defined in:
lib/pubilion/worker/message_handler.rb

Overview

Message handler for Pubilion worker

Instance Method Summary collapse

Instance Method Details

#on_error(error) ⇒ Object

Handle error



27
28
29
 
# File 'lib/pubilion/worker/message_handler.rb', line 27

def on_error(error)
  # TODO: Implement error handling
end

#on_message(message) ⇒ Object

Handle incoming message



10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
 
# File 'lib/pubilion/worker/message_handler.rb', line 10

def on_message(message)
  autoreload do
    job = deserialize(message.data)

    if job.nil?
      message.nack!
      return
    end

    job.perform_now
    message.ack!
  end
rescue StandardError
  message.nack!
end