Skip to main content

Crate zimq_impl

Crate zimq_impl 

Source

Modules§

defer
error
message

Macros§

defer
defer_async

Functions§

cleanup
First interrupts the delayed message expiration detector, then waits for pending messages (immediate and expired) in the execution queue to complete, and finally releases resources before exiting.
init
Initialize ZIMQ
send_delay
Publishes a delayed message to the specified topic.
send_delay_ex
Publishes a delayed message with a custom message ID to the specified topic. If a delayed message with the same ID already exists and has not been consumed yet, this method will return ZimqError::DuplicatedMessageError to prevent duplicates.
send_immediate
Publishes an immediate message to the specified topic.
start
Starts the core services of the ZIMQ.
subscribe
Subscribes to messages on a specific topic.