RedisSMQ / Docs / API Reference / ProducibleMessage
- disablePriority
- getBody
- getConsumeTimeout
- getCreatedAt
- getExchange
- getFanOut
- getPriority
- getQueue
- getRetryDelay
- getRetryThreshold
- getScheduledCRON
- getScheduledDelay
- getScheduledRepeat
- getScheduledRepeatPeriod
- getTTL
- getTopic
- hasPriority
- resetScheduledParams
- setBody
- setConsumeTimeout
- setFanOut
- setPriority
- setQueue
- setRetryDelay
- setRetryThreshold
- setScheduledCRON
- setScheduledDelay
- setScheduledRepeat
- setScheduledRepeatPeriod
- setTTL
- setTopic
- setDefaultConsumeOptions
• new ProducibleMessage(): ProducibleMessage
▸ disablePriority(): ProducibleMessage
▸ getBody(): unknown
unknown
▸ getConsumeTimeout(): number
number
▸ getCreatedAt(): number
number
▸ getExchange(): null | TExchangeTransferable
null | TExchangeTransferable
▸ getFanOut(): null | string
null | string
▸ getPriority(): null | EMessagePriority
null | EMessagePriority
▸ getQueue(): null | IQueueParams
null | IQueueParams
▸ getRetryDelay(): number
number
▸ getRetryThreshold(): number
number
▸ getScheduledCRON(): null | string
null | string
▸ getScheduledDelay(): null | number
null | number
▸ getScheduledRepeat(): number
number
▸ getScheduledRepeatPeriod(): null | number
null | number
▸ getTTL(): number
number
▸ getTopic(): null | ITopicParams
null | ITopicParams
▸ hasPriority(): boolean
boolean
▸ resetScheduledParams(): ProducibleMessage
▸ setBody(body): ProducibleMessage
| Name | Type |
|---|---|
body |
unknown |
▸ setConsumeTimeout(timeout): ProducibleMessage
| Name | Type | Description |
|---|---|---|
timeout |
number |
In milliseconds |
▸ setFanOut(fanOutName): ProducibleMessage
| Name | Type |
|---|---|
fanOutName |
string |
▸ setPriority(priority): ProducibleMessage
| Name | Type |
|---|---|
priority |
EMessagePriority |
▸ setQueue(queueParams): ProducibleMessage
| Name | Type |
|---|---|
queueParams |
string | IQueueParams |
▸ setRetryDelay(delay): ProducibleMessage
| Name | Type | Description |
|---|---|---|
delay |
number |
In millis |
▸ setRetryThreshold(threshold): ProducibleMessage
| Name | Type |
|---|---|
threshold |
number |
▸ setScheduledCRON(cron): ProducibleMessage
| Name | Type |
|---|---|
cron |
string |
▸ setScheduledDelay(delay): ProducibleMessage
| Name | Type | Description |
|---|---|---|
delay |
number |
In millis |
▸ setScheduledRepeat(repeat): ProducibleMessage
| Name | Type |
|---|---|
repeat |
number |
▸ setScheduledRepeatPeriod(period): ProducibleMessage
| Name | Type | Description |
|---|---|---|
period |
number |
In millis |
▸ setTTL(ttl): ProducibleMessage
| Name | Type | Description |
|---|---|---|
ttl |
number |
In milliseconds |
▸ setTopic(topicParams): ProducibleMessage
| Name | Type |
|---|---|
topicParams |
string | ITopicParams |
▸ setDefaultConsumeOptions(consumeOptions): void
| Name | Type |
|---|---|
consumeOptions |
Partial<TMessageConsumeOptions> |
void