Alpakka AWS SQS Connector with FIFO Queue

196 views
Skip to first unread message

h.inam...@gmail.com

unread,
Dec 3, 2016, 4:54:02 AM12/3/16
to Akka User List
Hi,
I tried to use Alpakka AWS SQS Connector, and I like it!
I have a question about using FIFO Queue.

1. I sent 5 messages(body: message-1, message-2) to FIFO Queue that I made in AWS.
2. I ran a program, and I got result. (below)

```
SqsSource(queue)
  .runForeach((message) => {
    println(message.getBody)
  })
```

```
[info] Running ***.AlpakkaSQSSample 
message-5
message-4
message-3
message-2
message-1
```

Is this expected result?
I expected that I can get message from 1.

In aws-cli,
```
{
  "Messages": [
    {
      "Body": "message-1"
    },
    {
      "Body": "message-2"
    },
    {
      "Body": "message-3"
    },...
  ]
}
```

My code is here.

Thank you.

Hideto

h.inam...@gmail.com

unread,
Dec 3, 2016, 7:39:41 AM12/3/16
to Akka User List
Reply all
Reply to author
Forward
0 new messages