pub fn wrap_with_catch_unwind<CM, F>(
func: F,
) -> Pin<Box<dyn Fn(Arc<Message>, Arc<EventBus<CM>>) -> BoxFuture<()> + Send + Sync + RefUnwindSafe + 'static>>where
CM: ClusterManager + Send + Sync + 'static + RefUnwindSafe,
F: Fn(Arc<Message>, Arc<EventBus<CM>>) -> BoxFuture<()> + Send + 'static + Sync + RefUnwindSafe,