pub fn register<T: Clone + Send + Sync + 'static>(
registry: &mut MessagingRegistry<T>,
broker: InMemoryBroker<T>,
) -> AppResult<()>Expand description
Register in-memory producer and consumer factories.
pub fn register<T: Clone + Send + Sync + 'static>(
registry: &mut MessagingRegistry<T>,
broker: InMemoryBroker<T>,
) -> AppResult<()>Register in-memory producer and consumer factories.