Struct Message 

pub struct Message {
    pub id: String,
    pub topic: String,
    pub payload: Vec<u8>,
    pub sender: String,
    pub metadata: HashMap<String, String>,
    pub created_at: i64,
}

Fields

id: String

topic: String

payload: Vec<u8>

sender: String

metadata: HashMap<String, String>

created_at: i64

Implementations

impl Message

pub fn new( topic: impl Into<String>, payload: Vec<u8>, sender: impl Into<String>, ) -> Self

Examples found in repository

examples/mesh_architecture.rs (line 38)

    async fn on_message(&mut self, msg: Message, _ctx: &mut AgentContext) -> Result<()> {
        let content = String::from_utf8_lossy(&msg.payload);
        println!("[Worker] Received task from {}: {}", msg.sender, content);

        // Simulate processing
        tokio::time::sleep(Duration::from_millis(500)).await;

        // Send response
        let response = format!("Processed: {}", content);
        println!("[Worker] Sending response: {}", response);

        let reply_msg = Message::new("result", response.into_bytes(), self.name());
        self.mesh.send(reply_msg, &msg.sender).await?;

        Ok(())
    }
}

// --- Manager Agent ---
struct ManagerAgent {
    mesh: Arc<LocalMesh>,
    completion_notify: Arc<Notify>,
}

#[async_trait]
impl Agent for ManagerAgent {
    fn name(&self) -> String {
        "manager".to_string()
    }

    async fn on_start(&mut self, _ctx: &mut AgentContext) -> Result<()> {
        println!("[Manager] Started. Sending task to worker...");

        // Send a task to the worker
        let task_msg = Message::new("task", b"Analyze data".to_vec(), self.name());
        self.mesh.send(task_msg, "worker").await?;

        Ok(())
    }

pub fn correlation_id(&self) -> Option<String>

pub fn set_correlation_id(&mut self, id: &str)

Trait Implementations

impl Clone for Message

fn clone(&self) -> Message

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Message

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Message

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Message

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.