我在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
我正在用一个新的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
在流程定义中,我一定遗漏了一些非常基本的东西。得到这个错误
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
我想从数据库中获取记录并将其转换为json。这在Spring Cloud Dataflow上运行。
我怀疑我错过了IntegrationFlow上的一些通话。
错误输出为:
Caused by: org.springframework.messaging.core.DestinationResolutionException: no output-channel or replyChannel header available
at org.springframework.integration.handler.AbstractMessageProducingHandler.sendO
我试图使用绑定来发送和接收本地动物园管理员和Kafka服务器的消息。但是,在启动Spring服务器时,我看到了以下例外情况:
Caused by: org.springframework.integration.MessageDispatchingException: Dispatcher has no subscribers
at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:154) ~[spring-integration-core-
我使用Spring将xml文件从SFTP传输到本地。我使用了Spring社区提供的代码。
主类文件
public class SFTPMain {
public static void main(String[] args) {
ConfigurableApplicationContext context =
new ClassPathXmlApplicationContext("/SftpInboundReceiveSample-context.xml", SftpInboundReceiveSample.class);
SftpInbou
当消息处理抛出异常时,我如何有效地支持JMS重新交付?
我有一个使用JMS (ActiveMQ)的流,它的connectionFactory被配置为允许n次重新传递尝试。
我希望在处理msg时发生的任何错误都会导致msg在connectionFactory配置允许的次数内被放回重新传送,然后当最大重新传送尝试用完时,传送到DLQ。像往常一样使用AMQ。
对一个相关SO问题的回答意味着我可以有一个重新抛出的errorChannel,它应该触发重新交付:
但是,由于以下原因,这种情况并没有发生:
/***
* Dispatch msgs from JMS queue to a handler u
我希望使用Spring从Unix位置读取.txt文件,而不将其复制到本地,这应该在连续模式下进行,即当一个新文件出现时,应该检测和读取该文件。
代码:
@SpringBootApplication
public class SftpJavaApplication {
public static void main(String[] args) {
new SpringApplicationBuilder(SftpJavaApplication.class)
.web(false)
我已经成功地实现了一些spring集成流程。 我希望有一个断路器,无论是为每个端点相同的,或在流程水平。我已经阅读了这个文档https://docs.spring.io/spring-integration/reference/html/handler-advice.html,但我还没有找到我的答案。 我应该使用一些AOP吗? 谢谢 G.