[−]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>