Queue Resource

[sam-goodwin]

Event Source:

export interface MyMessage {
  someID: string;
  someOtherID: string;
}

const MyQueue = queue<MyMessage>("MyQueue", {
  fifo: true,
  groupBy: (msg) => msg.someID,
  dedupe: (msg) => msg.someOtherID
}, async (messages) => {
  // process
  return {
    failed: [ .. ]
  }
});

Config:

• [ ] Fifo: true/false
• [ ] Encryption: yes/no
• [ ] MessageGroupID

Client-side APIs:

• [ ] SendMessage
• [ ] SendMessageBatch
• [ ] ChangeMessageVisibility
• [ ] DeleteMessage
• [ ] DeleteMessageBatch