KubeMQ binding spec

Detailed documentation on the KubeMQ binding component

Component format

To setup KubeMQ binding create a component of type bindings.kubemq. See this guide on how to create and apply a binding configuration.

  1. apiVersion: dapr.io/v1alpha1
  2. kind: Component
  3. metadata:
  4. name: binding-topic
  5. spec:
  6. type: bindings.kubemq
  7. version: v1
  8. metadata:
  9. - name: address
  10. value: localhost:50000
  11. - name: channel
  12. value: queue1

Spec metadata fields

FieldRequiredDetailsExample
addressYAddress of the KubeMQ server“localhost:50000”
channelYThe Queue channel namequeue1
authTokenNAuth JWT token for connection. Check out KubeMQ Authenticationew…
autoAcknowledgedNSets if received queue message is automatically acknowledgedtrue or false (default is false)
pollMaxItemsNSets the number of messages to poll on every connection1
pollTimeoutSecondsNSets the time in seconds for each poll interval3600

Binding support

This component supports both input and output binding interfaces.

Create a KubeMQ broker

  1. Obtain KubeMQ Key by visiting https://account.kubemq.io/login/register and register for a key.
  2. Wait for an email confirmation with your Key

You can run a KubeMQ broker with Docker:

  1. docker run -d -p 8080:8080 -p 50000:50000 -p 9090:9090 -e KUBEMQ_TOKEN=<your-key> kubemq/kubemq

You can then interact with the server using the client port: localhost:50000

  1. Obtain KubeMQ Key by visiting https://account.kubemq.io/login/register and register for a key.
  2. Wait for an email confirmation with your Key

Then Run the following kubectl commands:

  1. kubectl apply -f https://deploy.kubemq.io/init
  1. kubectl apply -f https://deploy.kubemq.io/key/<your-key>

Install KubeMQ CLI

Go to KubeMQ CLI and download the latest version of the CLI.

Browse KubeMQ Dashboard

Open a browser and navigate to http://localhost:8080

With KubeMQCTL installed, run the following command:

  1. kubemqctl get dashboard

Or, with kubectl installed, run port-forward command:

  1. kubectl port-forward svc/kubemq-cluster-api -n kubemq 8080:8080

KubeMQ Documentation

Visit KubeMQ Documentation for more information.

Last modified February 16, 2023: [1.10] Some docs fixes to components reference (#3187) (7956f821)