我正在制作一个简单的spring集成应用程序,它向可配置jms队列发送消息,并从不同的可配置jms队列接收消息。
我能够使用“目的地表达式”配置出站jms适配器队列,但由于这对入站适配器不起作用,我不确定如何做到这一点。
你有点误解了这个概念。
在<代码>
在<代码>
虽然可以,但您可以使用JmsDestinationPollingSource更改它。setDestination()/setDestinationName() 。您可以通过引用类似bean的[INBOUND\u CHANNEL\u ADAPTER\u ID]来实现这一点。源代码。
顺便说一句,在JMS中,您无法侦听来自一个消费者的多个目的地。因此,您的应用程序中确实必须有多个入站适配器。
如果我创建一个SFTP入站通道适配器,并使用在SFTP中配置为channel属性的通道发送一些文件。文件将传输到SFTP远程目录本地目录,还是直接从通道流到本地目录
这就是我的配置 这个想法是每3秒轮询一个目录,并根据通道向调度程序发送3条消息,以允许异步执行。然后根据消息数量聚合消息,然后发送到下一个服务激活器。第一个服务激活器将文件放在源目录中,第二个服务激活器获取聚合列表以将这些文件移动到暂存目录。 似乎发生的情况是,源文件夹跳过了一些文件,但临时文件夹确实获取了所有文件。我的猜测是,轮询器将消息发送到dispatcher通道,但当其线程池变满时,它会忽
问题内容: Spring Integration FTP中的入站通道适配器和出站通道适配器之间有什么区别?我应该使用哪一个?何时使用? 我从文档中了解到,出站可以发送任何类型的文件(例如byte [],String,java.io.File),但入站仅限于文件类型。那仅仅是区别还是其他? 问题答案: 我建议您首先阅读理论 。 任何Inbound适配器都旨在从外部系统获取数据。Outbound-放置
我是这个Spring集成和JMS的新手,我开始使用它。在这里,我想通过activemq创建普通的jms消息,并通过spring inbound适配器(消息驱动)接收它。 以下是我的spring配置文件 这是我的测试课。 } 但问题是我不能保证交货。有些时候程序不能接收消息,有些时候它成功了,但有一些警告,如 无法刷新目标“queue://MSG_QUEUE”的JMS连接,将在5000毫秒后重试,原
我目前正在一个基于Spring集成(3.0.1.RELEASE版)的应用程序上实现一个流,该应用程序需要将消息存储在JMS队列上,以便稍后提取。为此,我一直在尝试使用带有自定义选择器的Spring Integration JMS入站通道适配器,然后通过将JMSDestinationPollingSource的JMS选择器更改为作为头属性包含的某个匹配ID,从队列中提取消息。 其中一个要求是,我无法