(msg: JobPayload, err: BroccoliError)
| 32 | } |
| 33 | |
| 34 | async fn error_handler(msg: JobPayload, err: BroccoliError) -> Result<(), BroccoliError> { |
| 35 | eprintln!("Failed to process message: {}. Error: {}", msg.id, err); |
| 36 | Ok(()) |
| 37 | } |
| 38 | |
| 39 | #[tokio::main] |
| 40 | async fn main() -> Result<(), Box<dyn Error>> { |