我有一个非常简单的集成流程:
<int:gateway id="integrationGateway"
service-interface="com.wheeler.fits.returns.messaging.MessagingGateway"
default-request-channel="transactionMatcher">
<int:method name="publishReturnedTransaction" request-channel="transactionMatcher"/>
</int:gateway>
<int:channel id="transactionMatcher"/>
<int:service-activator input-channel="transactionMatcher" requires-reply="true">
<bean class="com.wheeler.fits.returns.domain.MatchTransactionToOriginal">
<constructor-arg ref="achTransactionMapper"/>
<constructor-arg ref="bankTransactionDao"/>
<constructor-arg ref="clientMapper"/>
<constructor-arg ref="oldAchTransactionMapper"/>
</bean>
</int:service-activator>
服务激活器调用的方法尝试将消息中的数据与数据库中的某些数据相匹配。如果是,则返回匹配的数据。如果没有,它将返回null
。
如果我没有设置必需回复为真,那么null
回复似乎会从集成流中消失,导致服务接口永远不会返回,从而导致应用程序挂起。如果我设置了必需回复为真,我至少会得到一个异常,但是应用程序仍然挂起,因为网关的服务接口永远不会返回:
[org.springframework.integration.handler.ReplyRequiredException: No reply produced by handler 'org.springframework.integration.config.ServiceActivatorFactoryBean#0', and its 'requiresReply' property is set to true.,
spring集成参考资料中似乎没有记录这种行为。我希望我的服务激活器将null
传递回网关,以便网关可以使用null
进行回复。
这是我的网关服务接口:
public interface MessagingGateway {
RawMessageData publishReturnedTransaction(ReturnedTransactionData returnedTransactionData) throws ChannelPublishException;
}
如何让它像处理任何其他消息一样处理null
?
在Service Activator(服务激活器)一章中有一些关于此问题的信息:
Service Activator是不需要生成回复消息的组件之一。如果您的方法返回null或返回类型为空,Service Activator将在方法调用后退出,没有任何信号。此行为可以由AbstractReplyProducingMessageHandler.requiresReply选项控制,在使用XML命名空间配置时,该选项也显示为要求-回复。如果标志设置为true且方法返回null,则会引发Reply必需异常。
您也可以在JIRA中找到一些讨论。
一般来说,null
负载在消息传递中没有意义,必须像在ReplyRequiredException
的情况下一样,将其视为终端信号或错误。
对于您的用例,您应该考虑从您的服务激活器返回一些<代码> RWMasigaDATA<代码>实例,您可以将其视为<代码> null <代码>。
我有一个队列通道和一个带有轮询器的服务激活器,轮询器从该队列中读取数据。我希望配置为“我希望50个线程轮询该队列,每次轮询并返回消息时,在此线程上调用服务激活器指向的服务。” 该服务没有异步注释,但无状态,可以以并发方式安全运行。 下面的方法能做到吗?有没有其他首选的方法来实现这一点?
我在一个简单的POJO中配置了一个服务激活器,我想将其转换为Java DSL。 现在,我的Java DSL如下所示, 有一个带有服务激活器的POJO, 在XML中,相应的配置如下所示, 如何在Java DSL中调用ServiceActivator方法?我正在考虑使用,但参数应该是什么 在使用Java DSL时,是否有空通道的概念?如果是,我们如何指定
我有一个Web服务,每个版本将有多个版本和多个类。我想在启动时动态创建服务激活器,这样我就可以减少配置量,从而更容易维护。开发人员可以放入一个新类,SI会自动拾取它。 我编码了一个Application Listener: 稍后在路由器中,我有以下代码: 但当路由器尝试路由时,我会出现以下错误: 我该怎么做?我需要动态创建服务激活器,并在以后将消息路由到这些激活器。 没有办法在ServiceAct
我试图从Spring集成示例中转换“Hello World示例”(https://github.com/spring-projects/spring-integration-samples/tree/master/basic/helloworld)从XML到Java配置(使用注释也是如此)。 配置类如下所示: 为了测试它,我使用示例项目提供的: 我在控制台中看到“Message payload:t
带有服务工作者的网站,托管https://121eddie.github.io/并在Chrome 66.0中运行。3359.181 /索引。html在每次加载时正确跟踪以下注册 }); 第一次运行时,/serviceWorker。js执行“激活”事件,正确获取缓存名称并缓存文件 在第二次运行时,不会触发“激活”(没有日志跟踪,没有获取)。 在第三次运行中,甚至不再触发“抓取”。这意味着脱机请求不被
我正在尝试创建一个TCP服务器,该服务器在端口5002上接受来自外部程序的消息。但是,它不接收来自外部程序的消息。 为了验证我的TCP服务器是否正常工作,我像这样使用了telnet,程序确实收到了文本“hello”。 设置wireshark时,我可以看到计算机正在端口5002上接收来自外部程序(我期待)的消息。为什么我的程序无法接收这些消息? 关于最终解决方案的最新情况: 由于负载没有停止线,我必