John, Can you use curl and verify the URI and credentials?
http://hg.rabbitmq.com/rabbitmq-management/raw-file/rabbitmq_v2_2_0/priv/www-api/help.html On Wed, Jul 20, 2016 at 12:52 PM, souciance < souciance.eqdam.ras...@gmail.com> wrote: > There is a rest API to connect and off course the RabbitMQ webgui is good > too. > > On Wed, Jul 20, 2016 at 7:50 PM, Ranx [via Camel] < > ml-node+s465427n5785285...@n5.nabble.com> wrote: > > > I've not used RabbitMQ so can't give much insight there but wonder if you > > have an independent way to verify the connection: > > > > rabbitmq://localhost:5672/rabbit > > > > Is there a rabbitmq equivalent of curl to connect? > > > > On Wed, Jul 20, 2016 at 12:40 PM, Kammer, John - US <[hidden email] > > <http:///user/SendEmail.jtp?type=node&node=5785285&i=0>> > > wrote: > > > > > Friends and colleagues, > > > > > > I have been tasked to implement a message route from an external > > RabbitMQ > > > provider into our Camel-ActiveMQ message service. I am having some > > > difficulties getting the rabbit part set up and working within Camel. I > > get > > > the feeling I am close, which may just be an illusion - but I am > > currently > > > stuck and would appreciate any insight more experienced Camel and > Rabbit > > > users could provide. > > > > > > At the moment I am suffering a ConnectionException for a refused > > > connection. It's unclear to me whether there are credentials that need > > to > > > be passed somewhere and if so where they are supposed to be defined. In > > the > > > JMS section we're using a truststore as you can see in the listings > > below. > > > Is the same required for the rabbit and if so how/where is that to be > > > configured? > > > > > > FWIW: We are using camel v2.15.5 and camel-rabbitmq v2.15.6 > > > > > > Here's the error I am currently seeing: > > > 2016-07-20 16:07:17,988 [Camel (camel-1) thread #3 - RabbitMQConsumer] > > > INFO org.apache.camel.component.rabbitmq.RabbitMQConsumer - Connection > > > failed, will retry in {}100ms > > > java.net.ConnectException: Connection refused > > > at java.net.PlainSocketImpl.socketConnect(Native Method) > > > at > > > > > > java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350) > > > > > at > > > > > > java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206) > > > > > at > > > > > > java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188) > > > at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392) > > > at java.net.Socket.connect(Socket.java:589) > > > at > > > > > > com.rabbitmq.client.impl.FrameHandlerFactory.create(FrameHandlerFactory.java:32) > > > > > at > > > > > > com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:811) > > > > > at > > > > > > com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:767) > > > > > at > > > > > > com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:887) > > > > > at > > > > > > org.apache.camel.component.rabbitmq.RabbitMQEndpoint.connect(RabbitMQEndpoint.java:195) > > > > > at > > > > > > org.apache.camel.component.rabbitmq.RabbitMQConsumer.openConnection(RabbitMQConsumer.java:68) > > > > > at > > > > > > org.apache.camel.component.rabbitmq.RabbitMQConsumer.access$500(RabbitMQConsumer.java:36) > > > > > at > > > > > > org.apache.camel.component.rabbitmq.RabbitMQConsumer$StartConsumerCallable.call(RabbitMQConsumer.java:323) > > > > > at > > > > > > org.apache.camel.component.rabbitmq.RabbitMQConsumer$StartConsumerCallable.call(RabbitMQConsumer.java:304) > > > > > at java.util.concurrent.FutureTask.run(FutureTask.java:266) > > > at > > > > > > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) > > > > > at > > > > > > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) > > > > > at java.lang.Thread.run(Thread.java:745) > > > > > > And what I think are the relevant parts of the configuration... > > > > > > <!-These are commented out at present but were tried with similar > > results > > > earlier > > > <route id="rabbit_route"> > > > <from uri="rabbitmq://localhost:5672/rabbit?sslProtocol=true"/> > > > <to uri="{{data_dir}}/?fileName=rabbitMessage" /> > > > </route> > > > <route id="rabbit_route"> > > > <from > > > > > > uri="rabbitmq://localhost:5672/rabbit?connectionFactory=#rabbitConnectionFactory"/> > > > > > <to uri="{{data_dir}}/?fileName=rabbitMessage" /> > > > </route> > > > --> > > > > > > <route id="rabbit_route"> > > > <from uri="rabbitmq://localhost:5672/rabbit"/> > > > <to uri="{{data_dir}}/?fileName=rabbitMessage" /> > > > </route> > > > ... > > > <!--- JMS/Rabbit beans.... ---> > > > <!-- ############################ Local JMS Configuration > > > ##################### --> > > > <bean id="localConnFactory" > > > class="org.apache.activemq.ActiveMQSslConnectionFactory"> > > > <property name="trustAllPackages" value="true" /> > > > <property name="brokerURL" value="${local.broker.url}" /> > > > <property name="trustStore" value="${local.truststore.file}" /> > > > <property name="trustStorePassword" > > > value="${local.truststore.password}" /> > > > </bean> > > > <bean id="localPooledConnFactory" > > > class="org.apache.activemq.pool.PooledConnectionFactory" > > > init-method="start" destroy-method="stop"> > > > <property name="connectionFactory" ref="localConnFactory" /> > > > <property name="maxConnections" value="${local.max.conn}" /> > > > <property name="idleTimeout" value="${local.idle.timeout}" /> > > > </bean> > > > <bean id="localConfig" > > > class="org.apache.camel.component.jms.JmsConfiguration"> > > > <property name="connectionFactory" ref="localPooledConnFactory" /> > > > <property name="transacted" value="false" /> > > > </bean> > > > <bean id="localJms" > > > class="org.apache.activemq.camel.component.ActiveMQComponent"> > > > <property name="configuration" ref="localConfig" /> > > > </bean> > > > > > > <bean id="rabbitmq" > > > class="org.apache.camel.component.rabbitmq.RabbitMQComponent"> > > > </bean> > > > > > > From the logs... > > > > > > ... > > > 2016-07-20 16:22:37,603 [main] DEBUG > > > org.springframework.context.support.FileSystemXmlApplicationContext - > > Bean > > > factory for > > > > > > org.springframework.context.support.FileSystemXmlApplicationContext@48524010 > : > > > > > > > > org.springframework.beans.factory.support.DefaultListableBeanFactory@73c60324 > : > > > > > defining beans > > > > > > [org.springframework.context.annotation.internalConfigurationAnnotationProcessor,org.springframework.context.annotation.internalAutowiredAnnotationProcessor,org.springframework.context.annotation.internalRequiredAnnotationProcessor,org.springframework.context.annotation.internalCommonAnnotationProcessor,org.springframework.context.annotation.internalPersistenceAnnotationProcessor,bridgePropertyPlaceholder,audit_log,producerTemplate,org.apache.camel.spring.CamelRedeliveryPolicyFactoryBean#0,defaultEH,consumerTemplate,camel-1:beanPostProcessor,camel-1,broadcastProcessor,fileWrapper,timeUtil,...,redeliveryPolicyConfig,localConnFactory,localPooledConnFactory,localConfig,localJms,rabbitmq]; > > > > > root of factory hierarchy > > > ... > > > 2016-07-20 16:22:37,756 [main] INFO > > > org.springframework.beans.factory.support.DefaultListableBeanFactory - > > > Pre-instantiating singletons in > > > > > > org.springframework.beans.factory.support.DefaultListableBeanFactory@73c60324 > : > > > > > defining beans > > > > > > [org.springframework.context.annotation.internalConfigurationAnnotationProcessor,org.springframework.context.annotation.internalAutowiredAnnotationProcessor,org.springframework.context.annotation.internalRequiredAnnotationProcessor,org.springframework.context.annotation.internalCommonAnnotationProcessor,org.springframework.context.annotation.internalPersistenceAnnotationProcessor,bridgePropertyPlaceholder,audit_log,producerTemplate,org.apache.camel.spring.CamelRedeliveryPolicyFactoryBean#0,defaultEH,consumerTemplate,camel-1:beanPostProcessor,camel-1,broadcastProcessor,fileWrapper,timeUtil,...,redeliveryPolicyConfig,localConnFactory,localPooledConnFactory,localConfig,localJms,rabbitmq,org.springframework.context.annotation.ConfigurationClassPostProcessor.importAwareProcessor]; > > > > > root of factory hierarchy > > > ... > > > 2016-07-20 16:22:39,278 [main] DEBUG > > org.hibernate.impl.SessionFactoryImpl > > > - instantiating session factory with properties: {java.vendor=Oracle > > > Corporation, sun.java.launcher=SUN_STANDARD, > > > javax.net.ssl.trustStorePassword=paXXXXrd, > > sun.management.compiler=HotSpot > > > 64-Bit Tiered Compilers, os.name=Linux, > > > > > > sun.boot.class.path=/apps/java/jre1.8.0_60/lib/resources.jar:/apps/java/jre1.8.0_60/lib/rt.jar:/apps/java/jre1.8.0_60/lib/sunrsasign.jar:... > > > > > java.specification.version=1.8, > > > javax.net.ssl.trustStore=/apps/configs/keys/client.ts, > > > hibernate.show_sql=false} > > > ... > > > [main] DEBUG > > > org.springframework.beans.factory.support.DefaultListableBeanFactory - > > > Finished creating instance of bean 'localPooledConnFactory' > > > [main] DEBUG > > > org.springframework.beans.factory.support.DefaultListableBeanFactory - > > > Creating shared instance of singleton bean 'localConfig' > > > [main] DEBUG > > > org.springframework.beans.factory.support.DefaultListableBeanFactory - > > > Creating instance of bean 'localConfig' > > > [main] DEBUG > > > org.springframework.beans.factory.support.DefaultListableBeanFactory - > > > Eagerly caching bean 'localConfig' to allow for resolving potential > > > circular references > > > [main] DEBUG > > > org.springframework.beans.factory.support.DefaultListableBeanFactory - > > > Returning cached instance of singleton bean 'localPooledConnFactory' > > > [main] DEBUG > > > org.springframework.beans.factory.support.DefaultListableBeanFactory - > > > Finished creating instance of bean 'localConfig' > > > [main] DEBUG > > > org.springframework.beans.factory.support.DefaultListableBeanFactory - > > > Creating shared instance of singleton bean 'localJms' > > > [main] DEBUG > > > org.springframework.beans.factory.support.DefaultListableBeanFactory - > > > Creating instance of bean 'localJms' > > > [main] DEBUG > > > org.springframework.beans.factory.support.DefaultListableBeanFactory - > > > Eagerly caching bean 'localJms' to allow for resolving potential > > circular > > > references > > > [main] DEBUG > > > org.springframework.beans.factory.support.DefaultListableBeanFactory - > > > Returning cached instance of singleton bean 'localConfig' > > > [main] DEBUG > > > org.springframework.beans.factory.support.DefaultListableBeanFactory - > > > Finished creating instance of bean 'localJms' > > > [main] DEBUG > > > org.springframework.beans.factory.support.DefaultListableBeanFactory - > > > Creating shared instance of singleton bean 'rabbitmq' > > > [main] DEBUG > > > org.springframework.beans.factory.support.DefaultListableBeanFactory - > > > Creating instance of bean 'rabbitmq' > > > [main] DEBUG > > > org.springframework.beans.factory.support.DefaultListableBeanFactory - > > > Eagerly caching bean 'rabbitmq' to allow for resolving potential > > circular > > > references > > > [main] DEBUG > > > org.springframework.beans.factory.support.DefaultListableBeanFactory - > > > Finished creating instance of bean 'rabbitmq' > > > ... > > > [main] DEBUG org.apache.camel.core.xml.AbstractCamelContextFactoryBean > - > > > Found JAXB created routes: > > > [...Route(rabbit_route)[[From[rabbitmq://localhost:5672/rabbit]] -> > > > [To[{{data_dir}}/?fileName=rabbitMessage]]],... > > > ... > > > [main] DEBUG org.apache.camel.impl.DefaultComponentResolver - Found > > > component: rabbitmq in registry: > > > org.apache.camel.component.rabbitmq.RabbitMQComponent@6dcbbb49 > > > [main] DEBUG org.apache.camel.management.DefaultManagementAgent - > > > Registered MBean with ObjectName: > > > org.apache.camel:context=camel-1,type=components,name="rabbitmq" > > > [main] DEBUG org.apache.camel.impl.DefaultComponent - Creating endpoint > > > uri=[rabbitmq://localhost:5672/rabbit], path=[localhost:5672/rabbit] > > > [main] DEBUG org.apache.camel.component.rabbitmq.RabbitMQComponent - > > > Creating RabbitMQEndpoint with host localhost:5672 and exchangeName: > > rabbit > > > [main] DEBUG org.apache.camel.spring.SpringCamelContext - > > > rabbitmq://localhost:5672/rabbit converted to endpoint: > > > Endpoint[rabbitmq://localhost:5672/rabbit] by component: > > > org.apache.camel.component.rabbitmq.RabbitMQComponent@6dcbbb49 > > > [main] DEBUG org.apache.camel.management.DefaultManagementAgent - > > > Registered MBean with ObjectName: > > > > > > org.apache.camel:context=camel-1,type=endpoints,name="rabbitmq://localhost:5672/rabbit" > > > > > [main] DEBUG org.apache.camel.component.properties.PropertiesComponent > - > > > Parsed location: ref:bridgePropertyPlaceholder > > > [main] DEBUG > > org.apache.camel.component.properties.DefaultPropertiesParser > > > - Found property: data_dir with value: file:///apps/data to be used. > > > [main] DEBUG org.apache.camel.spring.SpringCamelContext - Resolved > text: > > > {{data_dir}}/?fileName=rabbitMessage -> > > > file:///apps/data/?fileName=rabbitMessage > > > [main] DEBUG org.apache.camel.util.IntrospectionSupport - Configured > > > property: uri on bean: To[file:///apps/data/?fileName=rabbitMessage] > > with > > > value: file:///apps/data/?fileName=rabbitMessage > > > [main] DEBUG org.apache.camel.model.ProcessorDefinitionHelper - Changed > > > property [uri] from: {{data_dir}}/?fileName=rabbitMessage to: > > > file:///apps/data/?fileName=rabbitMessage > > > [main] DEBUG org.apache.camel.impl.DefaultComponent - Creating endpoint > > > uri=[file:///apps/data/?fileName=rabbitMessage], path=[/apps/data/] > > > [main] DEBUG > > > org.springframework.beans.factory.support.DefaultListableBeanFactory - > > > Creating instance of bean > > > 'org.apache.camel.language.constant.ConstantLanguage' > > > [main] DEBUG > > > org.springframework.beans.factory.support.DefaultListableBeanFactory - > > > Finished creating instance of bean > > > 'org.apache.camel.language.constant.ConstantLanguage' > > > [main] DEBUG org.apache.camel.util.IntrospectionSupport - Configured > > > property: fileName on bean: > > > Endpoint[file:///apps/data/?fileName=rabbitMessage] with value: > > > rabbitMessage > > > [main] DEBUG org.apache.camel.spring.SpringCamelContext - > > > file:///apps/data/?fileName=rabbitMessage converted to endpoint: > > > Endpoint[file:///apps/data/?fileName=rabbitMessage] by component: > > > org.apache.camel.component.file.FileComponent@1c18ee69 > > > [main] DEBUG org.apache.camel.management.DefaultManagementAgent - > > > Registered MBean with ObjectName: > > > > > > org.apache.camel:context=camel-1,type=endpoints,name="file:///apps/data/\?fileName=rabbitMessage" > > > > > [main] DEBUG org.apache.camel.processor.interceptor.DefaultChannel - > > > Initialize channel for target: > > > 'To[file:///apps/data/?fileName=rabbitMessage]' > > > ... > > > [main] DEBUG org.apache.camel.spring.SpringCamelContext - Warming up > > route > > > id: rabbit_route having autoStartup=true > > > [main] DEBUG org.apache.camel.impl.RouteService - Starting services on > > > route: rabbit_route > > > [main] DEBUG org.apache.camel.impl.RouteService - Starting child > service > > > on route: rabbit_route -> > > > Channel[sendTo(Endpoint[file:///apps/data/?fileName=rabbitMessage])] > > > [main] DEBUG org.apache.camel.management.DefaultManagementAgent - > > > Registered MBean with ObjectName: > > > > > > org.apache.camel:context=camel-1,type=producers,name=GenericFileProducer(0x4fd37449) > > > > > [main] DEBUG org.apache.camel.component.file.GenericFileProducer - > > > Starting producer: Producer[file:///apps/data/?fileName=rabbitMessage] > > > [main] DEBUG org.apache.camel.impl.ProducerCache - Adding to producer > > > cache with key: Endpoint[file:///apps/data/?fileName=rabbitMessage] for > > > producer: Producer[file:///apps/data/?fileName=rabbitMessage] > > > [main] DEBUG org.apache.camel.processor.DefaultErrorHandler - > Redelivery > > > enabled: true on error handler: > > > > > > DefaultErrorHandler[Instrumentation:to[sendTo(Endpoint[file:///apps/data/?fileName=rabbitMessage])]] > > > > > [main] DEBUG org.apache.camel.impl.RouteService - Starting child > service > > > on route: rabbit_route -> > > > sendTo(Endpoint[file:///apps/data/?fileName=rabbitMessage]) > > > [main] DEBUG org.apache.camel.management.DefaultManagementAgent - > > > Registered MBean with ObjectName: > > > org.apache.camel:context=camel-1,type=processors,name="to5" > > > [main] DEBUG org.apache.camel.impl.RouteService - Starting child > service > > > on route: rabbit_route -> > > > Channel[sendTo(Endpoint[file:///apps/data/?fileName=rabbitMessage])] > > > [main] DEBUG org.apache.camel.management.DefaultManagementAgent - > > > Registered MBean with ObjectName: > > > org.apache.camel:context=camel-1,type=routes,name="rabbit_route" > > > ... > > > [main] DEBUG org.apache.commons.httpclient.HttpClient - Java class > path: > > > ... > > > > > > /apps/activemq/lib/camel/camel-rabbitmq-2.15.6.jar:/apps/activemq/lib/rabbitmq-client.jar > > > > > ... > > > [main] DEBUG org.apache.camel.spring.SpringCamelContext - Route: > > > rabbit_route >>> > > > EventDrivenConsumerRoute[Endpoint[rabbitmq://localhost:5672/rabbit] -> > > > Channel[sendTo(Endpoint[file:///apps/data/?fileName=rabbitMessage])]] > > > [main] DEBUG org.apache.camel.spring.SpringCamelContext - Starting > > > consumer (order: 1003) on route: rabbit_route > > > [main] DEBUG org.apache.camel.management.DefaultManagementAgent - > > > Registered MBean with ObjectName: > > > > > > org.apache.camel:context=camel-1,type=consumers,name=RabbitMQConsumer(0x241d1052) > > > > > [main] DEBUG org.apache.camel.management.DefaultManagementAgent - > > > Registered MBean with ObjectName: > > > > > > org.apache.camel:context=camel-1,type=threadpools,name="RabbitMQEndpoint(0xc5a2d5)" > > > > > [main] DEBUG org.apache.camel.impl.DefaultExecutorServiceManager - > > Created > > > new ThreadPool for source: Endpoint[rabbitmq://localhost:5672/rabbit] > > with > > > name: RabbitMQConsumer. -> > > > org.apache.camel.util.concurrent.RejectableThreadPoolExecutor@185339ed > [Running, > > > > > pool size = 0, active threads = 0, queued tasks = 0, completed tasks = > > > 0][RabbitMQConsumer] > > > [main] DEBUG org.apache.camel.component.rabbitmq.RabbitMQConsumer - > > Using > > > executor > > > org.apache.camel.util.concurrent.RejectableThreadPoolExecutor@185339ed > [Running, > > > > > pool size = 0, active threads = 0, queued tasks = 0, completed tasks = > > > 0][RabbitMQConsumer] > > > [main] INFO org.apache.camel.component.rabbitmq.RabbitMQConsumer - > > > Connection failed, will start background thread to retry! > > > ... > > > java.net.ConnectException: Connection refused > > > > > > > > > ------------ > > > My status: I am relatively new to Camel and have interacted with it in > > > passing. Very new to RabbitMQ and have only very recent experience with > > it. > > > I've tried to RTFM but found no TFM to read that has been terribly > > helpful > > > in the matter. Could be my searches simply haven't found it, but if so > I > > > assume it's reasonably well hidden. > > > > > > Thanks in advance for any assistance. > > > > > > - j kammer > > > > > > > > > ------------------------------ > > If you reply to this email, your message will be added to the discussion > > below: > > > > > http://camel.465427.n5.nabble.com/How-can-I-configure-Camel-ActiveMQ-to-receive-from-an-external-RabbitMQ-producer-tp5785283p5785285.html > > To start a new topic under Camel - Users, email > > ml-node+s465427n465428...@n5.nabble.com > > To unsubscribe from Camel - Users, click here > > < > http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_code&node=465428&code=c291Y2lhbmNlLmVxZGFtLnJhc2h0aUBnbWFpbC5jb218NDY1NDI4fDE1MzI5MTE2NTY= > > > > . > > NAML > > < > http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewer&id=instant_html%21nabble%3Aemail.naml&base=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespace&breadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml > > > > > > > > > -- > View this message in context: > http://camel.465427.n5.nabble.com/How-can-I-configure-Camel-ActiveMQ-to-receive-from-an-external-RabbitMQ-producer-tp5785283p5785286.html > Sent from the Camel - Users mailing list archive at Nabble.com. >
