@Configuration
@EnableJms
public class JmsConfig {
@Bean
public ConnectionFactory connectionFactory() {
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
connectionFactory.setSessionAcknowledgeMode(Session.AUTO_ACKNOWLEDGE);
return connectionFactory;
}
}
@Configuration
@EnableJms
public class JmsConfig {
@Bean
public ConnectionFactory connectionFactory() {
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
connectionFactory.setSessionAcknowledgeMode(Session.CLIENT_ACKNOWLEDGE);
return connectionFactory;
}
}
@Component
public class MyMessageListener implements MessageListener {
@Override
public void onMessage(Message message) {
try {
message.acknowledge();
} catch (JMSException e) {
}
}
}
