AmazonMQ
Kubemq AmazonMQ target connector allows services using kubemq server to access AmazonMQ messaging services.

Prerequisites

The following are required to run the AmazonMQ target connector:
  • kubemq cluster
  • AmazonMQ server - with access
  • kubemq-targets deployment
  • Please note the connector uses connection with stomp+ssl, when finishing handling messages need to call Close().

Configuration

AmazonMQ target connector configuration properties:
Properties Key
Required
Description
Example
host
yes
AmazonMQ connection host (stomp+ssl endpoint)
"localhost:1883"
username
no
set AmazonMQ username
"username"
password
no
set AmazonMQ password
"password"
Example:
1
bindings:
2
- name: kubemq-query-amazonmq
3
source:
4
kind: kubemq.query
5
name: kubemq-query
6
properties:
7
address: "kubemq-cluster:50000"
8
client_id: "kubemq-query-amazonmq-connector"
9
auth_token: ""
10
channel: "query.amazonmq"
11
group: ""
12
auto_reconnect: "true"
13
reconnect_interval_seconds: "1"
14
max_reconnects: "0"
15
target:
16
kind: aws.amazonmq
17
name: aws-amazonmq
18
properties:
19
host: "localhost:61613"
20
username: "admin"
21
password: "admin"
Copied!

Usage

Request

Request metadata setting:
Metadata Key
Required
Description
Possible values
destination
yes
set destination name
"destination"
Query request data setting:
Data Key
Required
Description
Possible values
data
yes
data to publish
base64 bytes array
Example:
1
{
2
"metadata": {
3
"destination": "destination"
4
},
5
"data": "U0VMRUNUIGlkLHRpdGxlLGNvbnRlbnQgRlJPTSBwb3N0Ow=="
6
}
Copied!
Last modified 11mo ago