Skip to content

Latest commit

 

History

History
 
 

rabbitmq

Folders and files

NameName
Last commit message
Last commit date

parent directory

..
 
 
 
 
 
 
 
 
 
 
 
 

Kubemq RabbitMQ Source

Kubemq RabbitMQ source provides a RabbitMQ subscriber for processing RabbitMQ's messages.

Prerequisites

The following are required to run events source connector:

  • kubemq cluster
  • kubemq-sources deployment
  • RabbitMQ Server

Configuration

RabbitMQ source connector configuration properties:

Properties Key Required Description Example
url yes rabbitmq connection string address "amqp://guest:guest@localhost:5672/"
queue yes set subscription queue "queue"
dynamic_mapping yes set if to map rabbit topic to kubemq channel "true"
consumer yes set subscription consumer tag "consumer"
requeue_on_error bool set requeue on error property "false"
auto_ack bool set auto_ack property "false"
exclusive bool set exclusive property "false"
ca_cert no SSL CA certificate pem certificate value
client_certificate no SSL Client certificate (mMTL) pem certificate value
client_key no SSL Client Key (mTLS) pem key value

Example:

bindings:
- name: rabbitmq
  source:
    kind: messaging.rabbitmq
    properties:
      auto_ack: "false"
      consumer: "1"
      exclusive: "false"
      dynamic_mapping: "true"
      queue: some-queue
      requeue_on_error: "false"
      url: amqp://guest:guest@localhost:5672/
  target:
    kind: kubemq.events
    properties:
      address: localhost:50000
      auth_token: ""
      channel: events.messaging.rabbitmq
      client_id: rabbitmq
  properties: {}