Skip to content

Commit 5af0e9e

Browse files
committed
Add message group ID
1 parent 30ec667 commit 5af0e9e

File tree

5 files changed

+9
-0
lines changed

5 files changed

+9
-0
lines changed

src/api/routes/apiKey.ts

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -126,6 +126,7 @@ If you did not create this API key, please secure your account and notify the AC
126126
new SendMessageCommand({
127127
QueueUrl: fastify.environmentConfig.SqsQueueUrl,
128128
MessageBody: JSON.stringify(sqsPayload),
129+
MessageGroupId: "securityNotification",
129130
}),
130131
);
131132
if (result.MessageId) {
@@ -228,6 +229,7 @@ If you did not delete this API key, please secure your account and notify the AC
228229
new SendMessageCommand({
229230
QueueUrl: fastify.environmentConfig.SqsQueueUrl,
230231
MessageBody: JSON.stringify(sqsPayload),
232+
MessageGroupId: "securityNotification",
231233
}),
232234
);
233235
if (result.MessageId) {

src/api/routes/membership.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -459,6 +459,7 @@ const membershipPlugin: FastifyPluginAsync = async (fastify, _options) => {
459459
new SendMessageCommand({
460460
QueueUrl: fastify.environmentConfig.SqsQueueUrl,
461461
MessageBody: JSON.stringify(sqsPayload),
462+
MessageGroupId: "membershipProvisioning",
462463
}),
463464
);
464465
if (!result.MessageId) {

src/api/routes/mobileWallet.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -79,6 +79,7 @@ const mobileWalletRoute: FastifyPluginAsync = async (fastify, _options) => {
7979
new SendMessageCommand({
8080
QueueUrl: fastify.environmentConfig.SqsQueueUrl,
8181
MessageBody: JSON.stringify(sqsPayload),
82+
MessageGroupId: "mobileWalletNotification",
8283
}),
8384
);
8485
if (!result.MessageId) {

src/api/routes/roomRequests.ts

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -160,6 +160,7 @@ const roomRequestRoutes: FastifyPluginAsync = async (fastify, _options) => {
160160
new SendMessageCommand({
161161
QueueUrl: fastify.environmentConfig.SqsQueueUrl,
162162
MessageBody: JSON.stringify(sqsPayload),
163+
MessageGroupId: "roomReservationNotification",
163164
}),
164165
);
165166
if (!result.MessageId) {
@@ -388,6 +389,7 @@ const roomRequestRoutes: FastifyPluginAsync = async (fastify, _options) => {
388389
new SendMessageCommand({
389390
QueueUrl: fastify.environmentConfig.SqsQueueUrl,
390391
MessageBody: JSON.stringify(sqsPayload),
392+
MessageGroupId: "roomReservationNotification",
391393
}),
392394
);
393395
if (!result.MessageId) {

src/api/routes/stripe.ts

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -434,6 +434,7 @@ Please ask the payee to try again, perhaps with a different payment method, or c
434434
new SendMessageCommand({
435435
QueueUrl: fastify.environmentConfig.SqsQueueUrl,
436436
MessageBody: JSON.stringify(sqsPayload),
437+
MessageGroupId: "invoiceNotification",
437438
}),
438439
);
439440
queueId = result.MessageId || "";
@@ -588,6 +589,7 @@ Please contact Officer Board with any questions.
588589
new SendMessageCommand({
589590
QueueUrl: fastify.environmentConfig.SqsQueueUrl,
590591
MessageBody: JSON.stringify(sqsPayload),
592+
MessageGroupId: "invoiceNotification",
591593
}),
592594
);
593595
queueId = result.MessageId || "";
@@ -636,6 +638,7 @@ Please contact Officer Board with any questions.`,
636638
new SendMessageCommand({
637639
QueueUrl: fastify.environmentConfig.SqsQueueUrl,
638640
MessageBody: JSON.stringify(sqsPayload),
641+
MessageGroupId: "invoiceNotification",
639642
}),
640643
);
641644
queueId = result.MessageId || "";

0 commit comments

Comments
 (0)