Correlation changes

Wrote code to change correlation from an object and helper methods to method chain. if coordinator is unavailable, messages will be queued as a celery task instead being lost.