Skip to content

Commit

Permalink
Add example for message producing
Browse files Browse the repository at this point in the history
  • Loading branch information
ayeshLK committed Feb 26, 2024
1 parent 2724d3c commit 4c9b89e
Show file tree
Hide file tree
Showing 5 changed files with 88 additions and 0 deletions.
1 change: 1 addition & 0 deletions examples/produce-messages/.github/README.md
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
../Produce Messages.md
8 changes: 8 additions & 0 deletions examples/produce-messages/Ballerina.toml
Original file line number Diff line number Diff line change
@@ -0,0 +1,8 @@
[package]
org = "wso2"
name = "produce_messages"
version = "0.1.0"
distribution = "2201.8.4"

[build-options]
observabilityIncluded = true
7 changes: 7 additions & 0 deletions examples/produce-messages/Config.toml
Original file line number Diff line number Diff line change
@@ -0,0 +1,7 @@
queueManagerName = "QM1"
host = "localhost"
port = 1414
channel = "DEV.APP.SVRCONN"
userID = "app"
password = "password"
queueName = "DEV.QUEUE.1"
31 changes: 31 additions & 0 deletions examples/produce-messages/Produce Messages.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,31 @@
# Produce messages

This example demonstrates how to produce messages to an IBM MQ queue.

## Prerequisites

### 1. Setup Gmail API

Refer to the [Setup Guide](https://dev-central.ballerina.io/ballerinax/ibm.ibmmq/latest#setup-guide) to set up the IBM MQ server locally.

### 2. Configuration

Configure Gmail API credentials in `Config.toml` in the example directory:

```toml
queueManagerName = "<queue-manager-name>"
host = "<host>"
port = <port>
channel = "<ibm-mq-channel>"
userID = "<user-ID>"
password = "<password>"
queueName = "<queue-name>"
```

## Run the Example

Execute the following command to run the example:

```bash
bal run
```
41 changes: 41 additions & 0 deletions examples/produce-messages/main.bal
Original file line number Diff line number Diff line change
@@ -0,0 +1,41 @@
// Copyright (c) 2024, WSO2 LLC. (http://www.wso2.org).
//
// WSO2 LLC. licenses this file to you under the Apache License,
// Version 2.0 (the "License"); you may not use this file except
// in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing,
// software distributed under the License is distributed on an
// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
// KIND, either express or implied. See the License for the
// specific language governing permissions and limitations
// under the License.

import ballerinax/ibm.ibmmq;

configurable string queueManagerName = ?;
configurable string host = ?;
configurable int port = ?;
configurable string channel = ?;
configurable string userID = ?;
configurable string password = ?;
configurable string queueName = ?;

public function main() returns error?{
ibmmq:QueueManager queueManager = check new (
name = queueManagerName,
host = host,
channel = channel,
userID = userID,
password = password
);
ibmmq:Queue queue = check queueManager.accessQueue(queueName, ibmmq:MQOO_OUTPUT);
check queue->put({
payload: "This is a sample message to IBM MQ queue".toBytes()
});
check queue->close();
check queueManager.disconnect();
}

0 comments on commit 4c9b89e

Please sign in to comment.