From d32501787c07d795a147668c2a90f0dd00e484ec Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Martynas=20Mickevi=C4=8Dius?= <self@2m.lt>
Date: Tue, 7 Aug 2018 09:07:42 +0300
Subject: [PATCH] Make sure the stream is there for all message acks (#974)

---
 .../java/akka/stream/alpakka/jms/javadsl/JmsConnectorsTest.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/jms/src/test/java/akka/stream/alpakka/jms/javadsl/JmsConnectorsTest.java b/jms/src/test/java/akka/stream/alpakka/jms/javadsl/JmsConnectorsTest.java
index b93b6ce3d3..f8b77991f4 100644
--- a/jms/src/test/java/akka/stream/alpakka/jms/javadsl/JmsConnectorsTest.java
+++ b/jms/src/test/java/akka/stream/alpakka/jms/javadsl/JmsConnectorsTest.java
@@ -491,13 +491,13 @@ public void publishAndConsumeJmsTextMessagesWithClientAcknowledgement() throws E
           // #run-jms-source-with-ack
           CompletionStage<List<String>> result =
               jmsSource
-                  .take(msgsIn.size())
                   .map(
                       message -> {
                         String text = ((ActiveMQTextMessage) message).getText();
                         message.acknowledge();
                         return text;
                       })
+                  .take(msgsIn.size())
                   .runWith(Sink.seq(), materializer);
           // #run-jms-source-with-ack