GitHub/Spring
1
0
Fork 0
mirror of https://github.com/OtusTeam/Spring.git synced 2026-05-30 10:50:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

2023-03 spring-29-integrations-channels updated

Browse Source
This commit is contained in:
stvort
2023-07-24 22:30:23 +04:00
parent 8f0997ff0d
commit 5fae5c4590
2 changed files with 14 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
2023-03/spring-29-integrations-channels/integrations-channels-exercise/src/main/java/ru/otus/spring/integration/App.java
+7 -1
View File
@@ -8,6 +8,7 @@ import org.springframework.integration.annotation.IntegrationComponentScan;
import org.springframework.integration.channel.QueueChannel;
import org.springframework.integration.dsl.DirectChannelSpec;
import org.springframework.integration.dsl.MessageChannels;
import org.springframework.messaging.Message;
import org.springframework.messaging.PollableChannel;
import org.springframework.messaging.SubscribableChannel;
import org.springframework.messaging.support.MessageBuilder;
@@ -16,6 +17,7 @@ import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
import static java.util.Objects.isNull;
import static java.util.Objects.requireNonNull;
@SpringBootApplication
@@ -33,7 +35,11 @@ public class App {
ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor();
executor.scheduleWithFixedDelay(() -> {
System.out.println("I am here!!!");
subscribableDirectChannel.send(requireNonNull(queueChannel.receive(5000)));
Message<?> receivedMessage = queueChannel.receive(5000);
if (isNull(receivedMessage)) {
return;
}
subscribableDirectChannel.send(receivedMessage);
}, 100, 300, TimeUnit.MILLISECONDS);
queueChannel.send(MessageBuilder.withPayload("Hello").build());
2023-03/spring-29-integrations-channels/integrations-channels-solution/src/main/java/ru/otus/spring/integration/App.java
+7 -1
View File
@@ -8,6 +8,7 @@ import org.springframework.integration.annotation.IntegrationComponentScan;
import org.springframework.integration.channel.QueueChannel;
import org.springframework.integration.dsl.DirectChannelSpec;
import org.springframework.integration.dsl.MessageChannels;
import org.springframework.messaging.Message;
import org.springframework.messaging.PollableChannel;
import org.springframework.messaging.SubscribableChannel;
import org.springframework.messaging.support.MessageBuilder;
@@ -16,6 +17,7 @@ import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
import static java.util.Objects.isNull;
import static java.util.Objects.requireNonNull;
@SpringBootApplication
@@ -33,7 +35,11 @@ public class App {
ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor();
executor.scheduleWithFixedDelay(() -> {
System.out.println("I am here!!!");
subscribableDirectChannel.send(requireNonNull(queueChannel.receive(5000)));
Message<?> receivedMessage = queueChannel.receive(5000);
if (isNull(receivedMessage)) {
return;
}
subscribableDirectChannel.send(receivedMessage);
}, 100, 300, TimeUnit.MILLISECONDS);
queueChannel.send(MessageBuilder.withPayload("Hello").build());