官方Spring Integration DSL参考文档在https://docs.spring.io/spring-integration/reference/html/dsl.html#java-dsl的第一部分中提供了以下代码示例 @Configuration
@EnableIntegration
public class MyConfiguration {
@Bean
public AtomicInteger integerSource() {
return new AtomicInteger();
}
@Bean
publ
我在5.1.3中使用JMS入站网关进行了测试
但我犯了以下错误:
Caused by: org.springframework.integration.MessageDispatchingException: Dispatcher has no subscribers
at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:138) ~[spring-integration-core-5.1.3.RELEASE.jar:5.1.3.REL
在流程定义中,我一定遗漏了一些非常基本的东西。得到这个错误
is a one-way 'MessageHandler' and it isn't appropriate to configure 'outputChannel'. This is the end of the integration flow.
我的理论是,由于适配器是单向组件,因此在流程的句柄步骤中没有生成输出。这就是为什么这会导致运行时错误。但是,不知道如何定义这个简单的流。
代码:
@Autowired
private JmsMessagingTemplate jmsMessagin
我正在用一个新的spring集成版本测试我现有的应用程序。不幸的是,我得到了一个意外的异常,如下所示:
Caused by: java.lang.UnsupportedOperationException: null
at org.springframework.integration.dsl.StandardIntegrationFlow.configure(StandardIntegrationFlow.java:64) ~[spring-integration-java-dsl-1.2.1.RELEASE.jar:na]
at org.springframework.in
是否可以将多方法接口用作只有一个通道的网关?
我使用了spring integration 4.1.2.RELEASE。
不同的方法调用其他服务器上不同的API方法。
我的配置/源代码如下所示:
网关:
@MessagingGateway
public interface TestService
{
@Gateway(requestChannel="testRequestChannel")
public Test findTestById( String test );
@Gateway(requestChannel="testRequestChannel
我的需求几乎和这里的中描述的一样。即,在文件生成器Spring批处理完成之后触发Spring集成程序。我在这里主要使用Spring Integration示例:和。我观察到的是,测试程序将配置文件初始化为ClassPathXmlApplicationContext,然后根据需要设置一些值。忽略配置,程序的症结似乎是以下四行:
final File file = new File(sourceFileName);
final Message<File> message = MessageBuilder.withPayload(file).build();
final MessageC
我正在尝试将下面的spring集成示例转换为Java版本。
我们需要稍微修改这个项目的版本才能在生产环境中工作。我的问题是,在启动应用程序时,我一直会得到以下异常。
org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'httpInboundGateway' defined in org.springframework.platform.proxy.TunnelApplication: Bean instantiation via factory metho
我使用的是Spring Cloud Streams和com.azure.spring:azure-spring-cloud-stream-binder-eventhubs:2.8.0,,我使用的是Supplier。
它适用于Spring boot 2.3.12.RELEASE。
但是,如果我转到spring boot版本>= 2.4.0,则会得到以下错误:
An attempt was made to call a method that does not exist. The attempt was made from the following location:
org.