# RabbitMQ

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"                                |

Example:

```yaml
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: {}
```


---

# Agent Instructions: Querying This Documentation

If you need additional information that is not directly available in this page, you can query the documentation dynamically by asking a question.

Perform an HTTP GET request on the current page URL with the `ask` query parameter:

```
GET https://docs.kubemq.io/configuration/connectors/kubemq-sources/messaging/rabbitmq.md?ask=<question>
```

The question should be specific, self-contained, and written in natural language.
The response will contain a direct answer to the question and relevant excerpts and sources from the documentation.

Use this mechanism when the answer is not explicitly present in the current page, you need clarification or additional context, or you want to retrieve related documentation sections.