将队列的消息记录到文本文件

Question

我有一个弹簧下集成xml，其中我发送消息到队列中，并且该消息最终被消耗并显示在控制台上，但现在我想定制它可以说那些消息是在文本文件中应该最终写入（换句话说，这些消息需要被记录）并且该文本文件应该保存在我的文件夹的C：驱动器中文件的名称是messageslog.txt

请告知如何我可以在春天集成本身添加这样的功能，以acheieve这个功能我已经知道，在春天集成东西像文件出站通道适配器将帮助

下面是我的sprin克integtaion 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:context="http://www.springframework.org/schema/context" 
    xsi:schemaLocation="http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms-3.0.xsd 
      http://www.springframework.org/schema/integration http://www.springframework.org/schema/integration/spring-integration-2.0.xsd 
      http://www.springframework.org/schema/integration/jms http://www.springframework.org/schema/integration/jms/spring-integration-jms-2.0.xsd 
      http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd 
      http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd"> 

    <int:poller id="poller" default="true"> 
     <int:interval-trigger interval="200" /> 
    </int:poller> 

    <int:channel id="output"> 
     <int:queue capacity="10" /> 
    </int:channel> 

    <bean id="tibcoEMSJndiTemplate" class="org.springframework.jndi.JndiTemplate"> 
     <property name="environment"> 
      <props> 
       <prop key="java.naming.factory.initial">com.tibco.tibjms.naming.TibjmsInitialContextFactory</prop> 
       <prop key="java.naming.provider.url">tcp://labc.net:7033</prop> 
       <prop key="java.naming.security.principal">wer</prop> 
       <prop key="java.naming.security.credentials">wer</prop> 
      </props> 
     </property> 
    </bean> 

    <bean id="tibcoEMSConnFactory" class="org.springframework.jndi.JndiObjectFactoryBean"> 
     <property name="jndiTemplate"> 
      <ref bean="tibcoEMSJndiTemplate" /> 
     </property> 
     <property name="jndiName"> 
      <value>GenericConnectionFactory</value> 
     </property> 
    </bean> 

    <bean id="tibcosendJMSTemplate" class="org.springframework.jms.core.JmsTemplate"> 
     <property name="connectionFactory"> 
      <ref local="tibcoEMSConnFactory" /> 
     </property> 
     <property name="defaultDestinationName"> 
      <value>test.data</value> 
     </property> 
     <property name="pubSubDomain"> 
      <value>false</value> 
     </property> 
     <property name="receiveTimeout"> 
      <value>120000</value> 
     </property> 
    </bean> 

    <int:channel id="input"> 

    </int:channel> 

    <jms:outbound-channel-adapter channel="input" 
     destination-name="test.data" connection-factory="tibcoEMSConnFactory" /> 

    <jms:message-driven-channel-adapter 
     channel="output" destination-name="test.data" connection-factory="tibcoEMSConnFactory" /> 

</beans> 

Answer 1

• 变化input到<publish-subscribe-channel/>
• 与order="2"

设置order="1"的JMS出站通道适配器

订阅文件的出站信道适配器（模式= APPEND）上默认情况下，只有发送到JMS成功时才会调用文件适配器。

你似乎没有消费者output;然而，为了避免消息丢失，output应该不是是一个QueueChannel，只是删除<queue/>元素（你不需要一个轮询）。