Skip to main content

agent_message

Function agent_message 

Source
pub fn agent_message(
    payload: impl Into<Vec<u8>>,
    provenance: Provenance,
) -> AgentMessage
Expand description

Build an AgentMessage for a handler unit test: a plain (non-envelope) message carrying payload and provenance, seated at the start of a synthetic partition. Feed it to an AgentHandler to exercise the handler without the reliable consumer or a live server.