Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
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
1 change: 1 addition & 0 deletions .gitignore
Original file line number Diff line number Diff line change
Expand Up @@ -26,3 +26,4 @@ effective-pom.xml
db.mv.db

akka-context/
.claude/settings.local.json
2 changes: 1 addition & 1 deletion pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
<parent>
<groupId>io.akka</groupId>
<artifactId>akka-javasdk-parent</artifactId>
<version>3.5.4</version>
<version>3.5.5</version>
</parent>

<groupId>io.akka.ai</groupId>
Expand Down
10 changes: 5 additions & 5 deletions src/main/java/demo/multiagent/application/ActivityAgent.java
Original file line number Diff line number Diff line change
@@ -1,22 +1,22 @@
package demo.multiagent.application;

import akka.javasdk.agent.Agent;
import akka.javasdk.annotations.AgentDescription;
import akka.javasdk.annotations.AgentRole;
import akka.javasdk.annotations.Component;
import akka.javasdk.client.ComponentClient;
import demo.multiagent.domain.AgentRequest;
import java.util.stream.Collectors;

@Component(id = "activity-agent")
@AgentDescription(
@Component(
id = "activity-agent",
name = "Activity Agent",
description = """
An agent that suggests activities in the real world. Like for example,
a team building activity, sports, an indoor or outdoor game,
board games, a city trip, etc.
""",
role = "worker"
"""
)
@AgentRole("worker")
public class ActivityAgent extends Agent {


Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2,14 +2,14 @@

import akka.javasdk.agent.evaluator.SummarizationEvaluator;
import akka.javasdk.agent.evaluator.ToxicityEvaluator;
import akka.javasdk.annotations.ComponentId;
import akka.javasdk.annotations.Component;
import akka.javasdk.annotations.Consume;
import akka.javasdk.client.ComponentClient;
import akka.javasdk.consumer.Consumer;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

@ComponentId("agent-team-eval-consumer")
@Component(id = "agent-team-eval-consumer")
@Consume.FromWorkflow(AgentTeamWorkflow.class)
public class AgentTeamEvaluatorConsumer extends Consumer { // <1>

Expand Down
6 changes: 3 additions & 3 deletions src/main/java/demo/multiagent/application/EvaluatorAgent.java
Original file line number Diff line number Diff line change
@@ -1,16 +1,16 @@
package demo.multiagent.application;


import akka.javasdk.agent.Agent;
import akka.javasdk.agent.EvaluationResult;
import akka.javasdk.annotations.AgentDescription;
import akka.javasdk.annotations.Component;
import akka.javasdk.client.ComponentClient;
import java.util.List;
import java.util.Locale;
import java.util.stream.Collectors;

@Component(id = "evaluator-agent")
@AgentDescription(
@Component(
id = "evaluator-agent",
name = "Evaluator Agent",
description = """
An agent that acts as an LLM judge to evaluate the quality of AI responses.
Expand Down
5 changes: 2 additions & 3 deletions src/main/java/demo/multiagent/application/PlannerAgent.java
Original file line number Diff line number Diff line change
Expand Up @@ -3,15 +3,14 @@
import akka.javasdk.JsonSupport;
import akka.javasdk.agent.Agent;
import akka.javasdk.agent.AgentRegistry;
import akka.javasdk.annotations.AgentDescription;
import akka.javasdk.annotations.Component;
import demo.multiagent.domain.AgentSelection;
import demo.multiagent.domain.Plan;
import demo.multiagent.domain.PlanStep;
import java.util.List;

@Component(id = "planner-agent")
@AgentDescription(
@Component(
id = "planner-agent",
name = "Planner",
description = """
An agent that analyzes the user request and available agents to plan the tasks
Expand Down
5 changes: 2 additions & 3 deletions src/main/java/demo/multiagent/application/SelectorAgent.java
Original file line number Diff line number Diff line change
Expand Up @@ -3,12 +3,11 @@
import akka.javasdk.JsonSupport;
import akka.javasdk.agent.Agent;
import akka.javasdk.agent.AgentRegistry;
import akka.javasdk.annotations.AgentDescription;
import akka.javasdk.annotations.Component;
import demo.multiagent.domain.AgentSelection;

@Component(id = "selector-agent")
@AgentDescription(
@Component(
id = "selector-agent",
name = "Selector Agent",
description = """
An agent that analyses the user request and selects useful agents for
Expand Down
Original file line number Diff line number Diff line change
@@ -1,13 +1,12 @@
package demo.multiagent.application;

import akka.javasdk.agent.Agent;
import akka.javasdk.annotations.AgentDescription;
import akka.javasdk.annotations.Component;
import java.util.Collection;
import java.util.stream.Collectors;

@Component(id = "summarizer-agent")
@AgentDescription(
@Component(
id = "summarizer-agent",
name = "Summarizer",
description = "An agent that creates a summary from responses provided by other agents"
)
Expand Down
10 changes: 5 additions & 5 deletions src/main/java/demo/multiagent/application/WeatherAgent.java
Original file line number Diff line number Diff line change
@@ -1,22 +1,22 @@
package demo.multiagent.application;

import akka.javasdk.agent.Agent;
import akka.javasdk.annotations.AgentDescription;
import akka.javasdk.annotations.AgentRole;
import akka.javasdk.annotations.Component;
import akka.javasdk.annotations.FunctionTool;
import demo.multiagent.domain.AgentRequest;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;

@Component(id = "weather-agent")
@AgentDescription(
@Component(
id = "weather-agent",
name = "Weather Agent",
description = """
An agent that provides weather information. It can provide current weather,
forecasts, and other related information.
""",
role = "worker"
"""
)
@AgentRole("worker")
public class WeatherAgent extends Agent {


Expand Down
Loading