# Rabbitmq river

**URL:** <https://discuss.elastic.co/t/rabbitmq-river/4793>\
**Category:** Elasticsearch\
**Created:** [July 6, 2011, 4:05pm UTC](https://discuss.elastic.co/t/rabbitmq-river/4793 "2011-07-06T16:05:42Z")\
**Posts on this page:** 2\
**Page:** 1

<div class="post-metadata">

**Author:** ![danoyoung](https://avatars.discourse-cdn.com/v4/letter/d/b9e5f3/32.png) [@danoyoung](https://discuss.elastic.co/u/danoyoung)\
**Post date:** [July 6, 2011, 4:05pm UTC](https://discuss.elastic.co/t/rabbitmq-river/4793/1 "2011-07-06T16:05:42Z")

</div>

I'm trying to setup/configure a rabbitmq river (using es 0.16.2) and am  
getting the following error in the logs:

[2011-07-06 09:53:38,883][DEBUG][river.cluster] [Coldfire]  
processing [reroute\_rivers\_node\_changed]: execute  
[2011-07-06 09:53:38,884][DEBUG][cluster.service] [Coldfire]  
processing [update-mapping [\_river][optimizer\_river]]: done applying updated  
cluster\_state  
[2011-07-06 09:53:38,924][DEBUG][river.cluster] [Coldfire]  
cluster state updated, version [1], source [reroute\_rivers\_node\_changed]  
[2011-07-06 09:53:38,926][DEBUG][river.cluster] [Coldfire]  
processing [reroute\_rivers\_node\_changed]: done applying updated  
cluster\_state  
[2011-07-06 09:53:38,926][DEBUG][river] [Coldfire]  
creating river [rabbitmq][optimizer\_river]  
[2011-07-06 09:53:38,928][WARN][river] [Coldfire]  
failed to create river [rabbitmq][optimizer\_river]  
org.elasticsearch.common.settings.NoClassSettingsException: Failed to load  
class with value [rabbitmq]  
at org.elasticsearch.river.RiverModule.loadTypeModule(RiverModule.java:84)  
at org.elasticsearch.river.RiverModule.spawnModules(RiverModule.java:56)  
at  
org.elasticsearch.common.inject.ModulesBuilder.add(ModulesBuilder.java:44)  
at org.elasticsearch.river.RiversService.createRiver(RiversService.java:127)  
at  
org.elasticsearch.river.RiversService$ApplyRivers$1.onResponse(RiversService.java:225)  
at  
org.elasticsearch.river.RiversService$ApplyRivers$1.onResponse(RiversService.java:220)  
at  
org.elasticsearch.action.support.single.shard.TransportShardSingleOperationAction$AsyncSingleAction$1.run(TransportShardSingleOperationAction.java:138)  
at  
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)  
at  
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)  
at java.lang.Thread.run(Thread.java:680)  
Caused by: java.lang.ClassNotFoundException: rabbitmq  
at java.net.URLClassLoader$1.run(URLClassLoader.java:202)  
at java.security.AccessController.doPrivileged(Native Method)  
at java.net.URLClassLoader.findClass(URLClassLoader.java:190)  
at java.lang.ClassLoader.loadClass(ClassLoader.java:306)  
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301)  
at java.lang.ClassLoader.loadClass(ClassLoader.java:247)  
at org.elasticsearch.river.RiverModule.loadTypeModule(RiverModule.java:70)  
... 9 more

Here's my create request:

#create river:  
curl -XPUT 'localhost:9200/\_river/optimizer\_river/\_meta' -d '{  
"type" : "rabbitmq",  
"host":"127.0.0.1",  
"user":"es\_writer",  
"password":"foo",  
"vhost":"/elasticsearch",  
"queue":"es\_index",  
"exchange":"es",  
"routing\_key":"es.optimizer.index"  
}'

Any ideas on what I'm doing incorrectly?

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\
**Post date:** [July 6, 2017, 4:01am UTC](https://discuss.elastic.co/t/rabbitmq-river/4793/2 "2017-07-06T04:01:37Z")

</div>