Method: LontaraUtilities::RMQ::Server::Subscriber#start

Defined in:
lib/lontara_utilities/rmq/server/subscriber.rb

#start ⇒ Object

Start consuming the queue and process the request.



14
15
16
17
18
19
20
21
22
 
# File 'lib/lontara_utilities/rmq/server/subscriber.rb', line 14

def start
  queue.subscribe(manual_ack: true) do |delivery_info, _, body|
    @request = JSON.parse(body, symbolize_names: true)

    channel.ack(delivery_info.delivery_tag)

    process_request
  end
end