We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 4b1d9c1 commit 07627e0Copy full SHA for 07627e0
1 file changed
pubsub/google/cloud/pubsub_v1/subscriber/policy/thread.py
@@ -296,8 +296,9 @@ def on_response(self, response):
296
For each message, schedule a callback with the executor.
297
"""
298
for msg in response.received_messages:
299
- _LOGGER.debug('New message received from Pub/Sub:\n%r', msg)
300
- _LOGGER.debug(self._callback)
+ _LOGGER.debug(
+ 'Using %s to process new message received:\n%r',
301
+ self._callback, msg)
302
message = Message(msg.message, msg.ack_id, self._request_queue)
303
future = self._executor.submit(self._callback, message)
304
future.add_done_callback(_callback_completed)
0 commit comments