將JMS隊列XML配置轉換爲Java配置

Question

爲了學習彈簧集成，我一直在試圖創建一個簡單的，有彈性的日誌處理器。我也想堅持使用java配置方法。

我一直在困難的時間翻譯現有的XML配置，主要是因爲對於一般的春天來說太新了。

在a question on the spring forums Gary Russell提出了一個類似的解決方案，使用帶有簡單XML配置的publish-subscribe + JMS模型。

我一直在試圖將他的建議翻譯成Java配置，但我堅持。即我不確定適用於出站通道適配器，服務激活器或如何正確設置消息順序的適當實體。

這裏是加里的XML配置：

<int-file:inbound-channel-adapter id="dispatcher" 
     directory="spool" 
     channel="fileChannel"> 
     <int:poller fixed-delay="2000"> 
      <int:transactional/> 
     </int:poller> 
    </int-file:inbound-channel-adapter> 

    <int:channel id="fileChannel" /> 

    <int-file:file-to-string-transformer input-channel="fileChannel" output-channel="dispatchChannel" /> 

    <int:publish-subscribe-channel id="dispatchChannel" /> 

    <int-jms:outbound-channel-adapter id="dispatcherJms" channel="dispatchChannel" order="1" 
     connection-factory="connectionFactory" 
     destination="dispatcher.queue" /> 

    <!-- If JMS Send was successful, remove the file (within the transaction)--> 
    <int:service-activator input-channel="dispatchChannel" order="2" 
     output-channel="nullChannel" 
        expression="headers.file_originalFile.delete()"> 

    <bean id="transactionManager" class="org.springframework.jms.connection.JmsTransactionManager"> 
     <property name="connectionFactory" ref="connectionFactory"/> 
    </bean> 

UPDATE

基礎上的評論下面我已經更新了Java的配置。

但是，我仍然收到錯誤，並且很可能不瞭解實體之間的流程和連接，但原始問題已得到解答。

@Bean 
@Transactional 
@InboundChannelAdapter(channel = "dispatchChannel", poller = @Poller(fixedDelay = "2000")) 
public MessageSource<?> dispatcher() { 
    CompositeFileListFilter<File> filters = new CompositeFileListFilter<>(); 
    filters.addFilter(new SimplePatternFileListFilter(sourceFilenamePattern)); 
    //filters.addFilter(persistentFilter()); 

    FileReadingMessageSource source = new FileReadingMessageSource(); 
    source.setAutoCreateDirectory(true); 
    source.setDirectory(new File(sourceDirectory)); 
    source.setFilter(filters); 

    return source; 
} 

@Bean 
public MessageChannel fileChannel() { 
    return new DirectChannel(); 
} 

@Bean 
public PublishSubscribeChannel dispatchChannel() { 
    return new PublishSubscribeChannel(); 
} 

@Autowired 
JmsTemplate jmsTemplate; 

@Autowired 
ConnectionFactory connectionFactory; 

@Bean 
@Order(1) 
@ServiceActivator(inputChannel = "dispatchChannel") 
public MessageHandler dispatcherJmsOutboundChannelAdapter(Message<File> message) { 
    JmsSendingMessageHandler handler = new JmsSendingMessageHandler(jmsTemplate); 
    handler.setDestinationName("dispatcher.queue"); 

    return handler; 
} 

@Bean 
@Order(2) 
@ServiceActivator(inputChannel = "dispatchChannel") 
public void removeFile(Message<?> message) { 
    //message.getHeaders().get(FileHeaders.ORIGINAL_FILE, File.class).delete(); 
    log.info("delete"); 
} 

@Bean 
public JmsTransactionManager transactionManager(ConnectionFactory connectionFactory) { 
    return new JmsTransactionManager(connectionFactory); 
} 

我使用的是spring啓動和幾個啓動組件，比如activemq。我已經爲JmsListenerContainerFactory和@JmsListener添加了@Bean，但我不確定這些是否真的有必要。

直到將@EnableJms添加到我的配置文件以及@Autowiring jmstemplate和connectionfactory之前，我無法運行任何程序。

運行時，現在我收到的錯誤是：

org.springframework.beans.factory.NoSuchBeanDefinitionException: 
    No qualifying bean of type [org.springframework.messaging.Message] found for dependency 
[org.springframework.messaging.Message<?>]: 
    expected at least 1 bean which qualifies as autowire candidate for this dependency. 
Dependency annotations: {} 

Answer 1

這一個

<int:service-activator input-channel="dispatchChannel" order="2" 
    output-channel="nullChannel" 
       expression="headers.file_originalFile.delete()"> 

很簡單在Java中：

@ServiceActivator(inputChannel = "dispatchChannel") 
public void removeFile(Message<?> message) { 
    message.getHeaders().get(FileHeaders.ORIGINAL_FILE, File.class).delete(); 
} 

和

<int-jms:outbound-channel-adapter> 

被翻譯成這樣：

@Bean 
@ServiceActivator(inputChannel = "dispatchChannel") 
public MessageHandler dispatcherJmsOutboundChannelAdapter() { 
    JmsSendingMessageHandler handler = 
       new JmsSendingMessageHandler(new JmsTemplate(this.connectionFactory)); 
    handler.setDestinationName("dispatcher.queue"); 
    return handler; 
} 

注意這個段落在Reference Manual。

Answer 2

拼圖的最後一塊是FileWritingMessageHandler

@Bean 
public FileWritingMessageHandler fileWritingMessageHandler() { 
    SpelExpressionParser parser = new SpelExpressionParser(); 
    Expression expression = parser.parseExpression("headers.file_originalFile.delete()"); 
    FileWritingMessageHandler fileWritingMessageHandler = new FileWritingMessageHandler(expression); 
    fileWritingMessageHandler.setOutputChannel(new NullChannel()); 
    fileWritingMessageHandler.setDeleteSourceFiles(true); 
    return fileWritingMessageHandler; 
}