Struct CheckForbiddenContext 

pub struct CheckForbiddenContext<'a> {
    pub name_srv_addr: Option<CheetahString>,
    pub group: Option<CheetahString>,
    pub message: Option<&'a dyn MessageTrait>,
    pub mq: Option<&'a MessageQueue>,
    pub broker_addr: Option<CheetahString>,
    pub communication_mode: Option<CommunicationMode>,
    pub send_result: Option<SendResult>,
    pub exception: Option<ClientError>,
    pub arg: Option<Box<dyn Any + Send + Sync>>,
    pub unit_mode: bool,
}

Context information for forbidden operation checks.

Contains all relevant information about a message send operation, allowing hooks to inspect and validate the operation before execution.

Examples

use rocketmq_client::CheckForbiddenContext;
use cheetah_string::CheetahString;

let mut context = CheckForbiddenContext::default();
context.group = Some(CheetahString::from("test_group"));
context.broker_addr = Some(CheetahString::from("127.0.0.1:10911"));
context.unit_mode = false;

Fields

name_srv_addr: Option<CheetahString>

Name server address

group: Option<CheetahString>

Producer or consumer group name

message: Option<&'a dyn MessageTrait>

Message being sent (borrowed reference)

mq: Option<&'a MessageQueue>

Target message queue (borrowed reference)

broker_addr: Option<CheetahString>

Broker address

communication_mode: Option<CommunicationMode>

Communication mode (sync, async, or oneway)

send_result: Option<SendResult>

Send result (available after sending)

exception: Option<ClientError>

Exception that occurred during sending

arg: Option<Box<dyn Any + Send + Sync>>

Custom argument

unit_mode: bool

Whether unit mode is enabled

Implementations

impl<'a> CheckForbiddenContext<'a>

pub fn new() -> Self

Creates a new context.

pub fn with_name_srv_addr(self, addr: impl Into<CheetahString>) -> Self

Sets the name server address.

pub fn with_group(self, group: impl Into<CheetahString>) -> Self

Sets the group name.

pub fn with_broker_addr(self, addr: impl Into<CheetahString>) -> Self

Sets the broker address.

pub fn with_communication_mode(self, mode: CommunicationMode) -> Self

Sets the communication mode.

pub fn with_unit_mode(self, unit_mode: bool) -> Self

Sets the unit mode flag.

Trait Implementations

impl<'a> Debug for CheckForbiddenContext<'a>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'a> Default for CheckForbiddenContext<'a>

fn default() -> Self

Returns the “default value” for a type.

impl<'a> Display for CheckForbiddenContext<'a>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.