如何在Apache Camel路由初始化中捕獲BeanCreationException以允許我的Spring應用程序啓動？

我使用的是Apache Camel，我定義了一個路由接收來自位於2個不同服務器上的2個隊列的輸入。我希望理想地從兩臺服務器上使用，但我也希望能夠在兩個目的地之一關閉時運行該應用程序。如何在Apache Camel路由初始化中捕獲BeanCreationException以允許我的Spring應用程序啓動？

這裏是我的路線：

try { 
     from("mccdsJmsRequest1:queue:{{mccds.queues.in}}").to("direct:apolloMccdsRoute"); 
    } catch (Exception e){ 
     // debug line 
     System.out.println("Ms1 not reachable"); 
     e.printStackTrace(); 
    } 
    try { 
     from("mccdsJmsRequest2:queue:{{mccds.queues.in}}").to("direct:apolloMccdsRoute"); 
    } catch (Exception e){ 
     // debug line 
     System.out.println("Ms2 not reachable"); 
     e.printStackTrace(); 
    } 

    from("direct:apolloMccdsRoute").routeId("apolloMCCDSRoute") 
    // Main route starts here...

我在這裏宣佈我的豆子：

@Bean 
public JndiObjectFactoryBean mccdsJmsConnectionFactory1() { 
    JndiObjectFactoryBean cf = new JndiObjectFactoryBean(); 
    cf.setJndiEnvironment(prodMccdsJndiProperties.getJndi1()); 
    cf.setJndiName(jndiName1); 
    return cf; 
} 

@Bean 
public JndiObjectFactoryBean mccdsJmsConnectionFactory2(){ 
    JndiObjectFactoryBean cf = new JndiObjectFactoryBean(); 
    cf.setJndiEnvironment(prodMccdsJndiProperties.getJndi2()); 
    cf.setJndiName(jndiName2); 
    return cf; 
} 

@Inject 
private CamelContext camelContext; 

@Bean 
public JmsComponent mccdsJmsRequest1() { 
    JmsComponent ac = new JmsComponent(camelContext); 
    ac.setConnectionFactory((ConnectionFactory) mccdsJmsConnectionFactory1().getObject()); 
    ac.setConcurrentConsumers(5); 
    return ac; 
} 

@Bean 
public JmsComponent mccdsJmsRequest2(){ 
    JmsComponent ac = new JmsComponent(camelContext); 
    ac.setConnectionFactory((ConnectionFactory) mccdsJmsConnectionFactory2().getObject()); 
    ac.setConcurrentConsumers(5); 
    return ac; 
}

如果連接工廠是不可達的應用程序沒有啓動的一個。我想捕獲一個忽略異常：

o.s.b.f.s.DefaultListableBeanFactory  : Bean creation exception on non-lazy FactoryBean type check: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'mccdsJmsConnectionFactory2' defined in class path resource [ca/bell/it/spa/uim/apollo/maximo/config/mccds/ProdMccdsJmsConfiguration.class]: Invocation of init method failed; nested exception is javax.naming.CommunicationException [Root exception is java.net.ConnectException: t3://someTestServerIP: Destination unreachable; nested exception is: 
java.net.ConnectException: Connection refused (Connection refused); No available router to destination]

來源

2017-07-28 Alex

嘗試將lookupOnStartup設置爲false。（添加cf.setLookupOnStartup(false)到mccdsJmsConnectionFactory1和mccdsJmsConnectionFactory2 bean定義。）

還要檢查這個線程：http://forum.spring.io/forum/spring-projects/batch/95620-jndi-lookup

來源

2017-07-29 08:25:25 mgyongyosi

這工作。我不得不添加cf.setProxyInterface（javax.jms.ConnectionFactory.class）;或者setLookuponStartup（false）是不允許的。謝謝！ – Alex

，因爲你的try/catch塊從不路線的執行期間，執行這是行不通的。在您的代碼中，只有在應用程序啓動時，在Camel執行此代碼時，您只會在構建路由時纔會收到異常，而不管您的隊列是否存在。

取而代之，您需要確定在執行之後，當您的路由發生錯誤時正在構建之後。有很多方法可以做到這一點，但一個好的開始可能是看駱駝的Exception Clause

而替代的或許更好的選擇是利用駱駝的Load Balancer。它允許您嘗試任意數量的端點，並在發生異常時失敗轉移到下一個端點。

來源

2017-07-28 18:51:09

如何在Apache Camel路由初始化中捕獲BeanCreationException以允許我的Spring應用程序啓動？

回答

相關問題