fixes FIFO bugs

Signed-off-by: Roberto J Rojas <robertojrojas@gmail.com>

.github/workflows/certification.yml

@@ -311,8 +311,8 @@ jobs:
         PUBSUB_AWS_SNSSQS_QUEUE_FIFO="sqssnscerttest-q-fifo-${{env.UNIQUE_ID}}"
         echo "PUBSUB_AWS_SNSSQS_QUEUE_FIFO=$PUBSUB_AWS_SNSSQS_QUEUE_FIFO" >> $GITHUB_ENV
         PUBSUB_AWS_SNSSQS_TOPIC_FIFO="sqssnscerttest-t-fifo-${{env.UNIQUE_ID}}"
-        echo "PUBSUB_AWS_SNSSQS_FIFO_GROUP_ID=$PUBSUB_AWS_SNSSQS_FIFO_GROUP_ID" >> $GITHUB_ENV
-        PUBSUB_AWS_SNSSQS_TOPIC_FIFO="sqssnscerttest-q-fifo-${{env.UNIQUE_ID}}"
+        echo "PUBSUB_AWS_SNSSQS_TOPIC_FIFO=$PUBSUB_AWS_SNSSQS_TOPIC_FIFO" >> $GITHUB_ENV
+        PUBSUB_AWS_SNSSQS_FIFO_GROUP_ID="sqssnscerttest-q-fifo-${{env.UNIQUE_ID}}"
         echo "PUBSUB_AWS_SNSSQS_FIFO_GROUP_ID=$PUBSUB_AWS_SNSSQS_FIFO_GROUP_ID" >> $GITHUB_ENV
 
         AWS_REGION="us-east-1"

tests/certification/pubsub/aws/snssqs/components/fifo/pubsub.yaml

@@ -29,7 +29,9 @@ spec:
     - name: fifo
       value: "true"
     - name: messageMaxNumber
-      value: "1"
+      value: "10"
+    - name: concurrencyMode
+      value: "single"
     
 auth:
   secretstore: envvar-secret-store

tests/certification/pubsub/aws/snssqs/snssqs_test.go

@@ -90,7 +90,6 @@ var topics = []string{
 	topicPassiveName,
 	topicToBeCreated,
 	topicDefaultName,
-	fifoTopic,
 }
 
 func init() {
@@ -119,10 +118,12 @@ func init() {
 	qn = os.Getenv("PUBSUB_AWS_SNSSQS_TOPIC_MVT")
 	if qn != "" {
 		messageVisibilityTimeoutTopic = qn
+		topics = append(topics, messageVisibilityTimeoutTopic)
 	}
 	qn = os.Getenv("PUBSUB_AWS_SNSSQS_TOPIC_FIFO")
 	if qn != "" {
 		fifoTopic = qn
+		topics = append(topics, fifoTopic)
 	}
 }
 
@@ -1219,7 +1220,7 @@ func SNSSQSFIFOMessages(t *testing.T) {
 	consumerGroup1 := watcher.NewOrdered()
 
 	// prepare the messages
-	maxFifoMessages := 10
+	maxFifoMessages := 20
 	fifoMessages := make([]string, maxFifoMessages)
 	for i := 0; i < maxFifoMessages; i++ {
 		fifoMessages[i] = fmt.Sprintf("m%d", i+1)