add code for reproducing elastic/elasticsearch#10290

.gitignore

@@ -0,0 +1,2 @@
+.idea/
+target/

build.sbt

@@ -0,0 +1,13 @@
+name := "es-repro"
+
+version := "1.0"
+
+scalaVersion := "2.10.1"
+
+libraryDependencies ++= Seq(
+//  "org.elasticsearch" % "elasticsearch" % "1.0.0.Beta2",
+  //"org.elasticsearch" % "elasticsearch" % "1.4.4",
+  "org.elasticsearch" % "elasticsearch" % "1.5.0",
+  "joda-time" % "joda-time"    % "2.3",
+  "org.joda"  % "joda-convert" % "1.6"
+)

project/build.properties

@@ -0,0 +1 @@
+sbt.version = 0.13.8

project/plugins.sbt

@@ -0,0 +1,4 @@
+logLevel := Level.Warn
+
+addSbtPlugin("com.eed3si9n" % "sbt-assembly" % "0.12.0")
+

src/main/scala/fi.markoa.es.repro.i10290/FooRiver.scala

@@ -0,0 +1,21 @@
+package fi.markoa.es.repro.i10290
+
+import java.util.TimeZone
+
+import org.elasticsearch.client.Client
+import org.elasticsearch.common.inject.Inject
+import org.elasticsearch.river._
+import org.joda.convert.StringConvert
+
+class FooRiver @Inject() (riverName: RiverName, settings: RiverSettings,
+                                      @RiverIndexName riverIndexName: String,
+                                      client: Client)
+  extends AbstractRiverComponent(riverName, settings) with River {
+
+  def close(): Unit = ???
+  def start(): Unit = ???
+
+  def foo = {
+    val zone = StringConvert.INSTANCE.convertFromString(classOf[TimeZone], "");
+  }
+}

src/main/scala/fi.markoa.es.repro.i10290/FooRiverModule.scala

@@ -0,0 +1,8 @@
+package fi.markoa.es.repro.i10290
+
+import org.elasticsearch.common.inject.AbstractModule
+import org.elasticsearch.river.River
+
+class FooRiverModule extends AbstractModule {
+  override def configure = bind(classOf[River]).to(classOf[FooRiver]).asEagerSingleton()
+}

src/main/scala/fi.markoa.es.repro.i10290/FooRiverPlugin.scala

@@ -0,0 +1,13 @@
+package fi.markoa.es.repro.i10290
+
+import org.elasticsearch.common.inject.Inject
+import org.elasticsearch.plugins.AbstractPlugin
+import org.elasticsearch.river.RiversModule
+
+class FooRiverPlugin @Inject() extends AbstractPlugin {
+  def description: String = ???
+  def name: String = ???
+
+  def onModule(module: RiversModule): Unit = module.registerRiver(name, classOf[FooRiverModule])
+}
+