Messaging & Streaming
Messaging & Streaming integrations for AI agents
Streaming, queueing, and pub/sub platforms for moving events between systems.
Messaging and streaming systems are how agents participate in event-driven architectures — consuming events that trigger runs and publishing results other systems react to. An agent subscribed to a queue becomes a worker in your existing pipeline, with the difference that its policy decides which topics it may publish to and its every message is audited.
Integration
ActiveMQ
ActiveMQ integration for queues, topics, message send/browse, connections, and broker info
Read more
Integration
Amazon SQS
Amazon SQS integration for queues, send/receive messages, queue attributes, and dead-letter queues
Read more
Integration
Apache Kafka
Apache Kafka integration for topics, consumer groups, produce/consume messages, brokers, and cluster info
Read more
Integration
Azure Service Bus
Azure Service Bus integration for queues, topics, subscriptions, send/receive messages, and peek
Read more
Integration
Google Pub/Sub
Google Pub/Sub integration for topics, subscriptions, publish/pull messages, acknowledgments, and snapshots
Read more
Integration
RabbitMQ
RabbitMQ integration for queues, exchanges, bindings, message publish/consume, connections, and vhosts
Read more
What agents do with messaging & streaming tools
- Event-triggered agents that run when a message lands on a queue
- Publishing agent results downstream without custom glue code
- Fan-out processing where each event becomes an isolated agent run
- Bridging legacy systems to agents through existing message brokers