feat: add procline to the consumer process

marcosgz · Nov 25, 2024 · 48c04e8 · 48c04e8
1 parent cf6c933
commit 48c04e8
Showing 1 changed file with 8 additions and 0 deletions.
diff --git 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|