---
title: Message Queue
description: Message Queue protocol schemas
---

{/* ⚠️  AUTO-GENERATED — DO NOT EDIT. Run build-docs.ts to regenerate. Hand-written docs go in content/docs/guides/. */}

<Callout type="info">
**Source:** `packages/spec/src/integration/message-queue.zod.ts`
</Callout>

## TypeScript Usage

```typescript
import { ConsumerConfig, MessageQueueProvider } from '@objectstack/spec/integration';
import type { ConsumerConfig, MessageQueueProvider } from '@objectstack/spec/integration';

// Validate data
const result = ConsumerConfig.parse(data);
```

---

## ConsumerConfig

### Properties

| Property | Type | Required | Description |
| :--- | :--- | :--- | :--- |
| **enabled** | `boolean` | ✅ | Enable consumer |
| **consumerGroup** | `string` | optional | Consumer group ID |
| **concurrency** | `number` | ✅ | Number of concurrent consumers |
| **prefetchCount** | `number` | ✅ | Prefetch count |
| **ackMode** | `Enum<'auto' \| 'manual' \| 'client'>` | ✅ | Message acknowledgment mode |
| **autoCommit** | `boolean` | ✅ | Auto-commit offsets |
| **autoCommitIntervalMs** | `number` | ✅ | Auto-commit interval in ms |
| **sessionTimeoutMs** | `number` | ✅ | Session timeout in ms |
| **rebalanceTimeoutMs** | `number` | optional | Rebalance timeout in ms |


---

## MessageQueueProvider

Message queue provider type

### Allowed Values

* `rabbitmq`
* `kafka`
* `redis_pubsub`
* `redis_streams`
* `aws_sqs`
* `aws_sns`
* `google_pubsub`
* `azure_service_bus`
* `azure_event_hubs`
* `nats`
* `pulsar`
* `activemq`
* `custom`


---

