Habari STOMP Client for RabbitMQ is a high-level, object-oriented STOMP client library for Delphi and Free Pascal which provides access to the RabbitMQ free open source message broker.

The STOMP specification does not prescribe what kinds of destinations a broker must support, instead the value of the destination header in SEND and MESSAGE frames is broker-specific. The RabbitMQ STOMP adapter supports a number of different destination types:

• /exchange - SEND to arbitrary routing keys and SUBSCRIBE to arbitrary binding patterns
• /queue - SEND and SUBSCRIBE to queues managed by the STOMP gateway
• /amq/queue - SEND and SUBSCRIBE to queues created outside the STOMP gateway
• /topic - SEND and SUBSCRIBE to transient and durable topics
• /temp-queue/ - create temporary queues (in reply-to headers only)

All destination types may be used with Habari STOMP Client for RabbitMQ. For details, see API documentation at IMQContext (for the simplified API) or ISession.html (for the classic API).

Habari STOMP Client libraries support broker-specific extensions of the STOMP specification. Most of them can be accessed with the same client side code across all broker versions.

Released 20 Juni 2025

Code Examples

"Hello, World!" - Send to message broker

code

Connects to a message broker instance with default port and credentials, and sends a text message.

strict private
  Factory: IConnectionFactory
...
  Factory := TBTConnectionFactory.Create('stomp://example.com');
...

procedure TExampleClient.SendHelloWorld;
var
  Ctx: IMQContext;
  Destination: IDestination;
begin
  Ctx := Factory.CreateContext;
  try
    Destination := Ctx.CreateQueue('hello_world');
    Ctx.CreateProducer.Send(Destination, 'Hello, World!');
  finally
    Ctx.Close;
  end;
end;

"Hello, World!" - Receive from message broker

code

Connects to a message broker instance with default port and credentials, and receives a text message.

strict private
  Factory: IConnectionFactory
...
  Factory := TBTConnectionFactory.Create('stomp://example.com');
...

procedure TExampleClient.ReceiveHelloWorld;
var
  Ctx: IMQContext;
  Destination: IDestination;
  Consumer: IMQConsumer;
  TextMessage: ITextMessage;
begin
  Ctx := Factory.CreateContext;
  try
    Destination := Ctx.CreateQueue('hello_world');
    Consumer := Ctx.CreateConsumer(Destination);
    TextMessage := Consumer.Receive(2500) as ITextMessage;
    if Assigned(TextMessage) then 
      ShowMessage(TextMessage.Text);
  finally
    Ctx.Close;
  end;
end;

About the RabbitMQ free open source message broker

RabbitMQ is a reliable and mature messaging and streaming broker, which is easy to deploy on cloud environments, on-premises, and on your local machine. It is currently used by millions worldwide. (source)

RabbitMQ supports several open standard protocols, including AMQP 1.0 and MQTT 5.0.

There are multiple client libraries available, which can be used with your programming language of choice, just pick one. No vendor lock-in!

https://www.rabbitmq.com/