Skip to main content

create_admin

Function create_admin 

Source
pub async fn create_admin(
    namesrv_addr: impl Into<String>,
) -> RocketMQResult<DefaultMQAdminExt>
Expand description

Helper function to create a simple admin client with just address

Equivalent to:

AdminBuilder::new()
    .namesrv_addr(addr)
    .build_and_start()
    .await