package com.megatim.apifdxweb.service.impl.camel;
|
|
import com.megatim.apifdxweb.service.impl.camel.config.CamelRouteConfiguration;
|
import com.megatim.apifdxweb.service.impl.camel.routes.in.FichierIntegrationLocalRoute;
|
import com.megatim.apifdxweb.service.impl.camel.routes.in.FichierIntegrationRemoteRoute;
|
import com.megatim.apifdxweb.service.impl.camel.routes.out.FdxStandaloneRoute;
|
import com.megatim.apifdxweb.service.impl.camel.routes.out.FileIntegrationRoute;
|
import com.megatim.apifdxweb.service.impl.camel.routes.in.TokenAuthentificationRoute;
|
import com.megatim.apifdxweb.service.impl.camel.routes.in.ReferentielIntegrationLocalRoute;
|
import com.megatim.apifdxweb.service.impl.camel.routes.in.ReferentielIntegrationRemoteRoute;
|
import com.megatim.apifdxweb.service.impl.camel.routes.in.UserActionsRoute;
|
import com.megatim.apifdxweb.service.impl.camel.routes.timers.DataIntegrationTimerRoute;
|
import com.megatim.apifdxweb.service.impl.camel.routes.timers.DeleteConsumedFilesTimer;
|
import com.megatim.apifdxweb.service.impl.camel.routes.timers.DeleteExpiredTokensTimer;
|
import com.megatim.apifdxweb.service.impl.camel.routes.timers.MergeTypeFichierBatchDataTimer;
|
import com.megatim.apifdxweb.tools.AppContext;
|
import java.util.logging.Level;
|
import java.util.logging.Logger;
|
import javax.annotation.PostConstruct;
|
import javax.annotation.Resource;
|
import javax.ejb.Singleton;
|
import javax.ejb.Startup;
|
import javax.enterprise.event.Observes;
|
import javax.inject.Inject;
|
import javax.naming.NamingException;
|
import javax.sql.DataSource;
|
import org.apache.camel.cdi.CdiCamelConfiguration;
|
import org.apache.camel.cdi.CdiCamelContext;
|
import org.apache.camel.component.jdbc.JdbcComponent;
|
import org.apache.camel.component.rabbitmq.RabbitMQComponent;
|
|
@Singleton
|
@Startup
|
public class CamelBootstrap {
|
|
@Inject
|
private CdiCamelContext camelContext;
|
|
@Resource(lookup = AppContext.JNDI_NAME)
|
private DataSource dataSource;
|
|
@Inject
|
private FdxStandaloneRoute fdxStandaloneRoute;
|
|
@Inject
|
private FileIntegrationRoute fileIntegrationRoute;
|
|
@Inject
|
private TokenAuthentificationRoute tokenAuthentificationRoute;
|
|
@Inject
|
private UserActionsRoute userActionsRoute;
|
|
@Inject
|
private FichierIntegrationLocalRoute fichierIntegrationLocalRoute;
|
|
@Inject
|
private ReferentielIntegrationLocalRoute referentielIntegrationLocalRoute;
|
|
@Inject
|
private FichierIntegrationRemoteRoute fichierIntegrationRemoteRoute;
|
|
@Inject
|
private ReferentielIntegrationRemoteRoute referentielIntegrationRemoteRoute;
|
|
@Inject
|
private DataIntegrationTimerRoute dataIntegrationTimerRoute;
|
|
@Inject
|
private MergeTypeFichierBatchDataTimer mergeBatchDataTimer;
|
|
@Inject
|
private DeleteConsumedFilesTimer deleteConsumedFilesTimer;
|
|
@Inject
|
private DeleteExpiredTokensTimer deleteExpiredTokensTimer;
|
|
@PostConstruct
|
public void init() {
|
|
try {
|
|
addDataSourceToContext();
|
addRabbitMQComponent();
|
|
loadJMSRoutes();
|
loadIntegrationRoutes();
|
loadTimers();
|
|
} catch (Exception ex) {
|
Logger.getLogger(CamelBootstrap.class.getName()).log(Level.SEVERE, null, ex);
|
}
|
|
}
|
|
private void loadIntegrationRoutes() throws Exception {
|
|
CamelRouteConfiguration camelRouteConfiguration = new CamelRouteConfiguration(AppContext.PROPERTY_FILE_PATH);
|
if (camelRouteConfiguration.hasCorrectLocalConfig()) {
|
|
loadLocalIntegrationRoutes();
|
|
if (camelRouteConfiguration.hasCorrectStfpConfig()) {
|
loadRemoteIntegrationRoutes();
|
}
|
}
|
|
}
|
|
private void loadRemoteIntegrationRoutes() throws Exception {
|
camelContext.addRoutes(fichierIntegrationRemoteRoute);
|
camelContext.addRoutes(referentielIntegrationRemoteRoute);
|
}
|
|
private void loadLocalIntegrationRoutes() throws Exception {
|
camelContext.addRoutes(fichierIntegrationLocalRoute);
|
camelContext.addRoutes(referentielIntegrationLocalRoute);
|
camelContext.addRoutes(fdxStandaloneRoute);
|
}
|
|
private void loadJMSRoutes() throws Exception {
|
camelContext.addRoutes(fileIntegrationRoute);
|
camelContext.addRoutes(tokenAuthentificationRoute);
|
camelContext.addRoutes(userActionsRoute);
|
}
|
|
private void loadTimers() throws Exception {
|
camelContext.addRoutes(dataIntegrationTimerRoute);
|
camelContext.addRoutes(mergeBatchDataTimer);
|
camelContext.addRoutes(deleteConsumedFilesTimer);
|
camelContext.addRoutes(deleteExpiredTokensTimer);
|
}
|
|
private void addDataSourceToContext() throws NamingException {
|
JdbcComponent jdbcComponent = new JdbcComponent();
|
jdbcComponent.setDataSource(dataSource);
|
camelContext.addComponent("jdbc", jdbcComponent);
|
}
|
|
private void addRabbitMQComponent() throws NamingException {
|
|
// Add RabbitMQ Component with connection details
|
RabbitMQComponent rabbitMQComponent = new RabbitMQComponent();
|
rabbitMQComponent.setHostname("localhost");
|
rabbitMQComponent.setPortNumber(5672);
|
rabbitMQComponent.setPortNumber(5672);
|
rabbitMQComponent.setUsername("guest");
|
rabbitMQComponent.setPassword("guest");
|
|
camelContext.addComponent("rabbitmq", rabbitMQComponent);
|
}
|
|
public static void configuration(@Observes CdiCamelConfiguration configuration) {
|
configuration.autoConfigureRoutes(false);
|
}
|
|
}
|
