AMQP Sender

· #322 most-used

Publish messages to any AMQP broker from inside your agent workflows

DatabaseDeveloperAutomationCloud & InfrastructureMonitoring & Alerts

AMQP (Advanced Message Queuing Protocol) Sender lets your agents push messages directly into enterprise message brokers — RabbitMQ, Azure Service Bus, ActiveMQ, IBM MQ, and any other AMQP 0-9-1 or AMQP 1.0 compliant broker. Connect once with hostname, port, and credentials; then your agents can route payloads to named exchanges, queues, and routing keys with full control over message headers, priority, TTL, and content type. Use it to decouple processing pipelines, fan out events to multiple consumers, or bridge AI-generated outputs into backend systems that already rely on message queues.

Average time saved
3 hours
per person · per month
≈ 1 workdays back

Eliminates manual work. Agents eliminate the manual work of orchestrating sequential API calls across downstream systems, managing routing logic, and re-triggering failed event chains when individual API calls time out or return errors.

Schedule

What your AMQP Sender agent runs on autopilot

A week of scheduled jobs your Actionist agent will execute on your behalf.

28Scheduled jobs
7Agents at work
24/7Always on
Agents
TueThu
Tue
Wed
Thu
7a
8a
9a
10a
11a
12p
1p
2p
3p
4p
5p
6p
Multi-app workflows

AMQP Sender × every other app you use

End-to-end automations that span multiple apps — each one a real business outcome.

6Workflows
5Apps spanned
~54 hrsSaved / week
5Personas served
For developer
Featured4 apps

New order event queued the moment a sale completes

When a completed order lands in the e-commerce system, the Operations Agent reads the order details, serialises a structured JSON event, and publishes it to the 'orders.created' routing key on the AMQP broker. The fulfilment service, the inventory manager, and the analytics pipeline each consume from their own bound queue — all triggered from one message, with zero direct coupling between the storefront and the backend services.

~20 hrs

Time saved for your team — every week, on autopilot

The flow
Trigger·When a new order is confirmed in the e-commerce platform
Result
Publish JSON event to 'orders.created' on the events exchangeLog order ID, timestamp, and queue routing key to the order audit sheetPost order dispatch confirmation to the #ops-events Slack channel
The win
Saved per run
8 min
Runs / week
~150×
Zero manual handoffs between storefront and fulfilment
Driven byOperations Agent
ROI

Savings

What your team gets back — two angles: what you stop doing manually, and what that's worth.

Without Actionist

What you do manually today

With Actionist

What your agent runs for you

  • Sales
    45 min / week
    Manual API call chains for every deal event

    Reps trigger downstream CRM updates, proposal generation, and analytics logging by making sequential API calls — if any call fails, the chain breaks and data is silently lost.

    Sales Agent
    0 min
    Agent publishes deal events to broker; all consumers react automatically

    The Sales Agent publishes one AMQP message per deal event and moves on. CRM enrichment, proposal automation, and analytics each consume from the queue on their own schedule — zero failed-chain risk and no code change when a new consumer is added.

  • Marketing
    30 min / week
    Manual broadcast to each downstream system on campaign launch

    The marketing team notifies analytics, A/B testing, and attribution systems one by one when a campaign launches — missing a step means a system has stale data for the rest of the campaign.

    Marketing Agent
    0 min
    One fanout publish notifies every consumer within about a minute

    The Marketing Agent publishes a single campaign-launched event to the fanout exchange. Every bound consumer receives the message simultaneously — adding a new tool that needs the signal requires only a queue binding, no human coordination.

  • Customer Support
    20 min / week
    Ticket events trigger synchronous API calls to multiple systems

    Every ticket escalation or resolution triggers direct API calls to the ticketing system, SLA monitor, and knowledge-base indexer in sequence — one slow API drags the entire chain and blocks the support agent's response.

    Customer Support Agent
    0 min
    Ticket events queued; each system consumes at its own pace

    The Support Agent publishes one message per ticket event and moves on immediately. Each downstream system consumes from the queue independently — the support agent's task completes in seconds regardless of how long the SLA monitor or indexer takes.

  • Human Resources
    60 min / week
    HR manually routes onboarding events to each regional team

    When a new hire is confirmed, HR emails or messages each regional coordinator, IT provisioning team, and facilities manager separately — manual routing that takes 20–30 minutes per hire and misses steps when someone is out of office.

    Human Resources Agent
    0 min
    Topic exchange routes onboarding events to the correct regional processor

    The HR Agent publishes once with a regional routing key. The correct provisioning service, facilities team, and payroll processor each receive the event from the topic exchange within about a minute — zero manual routing, even as the company expands into new regions.

  • Finance
    50 min / week
    Payment events logged manually and API-called to downstream services

    Finance manually logs payment confirmations and triggers revenue recognition, accounting reconciliation, and commission payout by calling each service's API — a missed call or a temporary API outage creates reconciliation gaps that take hours to audit.

    Finance Agent
    0 min
    Persistent payment events queued; services process safely even after restarts

    The Finance Agent publishes persistent payment-confirmed messages to a durable queue. Revenue recognition and accounting reconciliation consume the queue — even if either service restarts mid-week, no payment event is lost and reconciliation is always complete.

  • Operations
    40 min / week
    Infrastructure alerts sent by direct API to each monitoring tool

    Operations alerts are dispatched by calling each monitoring tool's API in sequence — if the incident management API is slow, the on-call pager notification is delayed; adding a new tool requires a code change to the alert sender.

    Operations Agent
    0 min
    One fanout publish reaches every monitoring consumer simultaneously

    The Operations Agent publishes to the fanout exchange once. The incident management system, on-call pager, Slack alert channel, and SLA tracker all receive the alert within about a minute — adding a new consumer is a broker queue binding, not a code change.

  • Legal
    35 min / week
    Compliance events manually logged and emailed to downstream teams

    Legal logs compliance actions manually, emails the audit team, and calls the record-keeping system's API — no guaranteed delivery, no message trail, and a single missed step can create an audit gap that takes days to reconcile.

    Legal Agent
    0 min
    Persistent compliance events queued with correlation IDs for full audit trail

    The Legal Agent publishes each compliance action as a persistent AMQP message with a correlation ID. The audit service records every message — the message trail is the audit trail, complete and tamper-evident, without any manual logging step.

+ 100s of other AMQP Sender automations
Average time saved
28 hrs / person / month
Calculator

Calculate what your team saves

Team size
5 people
Hourly rate
$75 / hr
Hours saved / week
4
Hours saved / year
175
Annual ROI
$13,125

Based on AMQP Sender's typical team usage — the visible tasks plus a few other automations the agent runs: ~0.7 hrs / person / week of admin work automated.

Connect

How to plug AMQP Sender into Actionist

Pick the connection method that suits your environment.

Connect to any AMQP-compliant message broker using hostname, port, and username/password credentials. Works with RabbitMQ, Azure Service Bus, ActiveMQ, IBM MQ, CloudAMQP, and any other AMQP 0-9-1 or 1.0 broker.

1
Prepare your broker endpoint

Locate your AMQP broker's hostname and port. For a self-hosted RabbitMQ server use its hostname and port 5672 (or 5671 for TLS). For Azure Service Bus, the hostname is your-namespace.servicebus.windows.net on port 5671. For CloudAMQP copy the 'AMQP URL' from your instance dashboard and extract the host.

2
Create a dedicated user (recommended)

Avoid using the default admin account. In RabbitMQ Management UI, go to Admin → Users → Add User, create a user with the vhost permissions you need. In Azure Service Bus, create a Shared Access Policy with Send permissions and use the Policy name as the username and the Primary Key as the password.

3
Enter credentials in Actionist

In the Actionist Apps tab, find AMQP Sender and click Connect. Enter the hostname, port, username, and password. Actionist will attempt a test connection to verify the handshake before saving.

Credentials you'll need
Hostname*
The hostname or IP address of your AMQP broker (e.g. your-rabbitmq.example.com or rabbitmq.azure.com)
Port
Port to connect on. Default is 5672 (plain) or 5671 (TLS). Azure Service Bus uses 5671.
Username*
The AMQP user account. In RabbitMQ the default is 'guest' (not recommended for production).
Password*
Password for the AMQP user.
Actions

15 actions your agent can call

Read and write operations available to your Actionist agent.

Triggers

0 events your agent can react to

Events your agent watches for, and the actions it kicks off in response.

This app has no triggers yet.
Skills

Skills that pair with AMQP Sender

Reusable agent skills that work well alongside this app.

Mermaid Diagrams

Create software diagrams using Mermaid syntax. Use when users need to create, visualize, or document software through diagrams including class diagrams, sequence diagrams, flowcharts, ERDs, C4 architecture diagrams, state diagrams, git graphs, and other diagram types. Triggers include requests to diagram, visualize, model, map out, or show the flow of a system.

FAQs

Questions about AMQP Sender + Actionist

How does Actionist connect to my AMQP broker?
Actionist connects to your AMQP broker using a direct TCP connection authenticated with a hostname, port, username, and password. You enter these in the Apps tab when you connect AMQP Sender. Actionist supports both plain connections (port 5672) and TLS-encrypted connections (port 5671). No OAuth flow or API key is involved — AMQP uses native broker authentication. Works with any AMQP 0-9-1 or AMQP 1.0 compliant broker: RabbitMQ, Azure Service Bus, ActiveMQ, IBM MQ, CloudAMQP, and others.
What's the difference between publishing to an exchange versus publishing directly to a queue?
When you publish to an exchange, the broker routes the message to one or more queues based on the exchange type and routing key — a direct exchange routes by exact key match, a topic exchange supports wildcard patterns, and a fanout exchange broadcasts to every bound queue. Publishing directly to a queue (using the default exchange) is a point-to-point pattern: one publisher, one queue, no routing logic. For most real-world architectures, publishing to a named exchange is preferred because it decouples the sender from the list of consumers. Direct-to-queue is useful for simple worker patterns where exactly one consumer type handles every message.
Does AMQP Sender support persistent messages that survive a broker restart?
Yes. When you use the Send Persistent Message action, Actionist sets the AMQP delivery-mode property to 2 (persistent). The broker writes the message to disk before acknowledging it, so the message survives a restart — provided the queue itself was declared as durable. Both the message persistence flag and the queue durability flag must be set for true crash-safety. Non-persistent messages (delivery-mode=1) live only in memory and are lost if the broker process restarts before the consumer acknowledges them.
Can I use AMQP Sender with RabbitMQ Cloud (CloudAMQP)?
Yes. CloudAMQP is one of the most common managed RabbitMQ services and works with Actionist's AMQP Sender out of the box. Find your instance in the CloudAMQP dashboard, copy the AMQP URL (format: amqp://user:password@host/vhost), and extract the individual components — host, port (usually 5672 or 5671 for TLS), username, and password — to enter in the Actionist connection form. CloudAMQP's free Lemur plan supports one broker instance with limited concurrency; paid plans remove those restrictions.
How do I send messages to Azure Service Bus using AMQP Sender?
Azure Service Bus supports the AMQP 1.0 protocol natively. To connect: in the Azure portal, navigate to your Service Bus namespace, go to Shared Access Policies, and create (or select) a policy with Send permissions. Use the namespace hostname (your-namespace.servicebus.windows.net) as the host, port 5671 (TLS is mandatory for Azure), the policy name as the username, and the Primary Key as the password. Messages published to your Service Bus queue or topic will be delivered within about a minute of publishing.
What happens to my messages if the AMQP broker is temporarily unavailable?
If the broker is unreachable when the agent tries to publish, the send action will fail and the agent task will be retried according to Actionist's task retry policy. Messages are not buffered client-side — AMQP Sender requires a live connection to publish. To protect against broker downtime, use a highly-available broker setup (RabbitMQ clustering, mirrored queues, or a managed service with built-in HA like Azure Service Bus or CloudAMQP). For messages that must not be lost, combine broker HA with the Send Persistent Message action so that once a message is accepted by the broker it is durable.
Can my Actionist agents also consume (read) messages from AMQP queues, or only send them?
AMQP Sender is a write-only integration — it publishes messages but does not consume them. If you need to trigger an agent workflow when a message arrives on a queue, that requires an AMQP Trigger (a separate integration that polls or subscribes to a queue and fires an agent task when a message is received). The two integrations complement each other: AMQP Sender dispatches work out to your backend systems; AMQP Trigger brings messages back in to start agent workflows.
How large can the message payload be when using AMQP Sender?
AMQP itself does not impose a fixed message size limit at the protocol level, but your broker has practical limits. RabbitMQ's default maximum frame size is 128 MB; CloudAMQP's Lemur plan limits messages to 128 KB. Azure Service Bus limits standard-tier messages to 256 KB and premium-tier to 100 MB. For large payloads — files, binary blobs, large JSON documents — the recommended pattern is to store the data in object storage (e.g. a Google Drive file or Vercel Blob URL) and publish a small reference message containing the URL and metadata to the AMQP queue. Consumers fetch the data from storage, keeping queue messages compact and broker memory usage low.