🚀 Building Your First AMCP Agent - Step-by-Step Tutorial

package org.example;

import io.quarkus.runtime.QuarkusApplication;
import io.quarkus.runtime.annotations.QuarkusMain;
import org.amcp.agent.Agent;
import org.amcp.agent.AgentContext;
import org.amcp.agent.Message;
import org.amcp.llm.LLMService;
import org.amcp.llm.ChatConfig;
import jakarta.inject.Inject;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;

/**
 * My First AMCP Agent
 * 
 * This is a simple greeting agent that:
 * 1. Listens for messages on a Kafka topic
 * 2. Processes the message with LLM (optional)
 * 3. Generates a response
 * 4. Publishes the response
 */
@QuarkusMain
public class MyFirstAgent extends Agent implements QuarkusApplication {
    
    @Inject
    LLMService llmService;
    
    @Override
    public void initialize(AgentContext context) {
        System.out.println("🤖 Initializing My First Agent...");
        
        // Set agent metadata
        this.setAgentName("my-first-agent");
        this.setVersion("1.0.0");
        
        // Subscribe to incoming messages
        context.subscribe("greetings", this::handleGreeting);
        context.subscribe("questions", this::handleQuestion);
        
        System.out.println("✅ Agent initialized successfully!");
    }
    
    /**
     * Handle greeting messages
     */
    private void handleGreeting(Message message) {
        String userGreeting = message.getPayload();
        
        System.out.println("📨 Received greeting: " + userGreeting);
        
        // Generate response
        String response = generateGreetingResponse(userGreeting);
        
        System.out.println("📤 Sending response: " + response);
        
        // Publish response
        this.publish("greeting-responses", response);
    }
    
    /**
     * Handle question messages with LLM
     */
    private void handleQuestion(Message message) {
        String question = message.getPayload();
        
        System.out.println("❓ Received question: " + question);
        
        try {
            // Use LLM to answer question
            String answer = llmService.chat(
                question,
                new ChatConfig()
                    .model("llama2-7b")
                    .temperature(0.7)
                    .maxTokens(500)
            );
            
            System.out.println("💡 Generated answer: " + answer);
            
            // Publish answer
            this.publish("question-answers", answer);
            
        } catch (Exception e) {
            System.err.println("⚠️ Error processing question: " + e.getMessage());
            this.publish("question-answers", "Sorry, I couldn't process your question.");
        }
    }
    
    /**
     * Generate greeting response
     */
    private String generateGreetingResponse(String greeting) {
        String timestamp = LocalDateTime.now()
            .format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
        
        return String.format(
            "Hello! You said: '%s' at %s. Welcome to AMCP!",
            greeting,
            timestamp
        );
    }
    
    @Override
    public int run(String... args) throws Exception {
        System.out.println("🚀 Starting My First Agent...");
        
        // Agent will run indefinitely
        Thread.currentThread().join();
        
        return 0;
    }
}

package org.example;

import jakarta.inject.Inject;
import jakarta.ws.rs.*;
import jakarta.ws.rs.core.MediaType;
import jakarta.ws.rs.core.Response;
import org.amcp.agent.AgentContext;

@Path("/api")
@Produces(MediaType.APPLICATION_JSON)
@Consumes(MediaType.APPLICATION_JSON)
public class GreetingResource {
    
    @Inject
    AgentContext agentContext;
    
    @POST
    @Path("/greet")
    public Response greet(String message) {
        try {
            // Publish message to agent
            agentContext.publish("greetings", message);
            
            return Response.ok()
                .entity(new Response("Message sent to agent"))
                .build();
        } catch (Exception e) {
            return Response.serverError()
                .entity(new ErrorResponse(e.getMessage()))
                .build();
        }
    }
    
    @POST
    @Path("/ask")
    public Response ask(String question) {
        try {
            // Publish question to agent
            agentContext.publish("questions", question);
            
            return Response.ok()
                .entity(new Response("Question sent to agent"))
                .build();
        } catch (Exception e) {
            return Response.serverError()
                .entity(new ErrorResponse(e.getMessage()))
                .build();
        }
    }
    
    @GET
    @Path("/health")
    public Response health() {
        return Response.ok()
            .entity(new HealthResponse("Agent is running", "healthy"))
            .build();
    }
    
    // Response classes
    public static class Response {
        public String message;
        
        public Response(String message) {
            this.message = message;
        }
    }
    
    public static class ErrorResponse {
        public String error;
        
        public ErrorResponse(String error) {
            this.error = error;
        }
    }
    
    public static class HealthResponse {
        public String status;
        public String health;
        
        public HealthResponse(String status, String health) {
            this.status = status;
            this.health = health;
        }
    }
}

package org.example;

import io.quarkus.test.junit.QuarkusTest;
import jakarta.inject.Inject;
import org.amcp.agent.Message;
import org.junit.jupiter.api.Test;

import static org.junit.jupiter.api.Assertions.*;

@QuarkusTest
public class MyFirstAgentTest {
    
    @Inject
    MyFirstAgent agent;
    
    @Test
    public void testAgentInitialization() {
        assertNotNull(agent);
        assertEquals("my-first-agent", agent.getAgentName());
    }
    
    @Test
    public void testGreetingHandling() {
        Message greeting = new Message("Hello, Agent!");
        
        // This would be called by the agent
        agent.handleGreeting(greeting);
        
        // Verify response was generated
        assertNotNull(greeting);
    }
    
    @Test
    public void testAgentVersion() {
        assertEquals("1.0.0", agent.getVersion());
    }
}