-
Notifications
You must be signed in to change notification settings - Fork 53
Description
Hi @poundifdef ,
I just jumped for testing the tool as replacement for SQS, however i cannot reproduce sucessfuly the FIFO queue with per message group ID throughput limit.
This works in aws but not in smoothmq:
const command = new CreateQueueCommand({
QueueName: 'test2',
Attributes: {
FifoQueue: 'true',
VisibilityTimeout: '30',
DeduplicationScope: 'messageGroup',
FifoThroughputLimit: 'perMessageGroupId',
},
})
const command = new SendMessageCommand({
QueueUrl,
MessageBody: 'receiving message',
MessageAttributes: {
MessageId: {
DataType: 'String',
StringValue: '123',
},
},
MessageDeduplicationId: `${Math.random().toString(36).substring(2, 15)}`,
MessageGroupId: 'MYGROUP1',
})
I can add values to the queue, but the FIFO per messageGroupId is not being respected as it should be (records from the same message group returns in the immediate subsequent ReceiveMessageCommand.)
The only difference I can notice is that AWS states that fifo queues should end with .fifo, however if i try to create this with as queuename 'test2.fifo', i get the " SQSServiceException [ValidationError]: Invalid request payload" error.
All same commands works fine in AWS but not in SmoothMq.
Another issue i noticed: hasnt delete queue been implemented?
If i try to delete queue, i get 'UnsupportedOperation: SQS method AmazonSQS.DeleteQueue not implemented' error.
Thank you.