camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tsv <ts_v...@yahoo.com>
Subject Re: camel-rabbitmq : not able to publish messages
Date Thu, 17 Oct 2013 21:55:59 GMT
I don’t see any errors in the logs, it’s only info/debug logs (given below).
I even created the exchange (direct durable) and the queue (durable)
manually. This only helped in establishing the connection and also the idle
channel was created from camel but no message was published to the queue. I
used rabbitmq client v3.1.3 this time.

[main] DefaultCamelContext            DEBUG Adding routes from builder:
Routes: []
[main] DefaultCamelContext            INFO  Apache Camel 2.12.1
(CamelContext: camel-1) is starting
[main] DefaultCamelContext            DEBUG Using
ClassResolver=org.apache.camel.impl.DefaultClassResolver@7946738,
PackageScanClassResolver=org.apache.camel.impl.DefaultPackageScanClassResolver@2004916b,
ApplicationContextClassLoader=sun.misc.Launcher$AppClassLoader@70cfaf6e
[main] ManagedManagementStrategy      INFO  JMX is enabled
[main] DefaultManagementAgent         DEBUG Starting JMX agent on server:
com.sun.jmx.mbeanserver.JmxMBeanServer@4f8429d6
[main] DefaultManagementAgent         DEBUG Registered MBean with
ObjectName:
org.apache.camel:context=[hostname]/camel-1,type=context,name="camel-1"
[main] TimerListenerManager           DEBUG Added TimerListener:
org.apache.camel.management.mbean.ManagedCamelContext@7302d823
[main] DefaultManagementAgent         DEBUG Registered MBean with
ObjectName:
org.apache.camel:context=[hostname]/camel-1,type=services,name=DefaultTypeConverter
[main] AnnotationTypeConverterLoader  DEBUG Found 3 packages with 15
@Converter classes to load
[main] AnnotationTypeConverterLoader  DEBUG Loading file
META-INF/services/org/apache/camel/TypeConverter to retrieve list of
packages, from url:
jar:file:/C:/Users/shanmukv/.m2/repository/org/apache/camel/camel-core/2.12.1/camel-core-2.12.1.jar!/META-INF/services/org/apache/camel/TypeConverter
[main] AnnotationTypeConverterLoader  DEBUG Loading file
META-INF/services/org/apache/camel/TypeConverter to retrieve list of
packages, from url:
jar:file:/C:/Users/shanmukv/.m2/repository/org/apache/activemq/activemq-all/5.8.0/activemq-all-5.8.0.jar!/META-INF/services/org/apache/camel/TypeConverter
[main] AnnotationTypeConverterLoader  DEBUG Loading file
META-INF/services/org/apache/camel/TypeConverter to retrieve list of
packages, from url:
jar:file:/C:/Users/shanmukv/.m2/repository/org/apache/camel/camel-spring/2.12.1/camel-spring-2.12.1.jar!/META-INF/services/org/apache/camel/TypeConverter
[main] AnnotationTypeConverterLoader  DEBUG Loaded 3 @Converter classes
[main] DefaultTypeConverter           INFO  Loaded 179 type converters
[main] DefaultManagementAgent         DEBUG Registered MBean with
ObjectName:
org.apache.camel:context=[hostname]/camel-1,type=services,name=EndpointRegistry
[main] DefaultManagementAgent         DEBUG Registered MBean with
ObjectName:
org.apache.camel:context=[hostname]/camel-1,type=services,name=DefaultExecutorServiceManager
[main] DefaultManagementAgent         DEBUG Registered MBean with
ObjectName:
org.apache.camel:context=[hostname]/camel-1,type=services,name=SharedProducerServicePool
[main] SharedProducerServicePool      DEBUG Starting service pool:
org.apache.camel.impl.SharedProducerServicePool@51c93bea
[main] DefaultManagementAgent         DEBUG Registered MBean with
ObjectName:
org.apache.camel:context=[hostname]/camel-1,type=services,name=DefaultInflightRepository
[main] DefaultManagementAgent         DEBUG Registered MBean with
ObjectName:
org.apache.camel:context=[hostname]/camel-1,type=services,name=DefaultShutdownStrategy
[main] DefaultManagementAgent         DEBUG Registered MBean with
ObjectName:
org.apache.camel:context=[hostname]/camel-1,type=services,name=DefaultPackageScanClassResolver
[main] DefaultCamelContext            DEBUG Using ComponentResolver:
org.apache.camel.impl.DefaultComponentResolver@48caff01 to resolve component
with name: file
[main] DefaultComponentResolver       DEBUG Found component: file in
registry: null
[main] DefaultComponentResolver       DEBUG Found component: file via type:
org.apache.camel.component.file.FileComponent via:
META-INF/services/org/apache/camel/component/file
[main] DefaultManagementAgent         DEBUG Registered MBean with
ObjectName:
org.apache.camel:context=[hostname]/camel-1,type=components,name="file"
[main] DefaultComponent               DEBUG Creating endpoint
uri=[file://src/data], path=[src/data]
[main] DefaultCamelContext            DEBUG file://src/data converted to
endpoint: Endpoint[file://src/data] by component:
org.apache.camel.component.file.FileComponent@70b891ad
[main] DefaultManagementAgent         DEBUG Registered MBean with
ObjectName:
org.apache.camel:context=[hostname]/camel-1,type=endpoints,name="file://src/data"
[main] DefaultCamelContext            DEBUG Using ComponentResolver:
org.apache.camel.impl.DefaultComponentResolver@48caff01 to resolve component
with name: rabbitmq
[main] DefaultComponentResolver       DEBUG Found component: rabbitmq in
registry: null
[main] DefaultComponentResolver       DEBUG Found component: rabbitmq via
type: org.apache.camel.component.rabbitmq.RabbitMQComponent via:
META-INF/services/org/apache/camel/component/rabbitmq
[main] DefaultManagementAgent         DEBUG Registered MBean with
ObjectName:
org.apache.camel:context=[hostname]/camel-1,type=components,name="rabbitmq"
[main] DefaultComponent               DEBUG Creating endpoint
uri=[rabbitmq://myhost.com:5672/camel.exchange?password=xxxxxx&queue=camel.queue&routingKey=camel.queue.key&username=guest&vhost=myvhost],
path=[myhost.com:5672/camel.exchange]
[main] IntrospectionSupport           DEBUG Configured property: password on
bean:
Endpoint[rabbitmq://myhost.com:5672/camel.exchange?password=xxxxxx&queue=camel.queue&routingKey=camel.queue.key&username=guest&vhost=myvhost]
with value: guest
[main] IntrospectionSupport           DEBUG Configured property: queue on
bean:
Endpoint[rabbitmq://myhost.com:5672/camel.exchange?password=xxxxxx&queue=camel.queue&routingKey=camel.queue.key&username=guest&vhost=myvhost]
with value: camel.queue
[main] IntrospectionSupport           DEBUG Configured property: routingKey
on bean:
Endpoint[rabbitmq://myhost.com:5672/camel.exchange?password=xxxxxx&queue=camel.queue&routingKey=camel.queue.key&username=guest&vhost=myvhost]
with value: camel.queue.key
[main] IntrospectionSupport           DEBUG Configured property: username on
bean:
Endpoint[rabbitmq://myhost.com:5672/camel.exchange?password=xxxxxx&queue=camel.queue&routingKey=camel.queue.key&username=guest&vhost=myvhost]
with value: guest
[main] IntrospectionSupport           DEBUG Configured property: vhost on
bean:
Endpoint[rabbitmq://myhost.com:5672/camel.exchange?password=xxxxxx&queue=camel.queue&routingKey=camel.queue.key&username=guest&vhost=myvhost]
with value: guest
[main] RabbitMQComponent              DEBUG Creating RabbitMQEndpoint with
host myhost.com:5672 and exchangeName: camel.exchange
[main] DefaultCamelContext            DEBUG
rabbitmq://myhost.com:5672/camel.exchange?password=xxxxxx&queue=camel.queue&routingKey=camel.queue.key&username=guest&vhost=myvhost
converted to endpoint:
Endpoint[rabbitmq://myhost.com:5672/camel.exchange?password=xxxxxx&queue=camel.queue&routingKey=camel.queue.key&username=guest&vhost=myvhost]
by component: org.apache.camel.component.rabbitmq.RabbitMQComponent@274ccf3d
[main] DefaultManagementAgent         DEBUG Registered MBean with
ObjectName:
org.apache.camel:context=[hostname]/camel-1,type=endpoints,name="rabbitmq://myhost.com:5672/camel.exchange\?password=guest&queue=camel.queue&routingKey=camel.queue.key&username=guest&vhost=myvhost"
[main] DefaultChannel                 DEBUG Initialize channel for target:
'To[rabbitmq://myhost.com:5672/camel.exchange?queue=camel.queue&routingKey=camel.queue.key&username=guest&password=guest&vhost=myvhost]'
[main] DefaultManagementAgent         DEBUG Registered MBean with
ObjectName:
org.apache.camel:context=[hostname]/camel-1,type=tracer,name=BacklogTracer
[main] DefaultManagementAgent         DEBUG Registered MBean with
ObjectName:
org.apache.camel:context=[hostname]/camel-1,type=tracer,name=BacklogDebugger
[main] DefaultManagementAgent         DEBUG Registered MBean with
ObjectName:
org.apache.camel:context=[hostname]/camel-1,type=errorhandlers,name="DefaultErrorHandlerBuilder(ref:CamelDefaultErrorHandlerBuilder)"
[main] DefaultCamelContext            INFO  StreamCaching is not in use. If
using streams then its recommended to enable stream caching. See more
details at http://camel.apache.org/stream-caching.html
[main] DefaultCamelContext            DEBUG Warming up route id: route1
having autoStartup=true
[main] RouteService                   DEBUG Starting services on route:
route1
[main] RouteService                   DEBUG Starting child service on route:
route1 ->
Channel[sendTo(Endpoint[rabbitmq://myhost.com:5672/camel.exchange?password=xxxxxx&queue=camel.queue&routingKey=camel.queue.key&username=guest&vhost=myvhost])]
[main] RabbitMQProducer               DEBUG Starting producer:
Producer[rabbitmq://myhost.com:5672/camel.exchange?password=xxxxxx&queue=camel.queue&routingKey=camel.queue.key&username=guest&vhost=myvhost]
[main] ProducerCache                  DEBUG Adding to producer cache with
key:
Endpoint[rabbitmq://myhost.com:5672/camel.exchange?password=xxxxxx&queue=camel.queue&routingKey=camel.queue.key&username=guest&vhost=myvhost]
for producer:
Producer[rabbitmq://myhost.com:5672/camel.exchange?password=xxxxxx&queue=camel.queue&routingKey=camel.queue.key&username=guest&vhost=myvhost]
[main] DefaultErrorHandler            DEBUG Redelivery enabled: false on
error handler:
DefaultErrorHandler[Instrumentation:to[sendTo(Endpoint[rabbitmq://myhost.com:5672/camel.exchange?password=xxxxxx&queue=camel.queue&routingKey=camel.queue.key&username=guest&vhost=myvhost])]]
[main] RouteService                   DEBUG Starting child service on route:
route1 ->
sendTo(Endpoint[rabbitmq://myhost.com:5672/camel.exchange?password=xxxxxx&queue=camel.queue&routingKey=camel.queue.key&username=guest&vhost=myvhost])
[main] DefaultManagementAgent         DEBUG Registered MBean with
ObjectName:
org.apache.camel:context=[hostname]/camel-1,type=processors,name="to1"
[main] RouteService                   DEBUG Starting child service on route:
route1 ->
Channel[sendTo(Endpoint[rabbitmq://myhost.com:5672/camel.exchange?password=xxxxxx&queue=camel.queue&routingKey=camel.queue.key&username=guest&vhost=myvhost])]
[main] DefaultManagementAgent         DEBUG Registered MBean with
ObjectName:
org.apache.camel:context=[hostname]/camel-1,type=routes,name="route1"
[main] TimerListenerManager           DEBUG Added TimerListener:
org.apache.camel.management.mbean.ManagedSuspendableRoute@271d900d
[main] DefaultCamelContext            DEBUG Route: route1 >>>
EventDrivenConsumerRoute[Endpoint[file://src/data] ->
Channel[sendTo(Endpoint[rabbitmq://myhost.com:5672/camel.exchange?password=xxxxxx&queue=camel.queue&routingKey=camel.queue.key&username=guest&vhost=myvhost])]]
[main] DefaultCamelContext            DEBUG Starting consumer (order: 1000)
on route: route1
[main] DefaultManagementAgent         DEBUG Registered MBean with
ObjectName:
org.apache.camel:context=[hostname]/camel-1,type=consumers,name=FileConsumer(0x126db04e)
[main] FileConsumer                   DEBUG Starting consumer:
Consumer[file://src/data]
[main] IntrospectionSupport           DEBUG Configured property:
initialDelay on bean:
org.apache.camel.impl.DefaultScheduledPollConsumerScheduler@744611ae with
value: 1000
[main] IntrospectionSupport           DEBUG Configured property: timeUnit on
bean: org.apache.camel.impl.DefaultScheduledPollConsumerScheduler@744611ae
with value: MILLISECONDS
[main] IntrospectionSupport           DEBUG Configured property:
scheduledExecutorService on bean:
org.apache.camel.impl.DefaultScheduledPollConsumerScheduler@744611ae with
value: null
[main] IntrospectionSupport           DEBUG Configured property:
useFixedDelay on bean:
org.apache.camel.impl.DefaultScheduledPollConsumerScheduler@744611ae with
value: true
[main] IntrospectionSupport           DEBUG Configured property: delay on
bean: org.apache.camel.impl.DefaultScheduledPollConsumerScheduler@744611ae
with value: 500
[main] DefaultManagementAgent         DEBUG Registered MBean with
ObjectName:
org.apache.camel:context=[hostname]/camel-1,type=threadpools,name="FileConsumer(0x126db04e)"
[main] DefaultExecutorServiceManager  DEBUG Created new ScheduledThreadPool
for source: Consumer[file://src/data] with name: file://src/data. ->
org.apache.camel.util.concurrent.SizedScheduledExecutorService@4cfcb4de[file://src/data]
[main] ScheduledPollConsumerScheduler DEBUG Scheduling poll (fixed delay)
with initialDelay: 1000, delay: 500 (milliseconds) for:
Endpoint[file://src/data]
[main] DefaultCamelContext            INFO  Route: route1 started and
consuming from: Endpoint[file://src/data]
[main] ultManagementLifecycleStrategy DEBUG Load performance statistics
enabled
[main] DefaultManagementAgent         DEBUG Registered MBean with
ObjectName:
org.apache.camel:context=[hostname]/camel-1,type=services,name=TimerListenerManager
[main] DefaultManagementAgent         DEBUG Registered MBean with
ObjectName:
org.apache.camel:context=[hostname]/camel-1,type=threadpools,name="TimerListenerManager"
[main] DefaultExecutorServiceManager  DEBUG Created new ScheduledThreadPool
for source: org.apache.camel.support.TimerListenerManager@4a0848f6 with
name: ManagementLoadTask. ->
org.apache.camel.util.concurrent.SizedScheduledExecutorService@56aa5f3f[ManagementLoadTask]
[main] TimerListenerManager           DEBUG Started scheduled TimerListener
task to run with interval 1000 ms
[main] DefaultCamelContext            INFO  Total 1 routes, of which 1 is
started.
[main] DefaultCamelContext            INFO  Apache Camel 2.12.1
(CamelContext: camel-1) started in 0.841 seconds
[1) thread #0 - file://src/data] FileEndpoint                   DEBUG
Parameters for Generic file process strategy {readLock=markerFile,
readLockTimeout=10000, readLockLoggingLevel=WARN, readLockMinLength=1,
readLockCheckInterval=1000}
[1) thread #0 - file://src/data] FileEndpoint                   DEBUG Using
Generic file process strategy:
org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@5d63838
[1) thread #0 - file://src/data] rFileExclusiveReadLockStrategy DEBUG
Prepare on startup by deleting orphaned lock files from: src\data
[1) thread #0 - file://src/data] FileConsumer                   DEBUG Took
0.003 seconds to poll: src\data
[1) thread #0 - file://src/data] FileConsumer                   DEBUG Total
1 files to consume
[1) thread #0 - file://src/data] FileConsumer                   DEBUG About
to process file: GenericFile[message1.xml] using exchange:
Exchange[message1.xml]
[1) thread #0 - file://src/data] SendProcessor                  DEBUG >>>>
Endpoint[rabbitmq://myhost.com:5672/camel.exchange?password=xxxxxx&queue=camel.queue&routingKey=camel.queue.key&username=guest&vhost=myvhost]
Exchange[message1.xml]
[1) thread #0 - file://src/data] GenericFileOnCompletion        DEBUG Done
processing file: GenericFile[message1.xml] using exchange:
Exchange[message1.xml]
[1) thread #0 - file://src/data] FileUtil                       DEBUG
Retrying attempt 0 to delete file: src\data\.camel\message1.xml
[1) thread #0 - file://src/data] FileUtil                       DEBUG Tried
1 to delete file: src\data\.camel\message1.xml with result: true
[1) thread #0 - file://src/data] nericFileRenameProcessStrategy DEBUG
Renaming file: GenericFile[message1.xml] to:
GenericFile[.camel\message1.xml]
[1) thread #0 - file://src/data] FileUtil                       DEBUG Tried
1 to rename file: C:\Workspace\camel\src\data\message1.xml to:
src\data\.camel\message1.xml with result: true
[1) thread #0 - file://src/data] FileUtil                       DEBUG
Retrying attempt 0 to delete file:
C:\Workspace\camel\src\data\message1.xml.camelLock
[1) thread #0 - file://src/data] FileUtil                       DEBUG Tried
1 to delete file: C:\Workspace\camel\src\data\message1.xml.camelLock with
result: true
[1) thread #0 - file://src/data] FileConsumer                   DEBUG Took
0.001 seconds to poll: src\data
[1) thread #0 - file://src/data] FileConsumer                   DEBUG Took
0.001 seconds to poll: src\data
[1) thread #0 - file://src/data] FileConsumer                   DEBUG Took
0.000 seconds to poll: src\data
[1) thread #0 - file://src/data] FileConsumer                   DEBUG Took
0.001 seconds to poll: src\data





--
View this message in context: http://camel.465427.n5.nabble.com/camel-rabbitmq-not-able-to-publish-messages-tp5741707p5741800.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Mime
View raw message