We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 819b3f9 commit 0febe57Copy full SHA for 0febe57
1 file changed
core/src/main/java/io/temporal/samples/packetdelivery/Starter.java
@@ -7,6 +7,7 @@
7
import io.temporal.serviceclient.WorkflowServiceStubs;
8
import io.temporal.worker.Worker;
9
import io.temporal.worker.WorkerFactory;
10
+import java.util.Collections;
11
import java.util.List;
12
13
public class Starter {
@@ -36,10 +37,13 @@ public static void main(String[] args) {
36
37
// more
38
while (true) {
39
sleep(3);
40
+ // for "fun", reverse the list we get from delivery confirmation list
41
List<Packet> packets = workflow.deliveryConfirmationPackets();
42
if (packets.isEmpty()) {
43
break;
44
}
45
46
+ Collections.reverse(packets);
47
48
for (Packet p : packets) {
49
try {
0 commit comments