Skip to main content

MQAdminMessageReadExt

rocketmq_client_rust

Trait MQAdminMessageReadExt 

Source 
pub trait MQAdminMessageReadExt: Send {
    // Required method
    async fn query_message_metadata(
        &self,
        topic: CheetahString,
        message_id: CheetahString,
    ) -> ClientResult<MessageMetadataRead>;

    // Provided method
    async fn query_message_metadata_by_id(
        &self,
        _message_id: CheetahString,
    ) -> ClientResult<MessageMetadataRead> { ... }
}
Expand description

Additive read-only capability for fixed, body-free message metadata.

Required Methods§

Source

async fn query_message_metadata( &self, topic: CheetahString, message_id: CheetahString, ) -> ClientResult<MessageMetadataRead>

Looks up one message while returning only a fixed body-free metadata projection.

Provided Methods§

Source

async fn query_message_metadata_by_id( &self, _message_id: CheetahString, ) -> ClientResult<MessageMetadataRead>

Looks up one offset message identifier and derives the authoritative Topic from the returned message.

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§