messaging/index

Overview

Module

• package: org.eclipse.dirigible.sdk.messaging
• source: messaging/

This module is the platform messaging surface of the Eclipse Dirigible Java SDK. It exposes the embedded ActiveMQ broker that ships with every Dirigible runtime, letting Java code publish to and consume from JMS-style queues (point-to-point) and topics (publish/subscribe) without any client-side broker plumbing.

Two consumption styles are supported. For long-running, always-on listeners the platform manages the consumer thread, reconnects, and dispatch — a class is marked with @Listener, exposes a public onMessage(String) method, and the runtime wires it up at startup and on hot-reload. For script-style or pull-based code that processes a single message and exits, the Consumer facade offers a blocking receiveFromQueue / receiveFromTopic with a millisecond timeout. Every component running on the platform — in any language — targets the same broker, so producers and listeners interoperate transparently regardless of where the message originates.

The main components of this module are:

• Producer — sends a message to a queue or topic on the embedded ActiveMQ broker.
• Consumer — synchronously pulls a single message from a queue or topic with a millisecond timeout.
• Decorators — annotation set used to declare always-on listeners:
  • @Listener — marks a class as an ActiveMQ message listener
  • ListenerKind — enum selecting QUEUE or TOPIC semantics for the annotated listener

Classes