[]Function amqp_worker::parse_and_process_message

pub fn parse_and_process_message<ME: MessageEvent, F: Fn(Option<&Channel>, &Job, u8) -> Result<(), MessageError> + 'static>(
    message_event: &'static ME,
    message_data: &str,
    count: Option<i64>,
    channel: Option<&Channel>,
    publish_job_progression: F
) -> Result<JobResult, MessageError>