☁️ @saptools/cf-event-mesh

Listen to or publish messages directly to SAP BTP Event Mesh from your terminal.

Easily interact with AMQP queues or publish REST payloads to queues and topics without needing an external client like Postman or Advanced Event Mesh configurations.

Install • Quick Start • CLI • FAQ

✨ Features

• 🎧 AMQP Listener — stream live messages from an Event Mesh queue directly into your console
• 📤 REST Publisher — instantly publish JSON payloads to a queue or a topic
• 🔐 Auto-Discovery — seamlessly fetches credentials (clientid, clientsecret, tokens) via cf env
• 🛡️ Safe by Default — listening doesn't acknowledge messages by default, ensuring no data loss while debugging
• 🧩 Zero Config — just provide the app name bound to enterprise-messaging
• 🪶 Lightweight — no heavy dependencies, relies on Cloud Foundry CLI

📦 Install

# Global CLI
npm install -g @saptools/cf-event-mesh

# Or as a dependency
npm install @saptools/cf-event-mesh
# pnpm add @saptools/cf-event-mesh
# yarn add @saptools/cf-event-mesh

[!NOTE] Requires Node.js ≥ 20 and the official cf CLI on PATH (v8 recommended).

🚀 Quick Start

# 1. Make sure you are logged into Cloud Foundry and targeting a space
cf target -o my-org -s dev

# 2. Listen to a queue (messages are not acknowledged by default)
cf-event-mesh listen my-app-srv "namespace/queue-name"

# 3. Publish a message to a topic
cf-event-mesh publish my-app-srv topic "namespace/topic-name" '{"hello":"world"}'

🧰 CLI

🎧 cf-event-mesh listen

Connects to the Event Mesh queue via AMQP and streams incoming messages to the console.

cf-event-mesh listen <app-name> <queue-name>
cf-event-mesh listen <app-name> <queue-name> --ack

| Flag | Description | | --- | --- | | --ack | Acknowledge (delete) messages from the queue as they are received. Warning: this consumes the message permanently. |

📤 cf-event-mesh publish

Publishes a string payload to a specified queue or topic using the REST HTTP endpoint.

cf-event-mesh publish <app-name> queue <queue-name> '<payload>'
cf-event-mesh publish <app-name> topic <topic-name> '<payload>'

Example:

cf-event-mesh publish orders-srv topic "sap/s4/beh/salesorder/v1/SalesOrder/Created/v1" '{"SalesOrder":"10000001"}'

❓ FAQ

No. This package is specifically built for the default SAP Event Mesh (enterprise-messaging service plan default).

By default, the listen command connects with autoAck: false so that you can debug and monitor messages without stealing them from your actual application consumers. If you want to consume and remove them, pass the --ack flag.

It runs cf curl /v3/apps/<guid>/env to extract the enterprise-messaging service binding credentials, including the AMQP WebSocket URL, REST URL, and OAuth2 Client Credentials.

🛠️ Development

From the monorepo root:

pnpm install
pnpm --filter @saptools/cf-event-mesh build
pnpm --filter @saptools/cf-event-mesh typecheck
pnpm --filter @saptools/cf-event-mesh test:unit

🌐 Related

• 🔐 @saptools/cf-xsuaa — fetch XSUAA credentials and cached OAuth2 tokens for any CF app
• 🔄 @saptools/cf-sync — map your SAP BTP Cloud Foundry topology
• 🗂️ saptools monorepo — the full toolbox

👨‍💻 Author

dongtran ✨

📄 License

MIT

Made with ❤️ to make your work life easier!