Give events one safe front door
You publish normalized events into an inbox where policies authenticate, authorize, retry, dead-letter, and route them. Source callbacks never call a model directly.
Worked example
See the idea in context
auto source = std::make_shared<axllm::AxMCPEventSource>(
client, "inventory", "tenant:demo", "authenticated",
axllm::AxMCPResourceSubscriptionPolicy::all());
axllm::AxEventTarget target;
target.id = "inventory-agent";
target.mapInput = [](const axllm::AxEventEnvelope& event,
const axllm::AxEventContinuation*) {
return axllm::object({{"uri", axllm::Core::get(event.data, "uri")}});
};
target.invoke = invoke_agent;
axllm::AxEventRuntime runtime({axllm::AxEventRoute{
"resource-wake", "wake",
axllm::object({{"types", axllm::array({"mcp.resource.updated"})}}),
"inventory-agent", true,
}});
runtime.register_target(std::move(target)).add_source(source).start();Run itIn your own project
include(FetchContent)
FetchContent_Declare(axllm GIT_REPOSITORY https://github.com/ax-llm/ax GIT_TAG main SOURCE_SUBDIR packages/cpp)
FetchContent_MakeAvailable(axllm)
target_link_libraries(your_app PRIVATE axllm::axllm)
#include <axllm/axllm.hpp>
auto llm = axllm::ai("openai", axllm::object({{"apiKey", std::getenv("OPENAI_API_KEY")}}));
auto classify = axllm::ax("review:string -> sentiment:class \"positive, negative, neutral\"");Set OPENAI_APIKEY in your environment before running provider-backed code.
From a clone of the ax repo:
npm run example -- cpp src/examples/cpp/mcp/resource_wake_agent.cppActive practice
Answer 2 in a row to learn this · attempt 1