Skip to content

Commit 5b48ba4

Browse files
committed
fix: Remove fifo queues
1 parent 6d767ca commit 5b48ba4

File tree

2 files changed

+0
-17
lines changed

2 files changed

+0
-17
lines changed

lambdas/functions/control-plane/src/aws/sqs.test.ts

-16
Original file line numberDiff line numberDiff line change
@@ -27,22 +27,6 @@ describe('Publish message to SQS', () => {
2727
});
2828
});
2929

30-
it('should publish message to SQS Fifo queue', async () => {
31-
// setup
32-
mockSQSClient.on(SendMessageCommand).resolves({
33-
MessageId: '123',
34-
});
35-
36-
// act
37-
await publishMessage('test', 'https://sqs.eu-west-1.amazonaws.com/123456789/queued-builds.fifo');
38-
39-
// assert
40-
expect(mockSQSClient).toHaveReceivedCommandWith(SendMessageCommand, {
41-
QueueUrl: 'https://sqs.eu-west-1.amazonaws.com/123456789/queued-builds.fifo',
42-
MessageBody: 'test',
43-
MessageGroupId: '1', // Fifo queue
44-
});
45-
});
4630

4731
it('should log error if queue URL not found', async () => {
4832
// setup

lambdas/functions/control-plane/src/aws/sqs.ts

-1
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,6 @@ export async function publishMessage(message: string, queueUrl: string, delayInS
1919
QueueUrl: queueUrl,
2020
MessageBody: message,
2121
DelaySeconds: delayInSeconds,
22-
MessageGroupId: queueUrl.endsWith('.fifo') ? '1' : undefined,
2322
});
2423

2524
try {

0 commit comments

Comments
 (0)