NSQ Message¶
-
class
gnsq.
Message
(timestamp, attempts, id, body)[source]¶ A class representing a message received from nsqd.
-
enable_async
()[source]¶ Enables asynchronous processing for this message.
Consumer
will not automatically respond to the message upon return ofhandle_message()
.
-
finish
()[source]¶ Respond to nsqd that you’ve processed this message successfully (or would like to silently discard it).
-
on_requeue
[source]¶ Emitted after
requeue()
.The signal sender is the message instance and sends the
timeout
and abackoff
flag as arguments.
-