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

2019-08 - 25 - Fix channel names

Browse Source
This commit is contained in:
ydvorzhetskiy
2019-11-30 11:34:48 +03:00
parent e79268a0f3
commit 2b86c617b3
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
2019-08/spring-25/spring-25-exercise/src/main/java/ru/otus/spring/integration/App.java
+3 -3
View File
@@ -5,10 +5,10 @@ import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ConfigurableApplicationContext; import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Bean;
import org.springframework.integration.annotation.IntegrationComponentScan; import org.springframework.integration.annotation.IntegrationComponentScan;
import org.springframework.integration.channel.DirectChannel;
import org.springframework.integration.channel.QueueChannel; import org.springframework.integration.channel.QueueChannel;
import org.springframework.integration.dsl.channel.MessageChannels; import org.springframework.integration.dsl.channel.MessageChannels;
import org.springframework.messaging.PollableChannel; import org.springframework.messaging.PollableChannel;
import org.springframework.messaging.SubscribableChannel;
import org.springframework.messaging.support.MessageBuilder; import org.springframework.messaging.support.MessageBuilder;
@SpringBootApplication @SpringBootApplication
@@ -19,7 +19,7 @@ public class App {
ConfigurableApplicationContext ctx = SpringApplication.run(App.class, args); ConfigurableApplicationContext ctx = SpringApplication.run(App.class, args);
PollableChannel channel1 = ctx.getBean("channel1", PollableChannel.class); PollableChannel channel1 = ctx.getBean("channel1", PollableChannel.class);
DirectChannel channel2 = ctx.getBean("channel2", DirectChannel.class); SubscribableChannel channel2 = ctx.getBean("channel2", SubscribableChannel.class);
channel2.subscribe(System.out::println); channel2.subscribe(System.out::println);
new Thread(() -> { new Thread(() -> {
@@ -44,7 +44,7 @@ public class App {
} }
@Bean @Bean
public DirectChannel channel2() { public SubscribableChannel channel2() {
return MessageChannels.direct("channel2").get(); return MessageChannels.direct("channel2").get();
} }
} }
2019-08/spring-25/spring-25-solution/src/main/java/ru/otus/spring/integration/App.java
+3 -3
View File
@@ -5,10 +5,10 @@ import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ConfigurableApplicationContext; import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Bean;
import org.springframework.integration.annotation.IntegrationComponentScan; import org.springframework.integration.annotation.IntegrationComponentScan;
import org.springframework.integration.channel.DirectChannel;
import org.springframework.integration.channel.QueueChannel; import org.springframework.integration.channel.QueueChannel;
import org.springframework.integration.dsl.channel.MessageChannels; import org.springframework.integration.dsl.channel.MessageChannels;
import org.springframework.messaging.PollableChannel; import org.springframework.messaging.PollableChannel;
import org.springframework.messaging.SubscribableChannel;
import org.springframework.messaging.support.MessageBuilder; import org.springframework.messaging.support.MessageBuilder;
@SpringBootApplication @SpringBootApplication
@@ -19,7 +19,7 @@ public class App {
ConfigurableApplicationContext ctx = SpringApplication.run(App.class, args); ConfigurableApplicationContext ctx = SpringApplication.run(App.class, args);
PollableChannel channel1 = ctx.getBean("channel1", PollableChannel.class); PollableChannel channel1 = ctx.getBean("channel1", PollableChannel.class);
DirectChannel channel2 = ctx.getBean("channel2", DirectChannel.class); SubscribableChannel channel2 = ctx.getBean("channel2", SubscribableChannel.class);
channel2.subscribe(System.out::println); channel2.subscribe(System.out::println);
@@ -45,7 +45,7 @@ public class App {
} }
@Bean @Bean
public DirectChannel channel2() { public SubscribableChannel channel2() {
return MessageChannels.direct("channel2").get(); return MessageChannels.direct("channel2").get();
} }
} }