lib/pwwka/receiver.rb in pwwka-0.20.0 vs lib/pwwka/receiver.rb in pwwka-0.21.0

@@ -10,10 +10,10 @@
     attr_reader :routing_key
 
     def initialize(queue_name, routing_key, prefetch: Pwwka.configuration.default_prefetch)
       @queue_name        = queue_name
       @routing_key       = routing_key
-      @channel_connector = ChannelConnector.new(prefetch: prefetch, connection_name: "c: #{queue_name}")
+      @channel_connector = ChannelConnector.new(prefetch: prefetch, connection_name: "c: #{Pwwka.configuration.app_id} #{Pwwka.configuration.process_name}".strip)
       @channel           = @channel_connector.channel
       @topic_exchange    = @channel_connector.topic_exchange
     end
 
     def self.subscribe(handler_klass, queue_name,