Написание пользовательской реки

Я делаю свою первую попытку написать реку. (здесь исходный код)

Я следовал этому руководству. и сравнил ее с этой существующей рекой, но мне не повезло.

Чтобы развернуть реку, я создал папку с именем example-river, поместил в нее свою банку и перезапустил узел. Все нормально запускается.

Я также пробовал bin/plugin --url file:///path/to/plugin --install example-river, который, кажется, работает, но он распаковывает мою банку.

Когда я выдаю этот запрос PUT:

http://localhost:9200/_river/example_river/_meta
{
    "type": "example_river",
  "example_river":{
    "blah":"blah"
  }
}

Я получаю это исключение:

[2014-04-20 22:28:46,538][DEBUG][river ] [Gloom] создание реки [example_river][example_river] [2014-04-20 22:28:46,543][WARN ][river ] [Gloom] не удалось создать реку [example_river][example_river] org.elasticsearch.common.settings.NoClassSettingsException: не удалось загрузить класс со значением [example_river] в org.elasticsearch.river.RiverModule.loadTypeModule(RiverModule.java:87) в org.elasticsearch .river.RiverModule.spawnModules(RiverModule.java:58) в org.elasticsearch.common.inject.ModulesBuilder.add(ModulesBuilder.java:44) в org.elasticsearch.river.RiversService.createRiver(RiversService.java:137) в org.elasticsearch.river.RiversService$ApplyRivers$2.onResponse(RiversService.java:275) в org.elasticsearch.river.RiversService$ApplyRivers$2.onResponse(RiversService.java:269) в org.elasticsearch.action.support.TransportAction$ ThreadedActionListener$1.run(TransportAction.java:93) на java.uti l.concurrent.ThreadPoolExecutor.runWorker(неизвестный источник) в java.util.concurrent.ThreadPoolExecutor$Worker.run(неизвестный источник) в java.lang.Thread.run(неизвестный источник) Вызвано: java.lang.ClassNotFoundException: example_river в java.net.URLClassLoader$1.run(неизвестный источник) на java.net.URLClassLoader$1.run(неизвестный источник) на java.security.AccessController.doPrivileged(собственный метод) на java.net.URLClassLoader.findClass(неизвестный источник) на java.lang.ClassLoader.loadClass(неизвестный источник) в sun.misc.Launcher$AppClassLoader.loadClass(неизвестный источник) в java.lang.ClassLoader.loadClass(неизвестный источник) в org.elasticsearch.river.RiverModule.loadTypeModule(RiverModule. java:73) ... еще 9

Может ли кто-нибудь указать, что мне не хватает?