Make sure the stream is there for all message acks (#974)

akka · Aug 7, 2018 · d325017 · d325017
1 parent ca97753
commit d325017
Showing 1 changed file with 1 addition and 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
@@ -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