当前位置: 首页 > 知识库问答 >
问题:

int:拆分器不向通道发送消息以调用它们

单于智
2023-03-14
    null
<int-file:inbound-channel-adapter id="inErrorINPRm"
                                channel="errorRm" 
                                directory="in/error"
                                >
    <int:poller fixed-rate="5000" />
</int-file:inbound-channel-adapter>

<int:channel id="errorRm"></int:channel>
<int:channel id="ErrorRmMv"></int:channel>
<int:channel id="ftpINPfromError"></int:channel>

<int:splitter id="splitter" input-channel="errorRm" output-channel="ErrorRmMv"/>

<int-ftp:outbound-channel-adapter id="ftpError"
                                channel="ErrorRmMv" 
                                session-factory="ClientFactory"
                                auto-create-directory="true"
                                remote-directory="in/error"
                                >
</int-ftp:outbound-channel-adapter>

<int:header-enricher id="header-enricher-error" input-channel="ErrorRmMv" output-channel="ftpINPfromError">
    <int:header name="file_remoteDirectory" value="in/working"/>

</int:header-enricher>

<int-ftp:outbound-gateway id="gatewayRmfromError"
                          session-factory="ClientFactory"
                          expression="file_remoteDirectory"
                          request-channel="ftpINPfromError" 
                          command="rm" 
                          >
</int-ftp:outbound-gateway>

共有1个答案

齐栋
2023-03-14

拆分器没有任何东西要拆分-有效负载已经是一个文件

拆分器用于将列表拆分为每个列表元素的消息。

您需要将适配器的输入通道和头enricher设置为 -您可以将order=“1”添加到适配器中,并将order=“2”添加到enricher中,以明确调用它们的顺序。

 类似资料:
  • 我一直在四处寻找,似乎找不到我用Typescript制作的不和谐机器人的这个问题的答案。我的所有命令都放在它们自己的文件夹中,每个命令都有一个单独的文件。有助于保持井井有条。 我见过有人说 但这给了我并且 实际上,每当有人运行重启命令时,我会尝试在每个文本频道(从列表中给出)发送一条机器人消息,因为不管出于什么原因,人们总是重启机器人。我把它实现为一件有趣的事情,如果有人需要使用它,我会时不时地以

  • 正如标题中提到的,我正在尝试使用我使用discord构建的discord bot向特定频道发送消息。js和Node。js。我正在使用以下代码将消息发送到特定频道:

  • 我在Discord.py上做了一个机器人,我试图设置我想用参数发送消息的频道。代码是这样的: 当我键入通道id而不是arg1时,它可以工作,但是当我键入命令时,不和谐(!发送282772187812)它不工作,我得到这个错误:discord.ext.commands.errors.命令InvokeError:命令引发了一个异常:属性错误:'NoneType'对象没有属性'发送' 提前谢谢。

  • 我有一个Spring启动应用程序运行在heroku。我使用webSocket为特定用户向客户端和服务器发送消息。我使用Spring引导的SimpMessagingTemplate.convertAndSendToUser来发送和接收消息,当用户需要从服务器获取消息时,这种方法效果很好。我使用Heroku会话亲和力,这意味着即使我扩大了会话的数量,用户和webSocket仍然共享同一个会话。 当我需

  • 我正在使用spring-cloud-stream:1.3.0.发行版、spring-cloud-stream-binder-kafka:1.3.0.发行版开发spring引导应用程序。我使用spring integration dsl拆分文件中的行,使用beanio将行转换为json,要求将成功的json消息写入一个kafka主题,并将错误消息写入不同的kafka主题。下面是application

  • 我正在为我的Discord服务器创建一个bot。 我的服务器中有一个新的用户通道。当新用户加入时,我想向这个频道发送欢迎消息。但是,我不知道如何才能访问新用户的渠道。