conformance test runs in single mode

Signed-off-by: Amit Mor <amit.mor@hotmail.com>
This commit is contained in:
Amit Mor 2022-04-11 11:41:52 +03:00
parent c31866099c
commit 136bccd56e
No known key found for this signature in database
GPG Key ID: 6ED17DBA7E1AD71B
2 changed files with 4 additions and 2 deletions

View File

@ -562,7 +562,7 @@ func (s *snsSqs) callHandler(message *sqs.Message, queueInfo *sqsQueueInfo, hand
return fmt.Errorf("failed loading topic (sanitized): %s from internal topics cache. SNS topic might be just created", sanitizedTopic)
}
s.logger.Debugf("Processing SNS message id: %s of topic: %s", message.MessageId, sanitizedTopic)
s.logger.Debugf("Processing SNS message id: %s of topic: %s", *message.MessageId, sanitizedTopic)
ctx, cancelFn := context.WithCancel(s.ctx)
defer cancelFn()

View File

@ -24,4 +24,6 @@ spec:
- name: messageWaitTimeSeconds
value: 1
- name: messageMaxNumber
value: 10
value: 10
- name: concurrencyMode
value: "single"