Trait TopicMessageQueueChangeListener 

pub trait TopicMessageQueueChangeListener: Send + Sync {
    // Required method
    fn on_changed(&self, topic: &str, message_queues: HashSet<MessageQueue>);
}

A trait for listening to changes in the message queues of a specific topic.

Required Methods

fn on_changed(&self, topic: &str, message_queues: HashSet<MessageQueue>)

Called when the message queues for a topic have changed.

Arguments

• topic - The name of the topic whose message queues have changed.
• message_queues - A set of MessageQueue instances representing the new state of the message queues.

Dyn Compatibility

This trait is dyn compatible.

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

Implementors