Unit 10 · React safely to live events

Subscribe only to the resources you need

You start with no resource subscriptions and opt into a selector or explicit URI list. Templates are never expanded or authorized automatically.

8 focused minutesNot started

Unit example (nearest native match)

See the idea in context

AxMCPEventSource source = new AxMCPEventSource(
    client, "inventory", "tenant:demo", "authenticated",
    AxMCPEventSource.all());
AxEventRuntime.Target target = new AxEventRuntime.Target(
    "inventory-agent", (input, context) -> agent.forward(
        llm, castMap(input), Map.of("runtime", js)))
    .mapInput((event, continuation) -> Map.of(
        "uri", castMap(event.data()).get("uri")))
    .retrySafety("idempotent");
AxEventRuntime runtime = new AxEventRuntime(List.of(
    new AxEventRoute("resource-wake", "wake",
        Map.of("types", List.of("mcp.resource.updated")),
        "inventory-agent", true, "strict", 0)))
    .registerTarget(target)
    .addSource(source);
runtime.start();

Run itIn your own project

// Gradle (build.gradle):
implementation 'dev.axllm:ax:22.0.4'
// Maven (pom.xml):
<dependency>
  <groupId>dev.axllm</groupId>
  <artifactId>ax</artifactId>
  <version>22.0.4</version>
</dependency>

import dev.axllm.ax.Ax;

var llm = Ax.ai("openai", Map.of("apiKey", System.getenv("OPENAI_API_KEY")));
var classify = Ax.ax("review:string -> sentiment:class \"positive, negative, neutral\"");

Set OPENAI_APIKEY in your environment before running provider-backed code.

In the ax repo

From a clone of the ax repo:

npm run example -- java src/examples/java/mcp/ResourceWakeAgentExample.java

Active practice

Show that you can use it

Answer 2 in a row to learn this · attempt 1

Keep exploring

See the idea in context

Show that you can use it

Source-backed follow-up