Nats

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

Prerequisites

The following are required to run the Nats target connector:

• kubemq cluster

• Nats server

• kubemq-targets deployment

Configuration

Nats target connector configuration properties:

Properties Key	Required	Description	Example
url	yes	nats connection host	"localhost:1883"
subject	yes	set subject name	any string
username	no	set nats username	"username"
password	no	set nats password	"password"
token	no	set nats token	"my_token"
tls	no	set if tls is needed	"false","true"
cert_file	no	tls certificate file in string format	"my_file"
cert_key	no	tls certificate key in string format	"my_key"
timeout	no	connection timeout in seconds	"130"

Example:

bindings:
  - name: nats
    source:
      kind: kubemq.events
      properties:
        address: localhost:50000
        channel: event.messaging.nats
    target:
      kind: messaging.nats
      properties:
        cert_file: |-
          -----BEGIN CERTIFICATE-----
          -----END CERTIFICATE-----
        cert_key: |-
          -----BEGIN PRIVATE KEY-----
          -----END PRIVATE KEY-----
        dynamic_mapping: "false"
        url: nats://localhost:4222
    properties: {}

Usage

Request

Query request data setting:

Data Key	Required	Description	Possible values
data	yes	data to publish	base64 bytes array

Example:

{
  "data": "U0VMRUNUIGlkLHRpdGxlLGNvbnRlbnQgRlJPTSBwb3N0Ow=="
}