¸üÐÂÄÚÈÝ£º
5.0.0 M7
Òѽ« Reactive WebFlux Channel Adapter ÌáÈ¡µ½µ¥¶ÀµÄ spring-integration-webflux Ä£¿éÖУ¬ÒÔ½«»ùÓÚ Servlet µÄ MVC ÅäÖÃÓë Reactive »ù´¡Çø·Ö¿ªÀ´¡£
EmbeddedJsonHeadersMessageMapper ±»ÒýÈëÒÔÔÊÐí½«ÏûϢͷÓëÓÐÐ§ÔØºÉÒ»ÆðǶÈëÄ¿±êÐÒéµÄ°üÖУ¬¸ÃÄ¿±êÐÒé±¾Éí²»Ö§³ÖÍ·Îļþ£¬ÀýÈçÔÚ°æ±¾ 0.11.x ֮ǰµÄ TCP / IP£¬MQTT£¬AWS Kinesis ºÍ Apache Kafka¡£[code]java.util.function.Supplier ÏÖÔÚ¿ÉÒÔ×÷Ϊ MessageSource£º
@Bean
@InboundChannelAdapter(value = "myChannel")
public Supplier
return () -> counter.incrementAndGet();
}[/code]ÒѾÌí¼ÓÁËÒ»¸ö spring.integration.endpoints.noAutoStartup È«¾Ö¼¯³ÉÊôÐÔÀ´ÅäÖö˵ãµÄģʽ£¬ÕâЩģʽ²»»áÔÚÓ¦ÓóÌÐòÆô¶¯Ê±×Ô¶¯Æô¶¯¡£
Èí¼þÏêÇ飺https://spring.io/blog/2017/09/14/spring-integration-5-0-milestone-7-and-4-3-12-available
À´×Ô:¿ªÔ´ÖйúÉçÇø

