Method handle_message

examples/pulsar_processor_complex.rs:117–134

(&mut self, msg: DeliveryResult)

    async fn terminate(&mut self) {}

    async fn handle_message(&mut self, msg: DeliveryResult) ->  ProcResult<()> {
        
        match msg {
            Some(send_future) => {
                match send_future.await {
                    Ok(_) => (),
                    Err(_e) => {
                        // TODO: handle error
                    }
                }
            }
            Err(pulsar_err) => {
                // TODO: Push to dead letter or requeue
            }
        }

        ProcResult::Continue
    } 
}