From 48c04e83718a1193c11db2832cf107d7b4aa68b8 Mon Sep 17 00:00:00 2001 From: "Marcos G. Zimmermann" Date: Wed, 20 Nov 2024 17:12:54 -0300 Subject: [PATCH] feat: add procline to the consumer process --- lib/lepus/processes/consumer.rb | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/lib/lepus/processes/consumer.rb b/lib/lepus/processes/consumer.rb index 8d35868..2d5eea1 100644 --- a/lib/lepus/processes/consumer.rb +++ b/lib/lepus/processes/consumer.rb @@ -46,7 +46,15 @@ def shutdown super end + def set_procline + procline consumer_class.name + end + def setup_consumer! + if consumer_class.config.nil? + raise Lepus::InvalidConsumerConfigError, "Consumer #{consumer_class.name} has no configuration" + end + @bunny = Thread.current[:lepus_bunny] || Lepus.config.create_connection @channel = Thread.current[:lepus_channel] || begin @bunny.create_channel(nil, 1, true).tap do |channel|