JmsOutboundGateway - параметры конфигурации Java отсутствуют?

Question

Я в настоящее время перевод Springs XML- в Java-Configuration. (Spring Version 4.3.4) Я сейчас борется с интеграцией Spring. JmsOutboundGateway, кажется, не поддерживает все варианты, которые поддерживаются его XML аналог:

XML:

<int-jms:outbound-gateway 
    correlation-key="JMSCorrelationID" auto-startup="true" 
    connection-factory="connectionFactory" explicit-qos-enabled="true" 
    time-to-live="60000" request-channel="myRequestChannel" request-destination="outQueue" 
    requires-reply="true" reply-channel="myResponseChannel" reply-destination="inQueue" 
    receive-timeout="20000" > 
</int-jms:outbound-gateway> 

Перевод Java:

@Bean 
public JmsOutboundGateway myGateway(){ 
    JmsOutboundGateway gateway = new JmsOutboundGateway(); 
    gateway.setConnectionFactory(connectionFactory()); 
    gateway.setCorrelationKey("JMSCorrelationID"); 
    gateway.setReplyChannel(myResponseChannel()); 
    gateway.setReplyDestination(inQueue()); 
    gateway.setReceiveTimeout(20000); 
    gateway.setExplicitQosEnabled(true); 
    gateway.setRequiresReply(true); 
    gateway.setRequestDestination(outQueue()) 
    return gateway; 
} 

именно автоматического запуска и запрос канала кажется «пропавшим». Я просто ищу их в неправильном месте или необходимы дополнительные шаги? Я что-то неправильно понял?

Заранее благодарен!

Answer 1

Все потребляемые конечные точки, созданные парсером XML, получают 2 боба; обработчик messsage и потребитель, который вызывает обработчик; потребитель зависит от типа входного канала; эти атрибуты распространяются на потребителя.

При настройке конечных точек потребления с использованием конфигурации Java добавьте @ServiceActivator в @Bean, чтобы сгенерировать потребительский компонент (используйте для запроса канал inputChannel).

Для получения дополнительной информации см. Programming Tips and Tricks.

Answer 2

Попробуйте это

@Bean 
    @ServiceActivator(inputChannel="requestChannel",outputChannel="replyChannel",autoStartup="true") 
    public JmsOutboundGateway jmsGateway(){ 
     JmsOutboundGateway gateway=new JmsOutboundGateway(); 
     gateway.setConnectionFactory(connectionFactory); 
     gateway.setRequestDestinationName("test.out"); 
     gateway.setReplyDestinationName("test.in"); 
     gateway.setCorrelationKey("JMSCorrelationID"); 
     return gateway; 
    }