ObjectStackMessage Queue
Message Queue protocol schemas
Source: packages/spec/src/integration/message-queue.zod.ts
TypeScript Usage
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
rabbitmqkafkaredis_pubsubredis_streamsaws_sqsaws_snsgoogle_pubsubazure_service_busazure_event_hubsnatspulsaractivemqcustom