diff --git a/lib/lepus/processes/consumer.rb b/lib/lepus/processes/consumer.rb index 8d35868..48f26f3 100644 --- a/lib/lepus/processes/consumer.rb +++ b/lib/lepus/processes/consumer.rb @@ -46,6 +46,10 @@ def shutdown super end + def set_procline + "lepus-consumer: #{consumer_class.name}" + end + def setup_consumer! @bunny = Thread.current[:lepus_bunny] || Lepus.config.create_connection @channel = Thread.current[:lepus_channel] || begin