通道中消息的异步推送（spring-integration）
我有一个简单的JMS主题侦听器，我希望将它与spring-integration链挂钩。
基本上，当在侦听器中接收到JMS消息时，必须将其推入链的通道中。最终，消息被处理并推送到出站通道适配器中使用。
Spring Integration文档提到了异步网关的使用，但它使用了未来。难道没有一种简单的方法可以把消息放在频道上吗？
如果有一个可以指向的例子，那就太好了。
谢谢
问候
马丁
共有1个答案
如果要在侦听器线程上运行流，只需使用常规网关（而不是异步网关）；这将允许在流因任何原因失败时回滚消息。
如果您想“触发并忘记”，可以将来自网关的请求通道设置为executorchannel-请参见此处。
-
消息推送 PDF版下载 如流开放了消息发送接口，企业可以使用这些接口让企业应用与用户间进行双向通信。 推送消息 向成员推送消息 请求方式：POST（HTTPS） 请求地址：https://api.im.baidu.com/api/message/send?access_token=ACCESS_TOKEN 请求body：（每种类型的消息请求body不同，详见消息推送格式） 参数说明： 参数 类型
-
1、离线消息 接口说明： 接口类型：回调型接口 接口作用：智齿将客服发送给用户的离线消息推送至企业预先配置好的回调地址上。 请求方法： POST 请求格式： { "type": 202, //消息类型，表示客服发送消息给客户 "partnerId": "", //企业自己的用户id "msgId": "" ,//消息id "content": "" ,//客
-
我正在将SpringWebSocket 4.2.4与sockjs和stomp一起使用，并试图在异步任务中从服务器向所有订阅者发送消息，但运气不佳 我的班级是： 但是订阅者没有得到消息 有什么帮助吗？我做错了什么：( *编辑* 我的消息代理： 当我订阅时： 谢谢 **编辑2：** 谢谢你帮我解决这个问题：）
-
我曾经能够做到这一点，但我正在努力应对0.3的期货。 下面是我从WebSocket获得的一个sink和stream: 我创建了一个在异步tokio任务之间通信的无界通道: 这是我被卡住的部分。我生成了一个异步任务，它应该连接无界接收器和接收器；我的想法是通过< code>unbounded_sender发送消息: 对于＜code＞send_all＜/code＞，错误消息显示： 而且 而且 查看文档
-
主要内容：1 invokeOneway单向发送,1.1 invokeOnewayImpl单向调用,2 sendMessageSync同步发送,2.1 invokeSync同步调用,3 sendMessageAsync异步发送消息,3.1 invokeAsync异步调用,3.2 onExceptionImpl异常处理,4 NettyClientHandler处理服务端消息,4.1 processResponseCommand处理响应,基于RocketMQ release-4.9.3，深入的介绍了P
-
用户画像+平台提供了一个全新的功能：消息推送（目前支持为小米手机用户推送消息）。用户可以根据需要创建客群，待客群生成后，点击客群右侧的“推送消息”按钮，即可设置消息推送任务。 推送消息前，需要在小米开放平台接入小米推送服务和获得应用信息（App ID，App Key，App Secret等）。小米推送服务具体请参考：https://dev.mi.com/console/appservice/pus