Skip to content

[skip-runtime-e2e] examples: add planning and connectors examples #207

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
Drifter-yh wants to merge 1 commit into
base: main
Choose a base branch
from
Open

[skip-runtime-e2e] examples: add planning and connectors examples #207

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
42 changes: 42 additions & 0 deletions examples/connectors/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,42 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0">
<modelVersion>4.0.0</modelVersion>

<groupId>com.getaxonflow.examples</groupId>
<artifactId>connectors</artifactId>
<version>1.0-SNAPSHOT</version>
<packaging>jar</packaging>

<name>AxonFlow Java SDK — Connectors Example</name>
<description>
Minimal read-only example exercising listConnectors() against
a running AxonFlow agent.
</description>

<properties>
<maven.compiler.source>11</maven.compiler.source>
<maven.compiler.target>11</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>

<dependencies>
<dependency>
<groupId>com.getaxonflow</groupId>
<artifactId>axonflow-sdk</artifactId>
<version>9.0.0</version>
</dependency>
</dependencies>

<build>
<plugins>
<plugin>
<groupId>org.codehaus.mojo</groupId>
<artifactId>exec-maven-plugin</artifactId>
<version>3.1.0</version>
<configuration>
<mainClass>com.getaxonflow.examples.Connectors</mainClass>
</configuration>
</plugin>
</plugins>
</build>
</project>
49 changes: 49 additions & 0 deletions examples/connectors/src/main/java/com/getaxonflow/examples/Connectors.java
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,49 @@
// Copyright 2026 AxonFlow
// SPDX-License-Identifier: Apache-2.0
//
// Minimal read-only AxonFlow Java SDK connectors example.
//
// Run from this directory:
//
// mvn -q compile exec:java
package com.getaxonflow.examples;

import com.getaxonflow.sdk.AxonFlow;
import com.getaxonflow.sdk.AxonFlowConfig;
import com.getaxonflow.sdk.types.ConnectorInfo;

import java.util.List;

public class Connectors {

public static void main(String[] args) {
String endpoint = envOrDefault("AXONFLOW_AGENT_URL", "http://localhost:8080");
String clientId = envOrDefault("AXONFLOW_CLIENT_ID", "community");
String clientSecret = envOrDefault("AXONFLOW_CLIENT_SECRET", "");

try (AxonFlow client =
AxonFlow.create(
AxonFlowConfig.builder()
.endpoint(endpoint)
.clientId(clientId)
.clientSecret(clientSecret)
.build())) {
List<ConnectorInfo> connectors = client.listConnectors();
System.out.printf("Found %d connectors%n", connectors.size());
for (ConnectorInfo connector : connectors) {
System.out.printf(
"- id=%s name=%s type=%s version=%s installed=%s%n",
connector.getId(),
connector.getName(),
connector.getType(),
connector.getVersion(),
connector.isInstalled());
}
}
}

private static String envOrDefault(String name, String fallback) {
String value = System.getenv(name);
return value == null || value.isEmpty() ? fallback : value;
}
}
42 changes: 42 additions & 0 deletions examples/planning/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,42 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0">
<modelVersion>4.0.0</modelVersion>

<groupId>com.getaxonflow.examples</groupId>
<artifactId>planning</artifactId>
<version>1.0-SNAPSHOT</version>
<packaging>jar</packaging>

<name>AxonFlow Java SDK — Planning Example</name>
<description>
Minimal example exercising generatePlan() + executePlan() against
a running AxonFlow agent.
</description>

<properties>
<maven.compiler.source>11</maven.compiler.source>
<maven.compiler.target>11</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>

<dependencies>
<dependency>
<groupId>com.getaxonflow</groupId>
<artifactId>axonflow-sdk</artifactId>
<version>9.0.0</version>
</dependency>
</dependencies>

<build>
<plugins>
<plugin>
<groupId>org.codehaus.mojo</groupId>
<artifactId>exec-maven-plugin</artifactId>
<version>3.1.0</version>
<configuration>
<mainClass>com.getaxonflow.examples.Planning</mainClass>
</configuration>
</plugin>
</plugins>
</build>
</project>
54 changes: 54 additions & 0 deletions examples/planning/src/main/java/com/getaxonflow/examples/Planning.java
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,54 @@
// Copyright 2026 AxonFlow
// SPDX-License-Identifier: Apache-2.0
//
// Minimal AxonFlow Java SDK planning example.
//
// This example requires a local AxonFlow stack with an LLM provider configured.
//
// Run from this directory:
//
// mvn -q compile exec:java
package com.getaxonflow.examples;

import com.getaxonflow.sdk.AxonFlow;
import com.getaxonflow.sdk.AxonFlowConfig;
import com.getaxonflow.sdk.types.PlanRequest;
import com.getaxonflow.sdk.types.PlanResponse;

public class Planning {

public static void main(String[] args) {
String endpoint = envOrDefault("AXONFLOW_AGENT_URL", "http://localhost:8080");
String clientId = envOrDefault("AXONFLOW_CLIENT_ID", "community");
String clientSecret = envOrDefault("AXONFLOW_CLIENT_SECRET", "");

try (AxonFlow client =
AxonFlow.create(
AxonFlowConfig.builder()
.endpoint(endpoint)
.clientId(clientId)
.clientSecret(clientSecret)
.build())) {
PlanRequest request =
PlanRequest.builder()
.objective("Research a topic and summarize the key findings")
.build();

System.out.println("Generating plan...");
PlanResponse plan = client.generatePlan(request);
System.out.println("Plan generated: " + plan.getPlanId());

System.out.println("Executing plan...");
PlanResponse result = client.executePlan(plan.getPlanId());
System.out.println("Plan execution status: " + result.getStatus());
if (result.getResult() != null) {
System.out.println("Result: " + result.getResult());
}
}
}

private static String envOrDefault(String name, String fallback) {
String value = System.getenv(name);
return value == null || value.isEmpty() ? fallback : value;
}
}