Skip to content

spring-boot.md

Latest commit

 

History

History
149 lines (109 loc) · 4.43 KB

spring-boot.md

File metadata and controls

149 lines (109 loc) · 4.43 KB
Raw

Spring Boot

The conductor-client-ai-spring module provides Spring Boot auto-configuration. Add it and your AgentRuntime is wired automatically from application.properties.

Dependency

Gradle

implementation 'org.conductoross:conductor-client-ai-spring:<VERSION>'

Maven

<dependency>
    <groupId>org.conductoross</groupId>
    <artifactId>conductor-client-ai-spring</artifactId>
    <version>&lt;VERSION&gt;</version>
</dependency>

Replace <VERSION> with a published version from Maven Central.

This pulls in both conductor-client-ai and conductor-client-spring (which wires the ApiClient).

Configuration

# application.properties

# Conductor server — from conductor-client-spring
conductor.root-uri=http://localhost:8080/api
conductor.security.client.key-id=your-key      # optional
conductor.security.client.secret=your-secret   # optional

# Conductor agent worker tuning
conductor.agent.worker-poll-interval-ms=100
conductor.agent.worker-thread-count=1

Inject and use

import org.conductoross.conductor.ai.AgentRuntime;
import org.conductoross.conductor.ai.Agent;
import org.springframework.stereotype.Service;

@Service
public class ChatService {

    private final AgentRuntime runtime;

    public ChatService(AgentRuntime runtime) {
        this.runtime = runtime;
    }

    public String answer(String question) {
        Agent agent = Agent.builder()
            .name("assistant")
            .model("anthropic/claude-sonnet-4-6")
            .instructions("You are a helpful assistant.")
            .build();

        return runtime.run(agent, question).getOutput();
    }
}

Declare agents on beans with @AgentDef

Any Spring bean can declare agents with @AgentDef methods. The auto-configured AgentCatalog collects them from every bean in the context:

import org.conductoross.conductor.ai.annotations.AgentDef;
import org.conductoross.conductor.ai.annotations.Tool;
import org.conductoross.conductor.ai.spring.AgentCatalog;

@Component
public class SupportCrew {

    @Tool(description = "Look up an order by id")
    public String lookupOrder(String orderId) { ... }

    @AgentDef(model = "openai/gpt-4o")          // lookupOrder attaches automatically
    public String support() {
        return "You handle support tickets.";
    }
}

@Service
public class TicketService {
    private final AgentRuntime runtime;
    private final AgentCatalog agents;

    public TicketService(AgentRuntime runtime, AgentCatalog agents) {
        this.runtime = runtime;
        this.agents = agents;
    }

    public String answer(String ticket) {
        return runtime.run(agents.get("support"), ticket).getOutput().toString();
    }
}

The catalog scans lazily on first access; only beans whose class declares @AgentDef methods are touched. Duplicate agent names across beans fail fast with both bean names in the error. Proxied beans (e.g. @Transactional) work — discovery looks through the proxy subclass to the annotated declaration, and invocation goes through the proxy.

Beans provided

Bean type Bean name Condition
ApiClient orkesConductorClient From conductor-client-spring; @ConditionalOnMissingBean
AgentConfig conductorAgentConfig From conductor.agent.* properties; @ConditionalOnMissingBean
AgentRuntime agentRuntime Wires ApiClient + AgentConfig; @ConditionalOnMissingBean
AgentCatalog agentCatalog Collects @AgentDef agents from all beans; @ConditionalOnMissingBean

All beans are @ConditionalOnMissingBean — declare your own to override any of them.

Override the ApiClient

To connect to multiple servers or use custom TLS:

@Configuration
public class MyConductorAgentConfig {

    @Bean
    public ApiClient conductorAgentClient() {
        return ApiClient.builder()
                .basePath("http://myserver:8080/api")
                .credentials("key", "secret")
                .build();
    }
}

Override AgentConfig

@Bean
public AgentConfig conductorAgentConfig() {
    return new AgentConfig(500, 4);   // 500ms poll, 4 worker threads
}

Graceful shutdown

AgentRuntime is AutoCloseable. Spring calls close() on context shutdown automatically when it is a Spring-managed bean — worker threads stop and HTTP connections are released cleanly.