A class representing a message received from nsqd.
If you want to perform asynchronous message processing use the nsq.Message.enable_async() method, pass the message around, and respond using the appropriate instance method.
Parameters: |
|
---|
Enables asynchronous processing for this message.
nsq.Reader will not automatically respond to the message upon return of message_handler.
Respond to nsqd that you’ve processed this message successfully (or would like to silently discard it).
Returns whether or not this message has been responded to.
Returns whether or not asynchronous processing has been enabled.
Respond to nsqd that you’ve failed to process this message successfully (and would like it to be requeued).
Parameters: |
|
---|
Respond to nsqd that you need more time to process the message.