JMS: Accept redelivery of messages in tests (akka#839)

sajina125 · Mar 15, 2018 · 65c2cff · 65c2cff
1 parent 5d1b8df
commit 65c2cff
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/jms/src/test/scala/akka/stream/alpakka/jms/scaladsl/JmsTxConnectorsSpec.scala b/jms/src/test/scala/akka/stream/alpakka/jms/scaladsl/JmsTxConnectorsSpec.scala
@@ -313,7 +313,8 @@ class JmsTxConnectorsSpec extends JmsSpec {
 
       killSwitch2.shutdown()
 
-      resultList should contain theSameElementsAs numsIn.map(_.toString)
+      // messages might get delivered more than once, use set to ignore duplicates
+      resultList.toSet should contain theSameElementsAs numsIn.map(_.toString)
     }
 
     "ensure no message loss when aborting a stream" in withServer() { ctx =>
@@ -390,7 +391,8 @@ class JmsTxConnectorsSpec extends JmsSpec {
 
       killSwitch2.shutdown()
 
-      resultList should contain theSameElementsAs numsIn.map(_.toString)
+      // messages might get delivered more than once, use set to ignore duplicates
+      resultList.toSet should contain theSameElementsAs numsIn.map(_.toString)
     }
   }
 }