File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -223,7 +223,7 @@ def build_initial_requests
223223
224224 def process_response ( response , stream )
225225 type_url = response . type_url
226- Console . info ( self ) { "Processing response for type_url: #{ type_url } " }
226+ Console . debug ( self , "Processing response:" , type_url : type_url )
227227
228228 callback = nil
229229 resources = nil
@@ -232,7 +232,7 @@ def process_response(response, stream)
232232 @mutex . synchronize do
233233 subscription = @subscriptions [ type_url ]
234234 unless subscription
235- Console . warn ( self ) { "No subscription found for type_url: #{ type_url } " }
235+ Console . warn ( self ) { "No subscription found!" , type_url : type_url }
236236 return
237237 end
238238
@@ -254,7 +254,7 @@ def process_response(response, stream)
254254 if callback
255255 callback . call ( resources )
256256 else
257- Console . warn ( self ) { "No callback found for type_url: #{ type_url } " }
257+ Console . warn ( self , "No callback found!" , type_url : type_url )
258258 end
259259
260260 # Send ACK (acknowledge receipt)
You can’t perform that action at this time.
0 commit comments