Which integrations are available for this server?

Provides tools for managing Apache ActiveMQ message broker setup, including validating broker connectivity, scaffolding Ballerina projects, adding queues/topics, configuring acknowledgement modes, and building/deploying projects within a WSO2 Integrator workspace.

How do I use ballerina-activemq-mcp-server?

1. Click on "Deploy Server". 2. Wait a few minutes for the server to deploy. Once ready, it will show a "Started" state. 3. In the chat, type @ followed by the MCP server name and your instructions, e.g., "@ballerina-activemq-mcp-server scaffold a new Ballerina ActiveMQ project" That's it! The server will respond to your query, and you can continue using it as needed. Here is a step-by-step guide with screenshots.

ballerina-activemq-mcp-server

by PasinduGunarathne

Overview Schema Source Related Servers Discussions Admin

TypeScript

Local

ballerina-activemq-mcp-server

An MCP server that automates the full setup and deployment of Ballerina + Apache ActiveMQ (OpenWire/JMS) integrations inside a WSO2 Integrator (BI) workspace — from broker validation to a runnable, BI-low-code-ready project — with minimal user interaction.

It generates code against the ballerinax/activemq connector (v0.1.0, Ballerina 2201.12.10), matching the real connector API (Client / Listener / Caller / Transaction). See INSPECTION_NOTES.md for the Phase 0 API inspection this is built on.

Tools

Tool	Purpose
`mq_validate_broker`	TCP reachability to the OpenWire port (+ Jolokia console destination listing).
`mq_scaffold_project`	Main tool. Generate a complete BI-ready Ballerina project.
`mq_write_config_toml`	Write/rotate the broker `Config.toml`.
`mq_add_queue`	Add a queue producer/consumer helper module.
`mq_add_topic`	Add a topic (pub/sub) publisher helper module.
`mq_add_listener`	Add a Listener service — the polling-loop carrier — with ack-mode/transaction options.
`mq_set_ack_mode`	Change the acknowledgement mode on a listener service (edits the `@activemq:ServiceConfig`).
`mq_build_project`	Run `bal build`.
`mq_deploy_project`	Run `bal run`; returns PID (+ service URL).

Acknowledgement modes

`ack_mode`	Ballerina enum	Needs `Caller`?	Semantics
`auto` (default)	`AUTO_ACKNOWLEDGE`	no	auto-ack on successful `onMessage` return
`client`	`CLIENT_ACKNOWLEDGE`	yes	`caller->acknowledge(message)`
`dups-ok`	`DUPS_OK_ACKNOWLEDGE`	no	lazy ack, possible duplicates
`transacted`	`SESSION_TRANSACTED`	yes	`caller->'commit()` / `'rollback()`

The ack mode is a compile-time annotation field, so it lives in listener.bal (not Config.toml). mq_set_ack_mode edits the source accordingly.

Related MCP server: wso2-bi-salesforce-mcp-server

Build

npm install
npm run build

Run

# stdio (default — for MCP clients that spawn the server)
npm start

# streamable HTTP, bound to 127.0.0.1
npm run start:http            # or: node dist/index.js --http --port 3000

Register with an MCP client (stdio)

{
  "mcpServers": {
    "ballerina-activemq": {
      "command": "node",
      "args": ["/absolute/path/to/ballerina-activemq-mcp-server/dist/index.js"]
    }
  }
}

What gets scaffolded

mq_scaffold_project writes a complete project under <bi_path>/<project_name>/:

Ballerina.toml · Dependencies.toml · Config.toml (+ .example, gitignored) · .gitignore
main.bal · listener.bal · transactions.bal · modules/<dest>/<dest>.bal
docker-compose.yml (apache/activemq-classic:6.2.0) · README.md

main.bal — configurable broker settings + activemq:Client producer/consumer demo.
listener.bal — the polling-loop carrier: a declarative service activemq:Service on mqListener per destination, ack mode baked into @activemq:ServiceConfig.
Virtual topics — publish to topic://VirtualTopic.<name>; consume the queue Consumer.<group>.VirtualTopic.<name>.

Design notes

This is JMS/OpenWire, not Kafka. Consumer groups, offset commits, partitions, and bootstrap.servers have no analog here and are intentionally absent — reliability comes from ack modes and transacted sessions. The closest thing to a consumer group is an ActiveMQ Virtual Topic, modeled as a queue naming convention. See INSPECTION_NOTES.md for the full rejected-Kafka-patterns rationale.

License

Apache-2.0

Available Tools

9 tools

mq_add_listenerAdd Listener serviceA

Add a message Listener service — the polling-loop carrier — to listener.bal. Generates a declarative service activemq:Service on mqListener with the correct @activemq:ServiceConfig (queueName/topicName, sessionAckMode, pollingInterval, receiveTimeout) and an onMessage that carries an activemq:Caller for client/transacted ack modes (with acknowledge or commit/rollback). Supports queue, topic (optionally durable), and virtual-topic (consumer_group) destinations. If transacted=true conflicts with ack_mode, transacted wins (SESSION_TRANSACTED) with a warning. Creates listener.bal if absent; otherwise appends the service (or replaces the file if overwrite=true).

Inputs: org_name (required), destination (required), project_name (required), project_path (required), +7 more.

mq_add_queueAdd queue moduleA

Add a queue helper module to an existing project: creates modules//.bal with send() and receive() functions wired to the JMS queue (point-to-point). The producer sends with Client.sendMessage(queueName, ..) and receives synchronously with Client.receiveMessage(queueName, timeout). Does not overwrite unless overwrite=true.

Inputs: org_name (required), queue_name (required), project_name (required), project_path (required), +1 more.

mq_add_topicAdd topic moduleA

Add a topic (pub/sub) helper module to an existing project: creates modules//.bal with a publish() function that sends to "topic://". Subscribers are created as Listener services (use mq_add_listener with type=topic, optionally durable=true + subscriber_name). Does not overwrite unless overwrite=true.

Inputs: org_name (required), topic_name (required), project_name (required), project_path (required), +3 more.

mq_build_projectBuild Ballerina projectA

Idempotent

Run bal build in a scaffolded project and report success or the compiler diagnostics. Verifies the Ballerina toolchain is installed first (bal version). Use offline=true to build against locally cached dependencies only. Does not modify source files.

Inputs: project_path (required), offline, timeout_ms.

mq_deploy_projectDeploy (run) Ballerina projectA

Run bal run for a scaffolded project as a detached background process and return its PID. Watches the process for wait_ms to catch an early crash (and report the output) before declaring it started. If service_port is given, also returns a composed service URL. The process keeps running after this call returns. Verifies the Ballerina toolchain first.

Inputs: project_path (required), wait_ms, service_port.

mq_scaffold_projectScaffold ActiveMQ BI projectA

MAIN tool. Generate a complete, runnable WSO2 Integrator (BI) Ballerina project that integrates with ActiveMQ via the ballerinax/activemq connector. Creates Ballerina.toml (with the connector pinned from the local repository), Config.toml (+ .example, gitignored), .gitignore, main.bal (producer/consumer client demo), listener.bal (the polling-loop carrier with one declarative service activemq:Service on mqListener per destination) when include_listener is set, transactions.bal when transacted is set, a modules// helper per destination, a docker-compose.yml (apache/activemq-classic), and a README. Acknowledgement mode is baked into the listener's @activemq:ServiceConfig. If transacted=true conflicts with ack_mode, transacted wins (SESSION_TRANSACTED) and a warning is returned. Writes files to disk.

Inputs: bi_path (required), org_name (required), destinations (required), project_name (required), +7 more.

mq_set_ack_modeSet acknowledgement modeA

DestructiveIdempotent

Set/update the acknowledgement mode on listener service(s) by editing listener.bal in place. Rewrites sessionAckMode in the @activemq:ServiceConfig annotation and regenerates the affected onMessage to match (adds/removes the activemq:Caller parameter and the acknowledge / commit+rollback calls). Targets one service by service_name, or all services when omitted. Ack mode cannot live in Config.toml (it is a compile-time constant), which is why this edits source. Modifies a .bal file.

Inputs: ack_mode (required), project_path (required), service_name, listener_file.

mq_validate_brokerValidate ActiveMQ brokerA

Read-onlyIdempotent

Check that an ActiveMQ broker is reachable at the given OpenWire URL. Performs a TCP connectivity probe to each endpoint (handles tcp://, ssl://, and failover:(...) forms). When list_destinations is true, also queries the ActiveMQ web-console Jolokia REST agent (default port 8161) to list current queues and topics, degrading gracefully to a TCP-only result if the console is unreachable. Read-only; makes no changes.

Inputs: password, username, broker_url, timeout_ms, +2 more.

mq_write_config_tomlWrite broker Config.tomlA

DestructiveIdempotent

Write or rotate the broker connection Config.toml for an existing project. Sets the [org.project] table with brokerUrl and (optionally) username/password. Note: the acknowledgement mode and transacted flag live in listener.bal (compile-time annotation), so ack_mode/transacted here are written only as documented mirror comments. Overwrites the existing Config.toml.

Inputs: org_name (required), project_name (required), project_path (required), ack_mode, +4 more.

Tool Schema Changelog

Recent tool additions, removals, and schema changes observed during successful MCP inspections.

Loading tool schema changelog…

Deploy Server

Claude Code, inside the Godot 4 editorFlockbay puts an AI agent in the real Godot 4 editor: it writes GDScript, runs your game and fixes what breaks. Free, or bring your own Claude Code or Codex.flockbay.comAd

TDQS

A4.4/5.0

Scored 2026-08-01 19:10 across 9 tools

Disambiguation5/5

Each tool targets a distinct lifecycle stage or resource type: broker validation, project scaffolding, config writing, queue/topic/listener additions, ack mode editing, build, and deploy. The only similar pair (add_queue vs add_topic) is clearly differentiated by destination type (point-to-point vs pub/sub).

Naming Consistency5/5

All tool names follow the consistent 'mq_verb_noun' pattern with snake_case throughout. Examples include mq_validate_broker, mq_scaffold_project, mq_add_queue, mq_set_ack_mode, and mq_build_project. This uniform convention makes tool discovery and selection highly predictable.

Tool Count5/5

With 9 tools, the server is well-scoped for its purpose of managing an ActiveMQ Ballerina project lifecycle. The count is neither minimal (which would be vague) nor overwhelming, and each tool serves a clear, necessary function from validation through deployment.

Completeness4/5

The toolset covers the core lifecycle well: validate, scaffold, add components, configure, build, and deploy. Minor gaps exist such as the lack of a remove/teardown tool or a direct JMS message roundtrip test, but these are not critical for the primary scaffolding workflow and can be worked around via the generated code.

Maintenance

ActivityInactive

ResponsivenessNo recent community issues

Resources

Related MCP Connectors

EchoRelayA
dev.echorelay
A managed runtime for custom API integrations. Manage lines, endpoints, keys, logs and DLQ via MCP.
Communication Observability Developer Tools
802
https://mcp.echorelay.dev
rabbitmq-elasticsearch-mysql-stack-generator
ai.getvda
RabbitMQ + Elasticsearch + MySQL Stack Generator
Developer Tools Data Platforms
1
https://rabbitmq-elasticsearch-mysql-stack-generator.getvda.ai/mcp
rabbitmq-postgres-mongodb-stack-generator
ai.getvda
RabbitMQ + Postgres + MongoDB Stack Generator
Developer Tools Data Platforms
1
https://rabbitmq-postgres-mongodb-stack-generator.getvda.ai/mcp
Air PipeB
io.airpipe
Build, validate, deploy — HTTP APIs, cron jobs, webhooks and MCP tools — from your AI client.
Developer Tools CI/CD & DevOps App Automation
191
https://api.airpipe.io/mcp

Related MCP Servers

artemis-mcp-server
Communication Monitoring
k-krawczyk
A
license
A
quality
C
maintenance
An MCP server that lets an AI agent work with an ActiveMQ Artemis broker.
Updated 2 months ago (2026-09-13 03:52 UTC)
8
11 npm
1
MIT
wso2-bi-salesforce-mcp-server
CRM Developer Tools CI/CD & DevOps
PasinduGunarathne
F
license
A
quality
D
maintenance
Enables AI assistants to set up, run, and manage Ballerina + Salesforce integrations inside a WSO2 Integrator workspace, providing 18 tools for OAuth2 token acquisition, project scaffolding, building, deploying, and stopping the integration service.
Updated 5 months ago (2026-06-22 08:34 UTC)
18
-
MCP_INIT_MS_SegurosBolivar
Developer Tools CI/CD & DevOps
JohanMasmelaEu
F
license
Not graded
quality
D
maintenance
Automates the initialization of Java 21/Spring Boot microservices with Docker Compose, generating complete project archetypes for Seguros Bolivar.
Updated 4 months ago (2026-07-24 20:04 UTC)
-
ActiveMQ MCP Server
Developer Tools Monitoring
mradovic95
A
license
C
quality
D
maintenance
Enables AI assistants to manage ActiveMQ message brokers through MCP tools, supporting queue and topic operations, dynamic connection management, message browsing, and health monitoring.
Updated a year ago (2025-10-01 13:09 UTC)
22
18 npm
1
MIT

ballerina-activemq-mcp-server

Tools

Acknowledgement modes

Build

Run

Register with an MCP client (stdio)

What gets scaffolded

Design notes

License

Available Tools

Tool Schema Changelog

TDQS

Maintenance

Resources

Related MCP Connectors

Related MCP Servers

artemis-mcp-server

wso2-bi-salesforce-mcp-server

MCP_INIT_MS_SegurosBolivar

ActiveMQ MCP Server