0 Replies Latest reply on Feb 11, 2013 10:46 AM by komododave

    Camel application + Fabric MQ broker => Could not create discovery agent

    komododave

      We've successfully customised and run the  External MQ Client example on a broker group defined within a Fabric.

       

      We'd like to do the same with an external Camel application now.

       

      We believe our demo is set up equivalently to the External MQ Client, however on running we receive the following errors:

       

      mel-2) thread #3 - timer://foo Pipeline                       DEBUG Message exchange has failed: so breaking out of pipeline for exchange: Exchange[Message: Hello world.] Exception: org.springframework.jms.UncategorizedJmsException: Uncategorized exception occured during JMS processing; nested exception is javax.jms.JMSException: Error while attempting to add new Connection to the pool; nested exception is javax.jms.JMSException: Could not create Transport. Reason: java.io.IOException: Could not create discovery agent: fabric:cameltest

      mel-2) thread #3 - timer://foo TimerConsumer                  WARN  Error processing exchange. Exchange[Message: Hello world.]. Caused by: org.springframework.jms.UncategorizedJmsException - Uncategorized exception occured during JMS processing; nested exception is javax.jms.JMSException: Error while attempting to add new Connection to the pool; nested exception is javax.jms.JMSException: Could not create Transport. Reason: java.io.IOException: Could not create discovery agent: fabric:cameltest

      org.springframework.jms.UncategorizedJmsException: Uncategorized exception occured during JMS processing; nested exception is javax.jms.JMSException: Error while attempting to add new Connection to the pool; nested exception is javax.jms.JMSException: Could not create Transport. Reason: java.io.IOException: Could not create discovery agent: fabric:cameltest

       

      Here are the project files in gists:

       

      FloodTest

       

      pom.xml

       

       

      The POM has repository info removed for privacy.

       

      Note that the zookeeper.url and zookeeper.password properties are configured. Their values are known to be correct, since they are the same for our customised External MQ Client demo and that works on the same brokers without complaint.

       

      The same is true for the broker.username and broker.password properties.

       

      We would be grateful if you could advise what's causing this exception.