# Queue

Kubemq Queue source provides a queue subscriber for processing source queues.

## Prerequisites

The following are required to run queue source connector:

* kubemq cluster
* kubemq-targets deployment

## Configuration

Queue source connector configuration properties:

| Properties Key    | Required | Description                                            | Example              |
| ----------------- | -------- | ------------------------------------------------------ | -------------------- |
| address           | yes      | kubemq server address (gRPC interface)                 | kubemq-cluster:50000 |
| client\_id        | no       | set client id                                          | "client\_id"         |
| auth\_token       | no       | set authentication token                               | jwt token            |
| channel           | yes      | set channel to subscribe                               |                      |
| response\_channel | no       | set send target response to channel                    | "response.channel"   |
| batch\_size       | yes      | set how many messages to pull from queue               | "1"                  |
| wait\_timeout     | yes      | set how long to wait for messages to arrive in seconds | "60"                 |

Example:

```yaml
bindings:
  - name: kubemq-queue-elastic-search
    source:
      kind: queue
      name: kubemq-queue
      properties:
        address: "kubemq-cluster:50000"
        client_id: "kubemq-queue-elastic-search-connector"
        auth_token: ""
        channel: "queue.elastic-search"
        response_channel: "queue.response.elastic"
        batch_size: "1"
        wait_timeout: "60"
    target:
      kind: stores.elastic-search
      name: target-elastic-search
      properties:
        urls: "http://localhost:9200"
        username: "admin"
        password: "password"
        sniff: "false"
```