Re-exports§
pub use crate::protocol::rocketmq_serializable;pub use crate::codec::remoting_command_codec::CompositeCodec;pub use crate::codec::remoting_command_codec::RemotingCommandCodec;pub use crate::protocol::command_custom_header::CommandCustomHeader;pub use crate::protocol::command_custom_header::FromMap;pub use crate::protocol::RemotingCommand;pub use crate::code::request_code::RequestCode;pub use crate::code::response_code::RemotingSysResponseCode;pub use crate::protocol::header::ack_message_request_header::AckMessageRequestHeader;pub use crate::protocol::header::message_operation_header::send_message_request_header::SendMessageRequestHeader;pub use crate::protocol::header::pop_message_request_header::PopMessageRequestHeader;pub use crate::protocol::header::pull_message_request_header::PullMessageRequestHeader;pub use crate::protocol::header::client_request_header::GetRouteInfoRequestHeader;pub use crate::protocol::header::heartbeat_request_header::HeartbeatRequestHeader;pub use crate::protocol::header::namesrv::broker_request::UnRegisterBrokerRequestHeader;pub use crate::protocol::header::namesrv::register_broker_header::RegisterBrokerRequestHeader;pub use crate::protocol::header::create_topic_request_header::CreateTopicRequestHeader;pub use crate::protocol::header::delete_topic_request_header::DeleteTopicRequestHeader;pub use crate::protocol::header::get_topic_config_request_header::GetTopicConfigRequestHeader;pub use crate::protocol::header::get_max_offset_response_header::GetMaxOffsetResponseHeader;pub use crate::protocol::header::get_min_offset_response_header::GetMinOffsetResponseHeader;pub use crate::protocol::header::pop_message_response_header::PopMessageResponseHeader;pub use crate::protocol::header::pull_message_response_header::PullMessageResponseHeader;pub use crate::protocol::header::check_transaction_state_request_header::CheckTransactionStateRequestHeader;pub use crate::protocol::header::end_transaction_request_header::EndTransactionRequestHeader;pub use crate::protocol::header::query_consumer_offset_request_header::QueryConsumerOffsetRequestHeader;pub use crate::protocol::header::update_consumer_offset_header::UpdateConsumerOffsetRequestHeader;pub use crate::protocol::header::unregister_client_request_header::UnregisterClientRequestHeader;pub use crate::rpc::rpc_request::RpcRequest;pub use crate::rpc::rpc_request_header::RpcRequestHeader;pub use crate::rpc::rpc_response::RpcResponse;pub use crate::rpc::topic_request_header::TopicRequestHeader;pub use crate::protocol::body::batch_ack_message_request_body::BatchAckMessageRequestBody;pub use crate::protocol::body::broker_body::cluster_info::ClusterInfo;pub use crate::protocol::body::consumer_connection::ConsumerConnection;pub use crate::protocol::body::consumer_running_info::ConsumerRunningInfo;pub use crate::protocol::body::get_consumer_list_by_group_response_body::GetConsumerListByGroupResponseBody;pub use crate::protocol::body::topic_info_wrapper::topic_config_wrapper::TopicConfigSerializeWrapper;pub use crate::protocol::body::subscription_group_wrapper::SubscriptionGroupWrapper;pub use crate::protocol::body::request::lock_batch_request_body::LockBatchRequestBody;pub use crate::protocol::body::response::lock_batch_response_body::LockBatchResponseBody;pub use crate::protocol::body::query_assignment_response_body::QueryAssignmentResponseBody;pub use crate::protocol::body::broker_body::register_broker_body::RegisterBrokerBody;pub use crate::protocol::body::producer_connection::ProducerConnection;pub use crate::protocol::body::kv_table::KVTable;
Modules§
- base
- clients
- code
- codec
- common
- connection
- connection_
v2 - Refactored Connection based on FramedRead + FramedWrite
- error_
helpers - Error helper functions for rocketmq-remoting
- local
- net
- prelude
- Prelude module for convenient imports
- protocol
- remoting
- remoting_
server - request_
processor - rpc
- runtime
- Runtime components for remoting operations.
- smart_
encode_ buffer