Skip to content

Commit

Permalink
Polish "Configure ActiveMQConnectionFactory properly without spring-jms"
Browse files Browse the repository at this point in the history
  • Loading branch information
snicoll committed Aug 7, 2023
1 parent bcfaad2 commit 5e11bac
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -51,10 +51,10 @@ static class SimpleConnectionFactoryConfiguration {
@Bean(name = "jmsConnectionFactory")
@ConditionalOnProperty(prefix = "spring.jms.cache", name = "enabled", havingValue = "false")
ActiveMQConnectionFactory jmsConnectionFactory(ArtemisProperties properties, ListableBeanFactory beanFactory) {
return createConnectionFactory(properties, beanFactory);
return createJmsConnectionFactory(properties, beanFactory);
}

private static ActiveMQConnectionFactory createConnectionFactory(ArtemisProperties properties,
private static ActiveMQConnectionFactory createJmsConnectionFactory(ArtemisProperties properties,
ListableBeanFactory beanFactory) {
return new ArtemisConnectionFactoryFactory(beanFactory, properties)
.createConnectionFactory(ActiveMQConnectionFactory.class);
Expand All @@ -71,7 +71,7 @@ CachingConnectionFactory cachingJmsConnectionFactory(JmsProperties jmsProperties
ArtemisProperties properties, ListableBeanFactory beanFactory) {
JmsProperties.Cache cacheProperties = jmsProperties.getCache();
CachingConnectionFactory connectionFactory = new CachingConnectionFactory(
createConnectionFactory(properties, beanFactory));
createJmsConnectionFactory(properties, beanFactory));
connectionFactory.setCacheConsumers(cacheProperties.isConsumers());
connectionFactory.setCacheProducers(cacheProperties.isProducers());
connectionFactory.setSessionCacheSize(cacheProperties.getSessionCacheSize());
Expand Down

0 comments on commit 5e11bac

Please sign in to comment.