Struct RemotingCommandFactory 

pub struct RemotingCommandFactory { /* private fields */ }

Builds business commands from one immutable set of wire defaults.

A factory does not read process configuration. Application owners may keep the process-default compatibility path or inject explicit factories when multiple remoting configurations must coexist in one process.

Examples

use rocketmq_protocol::protocol::remoting_command_defaults::{
    RemotingCommandDefaults, RemotingCommandFactory,
};
use rocketmq_protocol::protocol::SerializeType;

let json = RemotingCommandFactory::new(RemotingCommandDefaults::new(101, SerializeType::JSON));
let binary = RemotingCommandFactory::new(RemotingCommandDefaults::new(202, SerializeType::ROCKETMQ));

assert_eq!(json.create_remoting_command(10).version(), 101);
assert_eq!(binary.create_remoting_command(10).version(), 202);

Implementations

impl RemotingCommandFactory

pub const fn new(defaults: RemotingCommandDefaults) -> Self

Creates a factory with explicit version and serialization defaults.

pub const fn defaults(&self) -> RemotingCommandDefaults

Returns the immutable defaults owned by this factory.

pub fn create_remoting_command(&self, code: impl Into<i32>) -> RemotingCommand

Creates a base command with an explicit code.

pub fn create_request( &self, code: impl Into<i32>, body: impl Into<Bytes>, ) -> RemotingCommand

Creates a request with an external body.

pub fn create_request_command<T>( &self, code: impl Into<i32>, header: T, ) -> RemotingCommand

where T: CommandCustomHeader + Sync + Send + 'static,

Creates a request with a typed custom header.

pub fn create_response_command_with_code( &self, code: impl Into<i32>, ) -> RemotingCommand

Creates a response with an explicit response code.

pub fn create_response_command_with_code_and_header( &self, code: impl Into<i32>, header: impl CommandCustomHeader + Sync + Send + 'static, ) -> RemotingCommand

Creates a response with an explicit code and typed custom header.

pub fn create_response_command_with_code_remark( &self, code: impl Into<i32>, remark: impl Into<CheetahString>, ) -> RemotingCommand

Creates a response with an explicit code and remark.

pub fn create_success_response_command(&self) -> RemotingCommand

Creates an explicitly successful response.

pub fn create_success_response_command_with_header( &self, header: impl CommandCustomHeader + Sync + Send + 'static, ) -> RemotingCommand

Creates an explicitly successful response with a typed custom header.

pub fn create_java_default_error_response_command(&self) -> RemotingCommand

Creates Java’s unset error response.

pub fn create_java_default_error_response_command_with_header( &self, header: impl CommandCustomHeader + Sync + Send + 'static, ) -> RemotingCommand

Creates Java’s unset error response with a typed custom header.

Trait Implementations

impl Clone for RemotingCommandFactory

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Copy for RemotingCommandFactory

impl Debug for RemotingCommandFactory

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

Formats the value using the given formatter.

impl Eq for RemotingCommandFactory

impl PartialEq for RemotingCommandFactory

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for RemotingCommandFactory