ballerinax/solace Ballerina library

Overview

Solace PubSub+ is an advanced event-broker platform that enables event-driven communication across distributed applications using multiple messaging patterns such as publish/subscribe, request/reply, and queue-based messaging. It supports standard messaging protocols, including JMS, MQTT, AMQP, and REST, enabling seamless integration across diverse systems and environments.

The ballerinax/solace package provides APIs to interact with Solace PubSub+ brokers through the JMS API. It allows developers to programmatically produce and consume messages, manage topics and queues, and implement robust, event-driven solutions that leverage Solace’s high-performance messaging capabilities within Ballerina applications.

Quickstart

Step 1: Import the module

Import the solace module into the Ballerina project.

import ballerinax/solace;

Step 2: Instantiate a new connector

Initialize a solace:MessageProducer

configurable string brokerUrl = ?;
configurable string messageVpn = ?;
configurable string queueName = ?;
configurable string username = ?;
configurable string password = ?;

solace:MessageProducer producer = check new (brokerUrl,
    destination = {
        queueName
    },
    messageVpn = messageVpn,
    auth = {
        username,
        password
    }
);

Initialize a solace:MessageConsumer

configurable string brokerUrl = ?;
configurable string messageVpn = ?;
configurable string queueName = ?;
configurable string username = ?;
configurable string password = ?;

solace:MessageConsumer consumer = check new (brokerUrl,
    destination = {
        queueName
    },
    messageVpn = messageVpn,
    auth = {
        username,
        password
    }
);

Step 3: Invoke the connector operation

Now, you can use the available connector operations to interact with Solace broker.

Produce message to a queue

check producer->send({
    payload: "This is a sample message"
});

Retrieve a message from a queue

solace:Message? receivedMessage = check consumer->receive(5.0);

Step 4: Run the Ballerina application

Save the changes and run the Ballerina application using the following command.

bal run