java - 使用 jms 向发件人发送自定义确认消息:使用 spring 集成的入站通道适配器
问题描述
一旦消费者队列客户端使用 jms 入站通道适配器接收到服装消息,我想将其作为(收到的消息)发送到生产者队列客户端。需要帮助如何使用 xml 配置来实现这个或任何替代方式。
XML 文件
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:int="http://www.springframework.org/schema/integration"
xmlns:jms="http://www.springframework.org/schema/integration/jms"
xmlns:int-file="http://www.springframework.org/schema/integration/file"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:int-xml="http://www.springframework.org/schema/integration/xml"
xmlns:int-jdbc="http://www.springframework.org/schema/integration/jdbc"
xmlns:task="http://www.springframework.org/schema/task"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/integration http://www.springframework.org/schema/integration/spring-integration.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/integration/file http://www.springframework.org/schema/integration/file/spring-integration-file.xsd
http://www.springframework.org/schema/integration/xml http://www.springframework.org/schema/integration/xml/spring-integration-xml.xsd
http://www.springframework.org/schema/integration/jdbc http://www.springframework.org/schema/integration/jdbc/spring-integration-jdbc.xsd
http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task.xsd
http://www.springframework.org/schema/integration/jms http://www.springframework.org/schema/integration/jms/spring-integration-jms.xsd">
<context:component-scan base-package="com.fcb.incoming.wires" />
<context:property-placeholder
location="classpath:application-default.properties, classpath:application-${spring.profiles.active}.properties"
ignore-unresolvable="true" />
<int:poller default="true" fixed-delay="${fcb.queue.poller.fixeddelay}"/>
<int:channel id="incomingWireChannel">
<int:queue />
</int:channel>
<int:channel id="interWireChannel">
<int:queue />
</int:channel>
<int:channel id="verifyWireChannel">
<int:queue />
</int:channel>
<jms:inbound-channel-adapter
channel="incomingWireChannel" connection-factory="${fcb.queue.mq.connection.factory}"
destination-name="${fcb.incoming.wires.req.queue}" acknowledge="client">
<int:poller fixed-delay="${fcb.queue.poller.fixeddelay}" />
</jms:inbound-channel-adapter>
<int:router input-channel="incomingWireChannel" ref="msgValidator" method="validate" />
<bean id="msgValidator" class="com.fcb.incoming.wires.validate.MessageValidator">
</bean>
解决方案
推荐阅读
- angular - 更新的组件字段在 UI 上没有改变
- java - 调用 serviceAccount.json 抛出 FileNotFoundException
- c++ - 如何为模板类的专用版本添加成员变量?
- ios - Apple 的 LLVM 中的优化错误,还是代码中的错误?
- node.js - 选择表数据时出现错误“参数类型错误、超出可接受范围或相互冲突”
- angular - 无法在 Ionic 4 中获取路由器中的参数发送
- node.js - 为什么 Postman 在我的 React 应用程序中接收到 express session cookie 但没有接收到我的 post 请求
- ffi - Nim 从 C 头文件导入 typedef
- sql - Redshift 中日期值之间的重复行
- php - PHP:使用套接字身份验证连接到 MySQL