I didn't see anywhere that you connected with a username/password to
rabbitmq. The default user and password is guest/guest but could be that
they restrict it to another user. Also I guessing you want access to the
default vhost and not another defined one?
On Wed, Jul 20, 2016 at 7:41 PM, Kammer, John - US [via Camel] <
ml-node+s465427n5785283...@n5.nabble.com> 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-tp5785283.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-tp5785283p5785284.html
Sent from the Camel - Users mailing list archive at Nabble.com.
