1

我是 Spring 新手,我正在使用Citrus Framework。我将尝试动态地更改inbound-channel-adapter destination变量。这个变量位于属性文件中并且一直在变化。

目前我正在使用一个AtomicReference并且我在java代码中改变了它的值

context.xml

    <bean id="targetDir" class="java.util.concurrent.atomic.AtomicReference">
        <constructor-arg value="${output.path.temp}"/>
    </bean>

    <file:inbound-channel-adapter id="fileInboundAdapter" auto-create-directory="false"
        channel="fileChannel" directory="file:@targetDir.get()" auto-startup="false"
        filename-pattern="*.xml">
        <si:poller cron="0 * * * * ?"/>
    </file:inbound-channel-adapter>

在java文件中:

SourcePollingChannelAdapter fileInboundAdapter = (SourcePollingChannelAdapter)context.getApplicationContext().getBean("fileInboundAdapter");
if (fileInboundAdapter.isRunning()) {
    fileInboundAdapter.stop();

    @SuppressWarnings("unchecked")
    AtomicReference<String> targetDir = (AtomicReference<String>)     
    context.getApplicationContext().getBean("targetDir", AtomicReference.class);
    targetDir.set(strOutPath[0]+"/"+strOutPath[1]+"/"+strOutPath[2]+"/"+strOutPath[3]+"/"); 
    fileInboundAdapter.start();
}

这个解决方案不起作用......有人有任何解决方案吗?

非常感谢。

4

1 回答 1

2

确实如此。因为你AtomicReference对目标没有影响directory

你这样做directory="file:@targetDir.get()"。这根本不正确,因为这String将尝试转换为File对象。如果你想在这里使用 SpEL,它应该是这样的:

directory="#{targetDir.get()}"

没有任何file:前缀。

无论如何,它没有帮助,因为 SpEL 只在 applicationContext strtup 评估一次。

由于您要directory在运行时更改您应该FileReadingMessageSource.setDirectory从您的服务中使用。像这样的东西:

SourcePollingChannelAdapter fileInboundAdapter = (SourcePollingChannelAdapter)context.getApplicationContext().getBean("fileInboundAdapter");
if (fileInboundAdapter.isRunning())
    fileInboundAdapter.stop();

    FileReadingMessageSource source = (FileReadingMessageSource) context.getApplicationContext().getBean("fileInboundAdapter.source");    
    source.setDirectory(new File(strOutPath[0]+"/"+strOutPath[1]+"/"+strOutPath[2]+"/"+strOutPath[3]+"/")); 
    fileInboundAdapter.start();
}

并摆脱它AtomicReference

directory从一开始,您就可以直接对属性使用属性占位符。

于 2015-02-10T10:08:28.067 回答