JMS Asnchron kosumieren

Diskutiere JMS Asnchron kosumieren im Allgemeines EE Bereich.
NicoDeluxe

NicoDeluxe

Hallöle

ich hab untenstehenden Consumer eines Queries und eine Factory. Im Queue sind 40.000 Messages, das abarbeiten passiert aber nicht sehr schnell (er holt die Message und macht nur ein println)

Er macht pro Sek nur ca 10-20 Messages. Ist das richtig asynch konfiguriert?

Code:
 @Bean
    public JmsListenerContainerFactory<?> queueFactory(ConnectionFactory connectionFactory,
                                                       DefaultJmsListenerContainerFactoryConfigurer configurer) {
        DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
        configurer.configure(factory, connectionFactory);
        factory.setMessageConverter(messageConverter());
        factory.setPubSubDomain(false);
        return factory;
    }
Code:
@JmsListener(destination = "product_update_qty_queue", containerFactory = "queueFactory")
    public void listen(@Payload ProductData productData, MessageHeaders headers, Message message) throws JMSException {
        String convertedMessage = ((TextMessage) message).getText();
        //System.out.....
}
 
NicoDeluxe

NicoDeluxe

Auch nach dem heutigen TAg mit viiiiiiielen Versuchen, bekomme ich es nicht hin, dass er das schneller macht! Ich werde nun einen TaskExecutor einbauen und hoffe, dass es dann klappt mehr gleichzeitig zu verarbeiten.
 
K

KSG9|sebastian

Du kannst an der DefaultJmsListenerContainerFactory Concurrency konfigurieren, alternativ via Task-Executor
 
Thema: 

JMS Asnchron kosumieren

Passende Stellenanzeigen aus deiner Region:
Anzeige

Neue Themen

Anzeige

Anzeige
Oben