Fix F sequencing

commercetools · Mar 7, 2024 · 67a0289 · 67a0289
1 parent 83b4415
commit 67a0289
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ervice-bus/src/main/scala/com/commercetools/queue/azure/servicebus/ServiceBusPusher.scala b/...ervice-bus/src/main/scala/com/commercetools/queue/azure/servicebus/ServiceBusPusher.scala
@@ -45,8 +45,8 @@ class ServiceBusPusher[F[_], Data](sender: ServiceBusSenderClient)(implicit seri
           msg.setScheduledEnqueueTime(now.plusMillis(delay.toMillis).atOffset(ZoneOffset.UTC))
         }
       }
-    }
-    F.blocking(sender.sendMessages(sbMessages.asJava)).void
+    } *>
+      F.blocking(sender.sendMessages(sbMessages.asJava)).void
   }
 
 }