Skip to main content

normalize_timer_request_fields

rocketmq_model::common::message::timer_request

Function normalize_timer_request_fields 

Source 
pub fn normalize_timer_request_fields(
    delay_seconds: Option<&str>,
    delay_milliseconds: Option<&str>,
    deliver_at_milliseconds: Option<&str>,
    now_ms: u64,
    policy: TimerPolicySnapshot,
) -> Result<NormalizedTimerRequest, ModelContractViolation>
Expand description

Normalizes timer fields for adapters that do not use RocketMQ’s internal property-map type.

§Errors

Has the same validation behavior as normalize_timer_request.