MQTT
Kubemq rabbitmq target connector allows services using kubemq server to access rabbitmq messaging services.
Prerequisites
The following are required to run the rabbitmq target connector:
kubemq cluster
rabbitmq server
kubemq-targets deployment
Configuration
RabbitMQ target connector configuration properties:
Properties Key
Required
Description
Example
url
yes
rabbitmq connection string address
"amqp://rabbitmq:rabbitmq@localhost:5672/"
Example:
bindings:
- name: kubemq-query-rabbitmq
source:
kind: kubemq.query
name: kubemq-query
properties:
address: "kubemq-cluster:50000"
client_id: "kubemq-query-rabbitmq-connector"
auth_token: ""
channel: "query.rabbitmq"
group: ""
concurrency: "1"
auto_reconnect: "true"
reconnect_interval_seconds: "1"
max_reconnects: "0"
target:
kind: messaging.rabbitmq
name: target-rabbitmq
properties:
url: "amqp://rabbitmq:rabbitmq@localhost:5672/"
Usage
Request
Request metadata setting:
Metadata Key
Required
Description
Possible values
queue
yes
set queue name
"queue"
exchange
no
set exchange name
"exchange"
mandatory
no
set mandatory
"true","false"
immediate
no
set immediate
"true","false"
delivery_mode
no
set delivery mode
"1","2"
priority
no
set priority
"0"-"9"
correlation_id
no
set correlation id
"some id"
reply_to
no
set set reply to
""
expiry_seconds
no
set message expiry in seconds
"3600"
Query request data setting:
Data Key
Required
Description
Possible values
data
yes
data to publish
base64 bytes array
Example:
{
"metadata": {
"queue": "queue",
"exchange": "",
"confirm": "true",
"mandatory": "false",
"immediate": "false",
"delivery_mode": "1",
"priority": "0",
"correlation_id": "",
"reply_to": "",
"expiry_seconds": "3600"
},
"data": "U0VMRUNUIGlkLHRpdGxlLGNvbnRlbnQgRlJPTSBwb3N0Ow=="
}
Last updated
Was this helpful?