package net.krg.kneip;

import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.camel.component.ActiveMQComponent;
import org.apache.activemq.pool.PooledConnectionFactory;
import org.apache.camel.component.jms.JmsConfiguration;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class AppConfig {
	
	@Bean
	public ApplicationContextProvider applicationContextProvider(){
		ApplicationContextProvider applicationContextProvider = new ApplicationContextProvider();
		return applicationContextProvider;		
	}
	
	@Bean
	public ActiveMQConnectionFactory jmsConnectionFactory(){
		ActiveMQConnectionFactory jmsConnectionFactory =  new ActiveMQConnectionFactory();
		jmsConnectionFactory.setBrokerURL("tcp://localhost:61616");
		return 	jmsConnectionFactory;
	}
	
	@Bean
	public PooledConnectionFactory pooledConnectionFactory(){
		PooledConnectionFactory pooledConnectionFactory = new PooledConnectionFactory();
		pooledConnectionFactory.setConnectionFactory(jmsConnectionFactory());
		pooledConnectionFactory.setMaxConnections(8);
		return pooledConnectionFactory;
	}
	
	@Bean
	public JmsConfiguration jmsConfig(){
		JmsConfiguration jmsConfig = new JmsConfiguration();
		jmsConfig.setConnectionFactory(pooledConnectionFactory());
		jmsConfig.setConcurrentConsumers(10);
		return jmsConfig;		
	}
	
	@Bean
	public ActiveMQComponent activeMq(){
		ActiveMQComponent activeMq = new ActiveMQComponent();
		activeMq.setConfiguration(jmsConfig());
		return activeMq;
	}

}