3. Discover & invoke

curl "http://localhost:9090/agents?skill_tags=research"

import asyncio

import httpx

KUBEMQ_URL = "http://localhost:9090"


async def main() -> None:
    async with httpx.AsyncClient() as client:
        resp = await client.get(
            f"{KUBEMQ_URL}/agents",
            params={"skill_tags": "research"},
        )
        agents = resp.json()
        for agent in agents:
            skills = [s["id"] for s in agent.get("skills", [])]
            print(f"  {agent['agent_id']}: skills={skills}, url={agent['url']}")


if __name__ == "__main__":
    asyncio.run(main())

curl -X POST http://localhost:9090/a2a/research-agent-01 \
  -H "Content-Type: application/json" \
  -d '{
    "jsonrpc": "2.0",
    "id": 1,
    "method": "message/send",
    "params": {
      "message": {
        "parts": [{"text": "Summarize the history of message queues"}]
      }
    }
  }'

import asyncio
import json

import httpx

KUBEMQ_URL = "http://localhost:9090"
AGENT_ID = "research-agent-01"


async def main() -> None:
    payload = {
        "jsonrpc": "2.0",
        "id": 1,
        "method": "message/send",
        "params": {
            "message": {
                "parts": [{"text": "Summarize the history of message queues"}],
            },
        },
    }

    async with httpx.AsyncClient() as client:
        resp = await client.post(f"{KUBEMQ_URL}/a2a/{AGENT_ID}", json=payload)
        data = resp.json()
        print(json.dumps(data, indent=2))

        if "error" in data:
            print(f"\nAgent returned an error: {data['error']['message']}")
        else:
            print("\nGot a synchronous result from the agent.")


if __name__ == "__main__":
    asyncio.run(main())