Getting Started
Configuration
Troubleshooting
License
Service Bus
Kubemq servicebus target connector allows services using kubemq server to access servicebus messaging services.
Prerequisites
The following are required to run the servicebus target connector:
- kubemq cluster
- Azure active with servicebus enable
- kubemq-targets deployment
Configuration
servicebus target connector configuration properties:
Properties Key
Required
Description
Example
end_point
yes
event hubs target endpoint
"sb://my_account.net"
shared_access_key_name
yes
event hubs access key name
"keyname"
shared_access_key
yes
event hubs shared access key name
"213ase123"
Example:
1
bindings:
2
- name: kubemq-query-azure-servicebus
3
source:
4
kind: kubemq.query
5
name: kubemq-query
6
properties:
7
address: "kubemq-cluster:50000"
8
client_id: "kubemq-query-azure-servicebus-connector"
9
auth_token: ""
10
channel: "azure.servicebus"
11
group: ""
12
auto_reconnect: "true"
13
reconnect_interval_seconds: "1"
14
max_reconnects: "0"
15
target:
16
kind: azure.servicebus
17
name: target-azure-servicebus
18
properties:
19
end_point: "sb://my_account.net"
20
shared_access_key_name: "keyname"
21
shared_access_key: "213ase123"
22
queue_name: "mypath"
Copied!
Usage
send
send metadata setting:
Metadata Key
Required
Description
Possible values
method
yes
type of method
"send"
label
no
the message label
"my_label"
content_type
no
message content type
"content_type"
time_to_live
no
message time to live
"1000000000"default(1000000000)
Example:
1
{
2
"metadata": {
3
"method": "send",
4
"label": "my_label"
5
},
6
"data": "bXktZmlsZS1kYXRh"
7
}
Copied!
send batch
send batch metadata setting:
Metadata Key
Required
Description
Possible values
method
yes
type of method
"send_batch"
label
no
the message label
"my_label"
content_type
no
message content type
"content_type"
time_to_live
no
message time to live
"1000000000"default(1000000000)
Example:
1
{
2
"metadata": {
3
"method": "send_batch",
4
"label": "my_label"
5
},
6
"data": "WyJ0ZXN0MSIsInRlc3QyIiwidGVzdDMiLCJ0ZXN0NCJd"
7
}
8
```
Copied!
Last modified 11mo ago
Copy link