I think we should be more descriptive in the docstring to explain how the task decorator is used:

Entry point into correlation pipeline for messages received from the syslog parser after being converted to JSON.  These messages must be converted into CEE format for processing.  

This entry point is implemented as a queued task.  The parameters in the task decorator allow for the task to be retried indefinitely int he event of network failure (store & forward).  Exceptions thrown from failed validation or a malformed message do not initiate a retry but instead allow the task to fail.