Skip to content

Commit fdc7b9f

Browse files
committed
Make processing shorter in Spring AMQP tutorial 2
Or the consumer application may stop before all messages are processed, making the user believe some messages have been lost.
1 parent 3845ab8 commit fdc7b9f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

spring-amqp/src/main/java/org/springframework/amqp/tutorials/tut2/Tut2Receiver.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@ public void receive(String in) throws InterruptedException {
4545
private void doWork(String in) throws InterruptedException {
4646
for (char ch : in.toCharArray()) {
4747
if (ch == '.') {
48-
Thread.sleep(1000);
48+
Thread.sleep(500);
4949
}
5050
}
5151
}

0 commit comments

Comments
 (0)