Struct NamespaceRpcHook 

pub struct NamespaceRpcHook { /* private fields */ }

RPC hook that injects namespace metadata into outgoing requests.

When the client configuration contains a namespace_v2 value, this hook automatically adds namespace-related extension fields to all RPC requests. This enables multi-tenancy and namespace isolation in RocketMQ clusters.

Two extension fields are added to requests when a namespace is configured:

• nsd: Marker field set to "true" indicating namespace presence
• ns: The actual namespace identifier

Examples

use cheetah_string::CheetahString;
use rocketmq_client_rust::ClientConfig;
use rocketmq_client_rust::NamespaceRpcHook;

let mut config = ClientConfig::default();
config.set_namespace_v2(CheetahString::from_static_str("my-namespace"));

let hook = NamespaceRpcHook::new(config);

Implementations

impl NamespaceRpcHook

pub fn new(client_config: ClientConfig) -> Self

Creates a new namespace RPC hook.

The hook uses the provided client configuration to determine whether namespace fields should be injected into requests.

pub fn client_config(&self) -> &ClientConfig

Returns a reference to the underlying client configuration.

Trait Implementations

impl RPCHook for NamespaceRpcHook

fn do_before_request( &self, _remote_addr: SocketAddr, request: &mut RemotingCommand, ) -> Result<(), SharedError>

Injects namespace extension fields into the request before transmission.

If the client configuration contains a namespace_v2 value, this method initializes the request’s extension fields map (if not already present) and adds the namespace marker and identifier fields.

fn do_after_response( &self, _remote_addr: SocketAddr, _request: &RemotingCommand, _response: &mut RemotingCommand, ) -> Result<(), SharedError>

Processes the response after reception.

This implementation performs no modifications and unconditionally returns Ok(()).