Module headers 

Re-exported request/response headers organized by category

This module provides simplified access to commonly used headers through re-exports. Original module paths remain functional for backward compatibility.

Usage Examples

Import by category

use rocketmq_protocol::protocol::headers::message::SendMessageRequestHeader;
use rocketmq_protocol::protocol::headers::namesrv::RegisterBrokerRequestHeader;
use rocketmq_protocol::protocol::headers::namesrv::UnRegisterBrokerRequestHeader;

Import most common types directly

use rocketmq_protocol::protocol::headers::PullMessageRequestHeader;
use rocketmq_protocol::protocol::headers::SendMessageRequestHeader;

Re-exports

pub use super::header::ack_message_request_header::AckMessageRequestHeader;

pub use super::header::message_operation_header::send_message_request_header::SendMessageRequestHeader;

pub use super::header::pop_message_request_header::PopMessageRequestHeader;

pub use super::header::pull_message_request_header::PullMessageRequestHeader;

pub use super::header::client_request_header::GetRouteInfoRequestHeader;

pub use super::header::heartbeat_request_header::HeartbeatRequestHeader;

pub use super::header::namesrv::broker_request::UnRegisterBrokerRequestHeader;

pub use super::header::namesrv::register_broker_header::RegisterBrokerRequestHeader;

pub use super::header::get_max_offset_response_header::GetMaxOffsetResponseHeader;

pub use super::header::get_min_offset_response_header::GetMinOffsetResponseHeader;

pub use super::header::pull_message_response_header::PullMessageResponseHeader;

pub use super::header::add_broker_request_header::AddBrokerRequestHeader;

pub use super::header::create_topic_list_request_header::CreateTopicListRequestHeader;

pub use super::header::create_topic_request_header::CreateTopicRequestHeader;

pub use super::header::delete_topic_request_header::DeleteTopicRequestHeader;

pub use super::header::get_all_producer_info_request_header::GetAllProducerInfoRequestHeader;

pub use super::header::get_all_subscription_group_request_header::GetAllSubscriptionGroupRequestHeader;

pub use super::header::get_all_subscription_group_request_header::GetAllSubscriptionGroupResponseHeader;

pub use super::header::get_all_topic_config_request_header::GetAllTopicConfigRequestHeader;

pub use super::header::get_topic_config_request_header::GetTopicConfigRequestHeader;

pub use super::header::remove_broker_request_header::RemoveBrokerRequestHeader;

pub use super::header::query_consumer_offset_request_header::QueryConsumerOffsetRequestHeader;

pub use super::header::update_consumer_offset_conditional_header::UpdateConsumerOffsetConditionalHeader;

pub use super::header::update_consumer_offset_header::UpdateConsumerOffsetRequestHeader;

pub use super::header::empty_header::EmptyHeader;

Modules

ack

Acknowledgment headers

acl

admin

broker

client

controller

ha

lite

lock

max_offset

message

Send and receive message headers

min_offset

namesrv

notification

offset

polling

Pull and query message headers

query

Query message headers

special

transaction

util

view

View and search message headers