Route webhooks through the same event runtimeYou route authenticated webhooks, timers, queues, and application events through AxEventRuntime. UCP commerce events use the same explicit wake and resume policy.javaacademyacademy/topics/ucp-and-eventswebsite/content-src/academy/course.mjsacademyRoute webhooks through the same event runtime
You route authenticated webhooks, timers, queues, and application events through AxEventRuntime. UCP commerce events use the same explicit wake and resume policy.
9 focused minutesNot started
Worked example
See the idea in context
Response handleUCPWebhook(Request request) {
// Verify signer profile, RFC 9421 signature, digest, freshness,
// key rotation, and replay state before publishing.
VerifiedOrder order = verifyUCPRequest(request);
String identity = lookupBuyerIdentity(order.checkoutId());
runtime.publish(
new AxEventEnvelope(order.id(), "ucp://orders",
"ucp.order.fulfilled", order.data()),
identity, "authenticated");
return new Response(202);
}
Run itIn your own project
// Gradle (build.gradle):
implementation 'dev.axllm:ax:24.0.15'
// Maven (pom.xml):
<dependency>
<groupId>dev.axllm</groupId>
<artifactId>ax</artifactId>
<version>24.0.15</version>
</dependency>
import dev.axllm.ax.Ax;
import java.util.Map;
public class QuickStart {
public static void main(String[] args) throws Exception {
var llm = Ax.ai("openai", Map.of("apiKey", System.getenv("OPENAI_API_KEY")));
var classify = Ax.ax("review:string -> sentiment:class \"positive, negative, neutral\"");
var result = classify.forward(llm, Map.of(
"review", "Useful and boring in the best way."
));
System.out.println("sentiment: " + result.get("sentiment"));
}
}
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/long-agents/SmartDefaultsAgentExample.java