2014-07-21 29 views
8

Zajmuję się JMS przy użyciu Spring i chcę utworzyć kilku jednoczesnych klientów danej kolejki, gdy uruchomi się moja aplikacja internetowa MVC.Ekwiwalent adnotacji wiosennych dla jms: listener-container

Widziałem następujące XML config gdzie indziej na SO (https://stackoverflow.com/a/6861144):

<jms:listener-container concurrency="10"> 
    <jms:listener destination="some.queue" ref="fooService" method="handleNewFoo"/> 
</jms:listener-container> 

Używam konfiguracji Wiosna w Javie, w przeciwieństwie do XML. Czy ktoś może pomóc przy składni wiosennej adnotacji?

Moja istniejący JmsConfiguration.java wygląda następująco:

@Configuration 
@ComponentScan(basePackages="net.domain.orders") 
public class JmsConfiguration { 

    @Bean 
    public JmsTemplate jmsTemplate() { 
     JmsTemplate jmsTemplate = new JmsTemplate(); 
     jmsTemplate.setDefaultDestination(new ActiveMQQueue("orders.queue")); 
     jmsTemplate.setConnectionFactory(connectionFactory()); 
     return jmsTemplate; 
    } 

    @Bean 
    public ActiveMQConnectionFactory connectionFactory() { 
     ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory(); 
     activeMQConnectionFactory.setBrokerURL("tcp://localhost:61616"); 
     return activeMQConnectionFactory; 
    } 

} 

Przeszukałem wiele przykładów ale znalazłem do tej pory są oparte na XML.

Odpowiedz

8

Chcesz DefaultMessageListenerContainer:

@Bean 
public DefaultMessageListenerContainer jmsListenerContainer() { 
    DefaultMessageListenerContainer dmlc = new DefaultMessageListenerContainer(); 
    dmlc.setConnectionFactory(connectionFactory()); 
    dmlc.setDestination(new ActiveMQQueue("orders.queue")); 

    // To schedule our concurrent listening tasks 
    dmlc.setTaskExecutor(taskExecutor()); 

    // To perform actual message processing 
    dmlc.setMessageListener(messageListener()); 

    dmlc.setConcurrentConsumers(10); 

    // ... more parameters that you might want to inject ... 
    return dmlc; 
} 

Czytaj the JMS namespace documentation informacji na temat parametrów mapowania XML parametrów Java.

Powiązane problemy