MCPcopy
hub / github.com/bbc/sqs-consumer / ConsumerOptions

Interface ConsumerOptions

src/types.ts:11–192  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

9 * The options for the consumer.
10 */
11export interface ConsumerOptions {
12 /**
13 * The SQS queue URL.
14 */
15 queueUrl: string;
16 /**
17 * List of queue attributes to retrieve, see [AWS docs](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-sqs/Variable/QueueAttributeName/).
18 * @defaultvalue `[]`
19 */
20 attributeNames?: QueueAttributeName[];
21 /**
22 * List of message attributes to retrieve (i.e. `['name', 'address']`).
23 * @defaultvalue `[]`
24 */
25 messageAttributeNames?: string[];
26 /**
27 * A list of attributes that need to be returned along with each message.
28 * @defaultvalue `[]`
29 */
30 messageSystemAttributeNames?: MessageSystemAttributeName[];
31 /** @hidden */
32 stopped?: boolean;
33 /**
34 * The number of messages to request from SQS when polling (default `1`).
35 *
36 * This cannot be higher than the
37 * [AWS limit of 10](https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/quotas-messages.html).
38 * @defaultvalue `1`
39 */
40 batchSize?: number;
41 /**
42 * The duration (in seconds) that the received messages are hidden from subsequent
43 * retrieve requests after being retrieved by a ReceiveMessage request.
44 */
45 visibilityTimeout?: number;
46 /**
47 * The duration (in seconds) for which the call will wait for a message to arrive in
48 * the queue before returning.
49 * @defaultvalue `20`
50 */
51 waitTimeSeconds?: number;
52 /**
53 * The duration (in milliseconds) to wait before retrying after an authentication error.
54 * @defaultvalue `10000`
55 */
56 authenticationErrorTimeout?: number;
57 /**
58 * The duration (in milliseconds) to wait before repolling the queue.
59 * @defaultvalue `0`
60 */
61 pollingWaitTimeMs?: number;
62 /**
63 * If you want the stop action to wait for the final poll to complete and in-flight messages
64 * to be processed before emitting 'stopped' set this to the max amount of time to wait.
65 * @defaultvalue `0`
66 */
67 pollingCompleteWaitTimeMs?: number;
68 /**

Callers 4

executeHandlerMethod · 0.80
executeBatchHandlerMethod · 0.80
receiveMessageMethod · 0.80
receiveMessageMethod · 0.80

Calls

no outgoing calls

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…