Struct EventPublisher 

pub struct EventPublisher { /* private fields */ }

Event publisher for SCUD task management events.

Manages ZMQ sockets for publishing events and handling requests.

Implementations

impl EventPublisher

pub fn new(pub_endpoint: &str, rep_endpoint: &str) -> Result<Self>

Create a new EventPublisher with ZMQ sockets.

Arguments

• pub_endpoint - Endpoint for the PUB socket (e.g., “tcp://*:5555”)
• rep_endpoint - Endpoint for the REP socket (e.g., “tcp://*:5556”)

Returns

A Result containing the EventPublisher or an error

pub fn publish(&self, topic: &str, message: &str) -> Result<()>

Publish an event message.

Arguments

• topic - The topic string for the message
• message - The message content

Returns

A Result indicating success or failure

pub fn receive_request(&self) -> Result<String>

Receive a request message.

This is a blocking call that waits for a request.

Returns

A Result containing the received message or an error

pub fn send_reply(&self, reply: &str) -> Result<()>

Send a reply message.

Arguments

• reply - The reply message to send

Returns

A Result indicating success or failure

Trait Implementations

impl Drop for EventPublisher

fn drop(&mut self)

Executes the destructor for this type.