verticle extends with org.vertx.scala.platform.Verticle failed to deploy

[angeloh]

When testing verticle extends with org.vertx.scala.platform.Verticle, it would throw an exception.

java.lang.ClassCastException: verticles.SockJSVerticle cannot be cast to org.vertx.java.platform.Verticle

Here is my deploy code:

container.deployVerticle(
  classOf[SockJSVerticle].getName,
  (ar: AsyncResult[String]) => {

  })

Here is my verticle code

import org.vertx.scala.platform.Verticle

class SockJSVerticle extends Verticle {

   override def start(future: Future[Void]):Unit = {
    start()
   }
} 

[Narigo]

Umm, can you try this?

container.deployVerticle("scala:" + classOf[SockJSVerticle].getName,
  (ar: AsyncResult[String]) => { ... })

I think it tries to use Java as a default if you have a class name and don't prefix it. That's why you need to have "main" : "scala:your.company.your.ScalaVerticle" in the mod.json at least.

[raniejade]

@Narigo If that's the case, I think the scala: prefix should be automatically added by the scala container implementation if not present.

[angeloh]

Ok. I got different error now.

At first, I use add "scala" prefix like you said above. It gave me an error.

   java.lang.IllegalStateException: No language implementation known for prefix scala

Then, I added langs.properties to src/main/resources. Note, I already have "io.vertx:lang-scala:0.1.0-SNAPSHOT" in my build.gradle dependencies. After I added langs.properties, now it complains "can't cast to scala's verticle" instead of "can't cast to java's verticle". I did not change SockJSVerticle.

   java.lang.ClassCastException: verticles.SockJSVerticle cannot be cast to org.vertx.scala.platform.Verticle

[angeloh]

I think above problem is due to different classloader in the system. One loads org.vertx.scala.platform.Verticle and the other one loads my verticle. They should be in the same classloader.

According to http://stackoverflow.com/a/11945858/772481, maybe Vertx ModuleClassLoader should call super(classpath, platformClassLoader) to pass parent's classloader to URLClassLoader constructor.

  public class ModuleClassLoader extends URLClassLoader {
        public ModuleClassLoader(ClassLoader platformClassLoader, URL[] classpath, boolean loadResourcesFromTCCL) {
            super(classpath);
            this.platformClassLoader = platformClassLoader;
            this.loadResourcesFromTCCL = loadResourcesFromTCCL;
          }
  }

[angeloh]

Here is a simple test case for this issue.

  import org.vertx.scala.platform.Verticle

  class MyTestVerticle extends Verticle {
    import org.vertx.scala.core.eventbus.EventBus._
    val hdl: EventBusHandler[String] = EventBus.toBusHandler(
      (msg: Message[String]) => {
        assertNotNull(msg.body)
      })
    override def start() {
      vertx.eventBus.registerHandler("some-address")(hdl, rst => {
        if (!rst.succeeded)
          fail()
      })
    }
  }


  class VerticleTest extends TestVerticle {
    @Test
    def localPubSubTest() {
      import org.vertx.scala.core.FunctionConverters._
        container.deployVerticle(
          classOf[MyTestVerticle].getName,
          (ar: AsyncResult[String]) => {
            if (ar.succeeded)
                  assertTrue(ar.succeeded)
            else {
              ar.cause.printStackTrace()
              fail()
            }
          })
    }
  }

Here is the exception I got.

java.lang.ClassCastException: verticles.MyTestVerticle cannot be cast to org.vertx.java.platform.Verticle
    at org.vertx.java.platform.impl.java.JavaVerticleFactory.createVerticle(JavaVerticleFactory.java:57)
    at org.vertx.java.platform.impl.DefaultPlatformManager$18.run(DefaultPlatformManager.java:1269)
    at org.vertx.java.core.impl.DefaultContext$3.run(DefaultContext.java:170)
    at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:354)
    at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:366)
    at io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:101)
    at java.lang.Thread.run(Thread.java:724)

[Narigo]

@angeloh Could you create a small project and share it on github to be able to reproduce that problem?
I haven't worked with deployVerticle yet, only deployModule in my tests (which worked, btw). So there might be a bug, but I'm not sure how to reproduce it...

[angeloh]

@Narigo Thank you! I create 3 tests in the following commit. Only 3rd one runs okay. The differences are explained below:

angeloh@dea3d8d

1st: this test case throws "cannot be cast to org.vertx.java.platform.Verticle" error
2nd: I replace the handler with line vertx.eventBus.publish("some-address", "foo"); {}. Now it will time out instead of throwing above error
3rd: Use org.vertx.java.platform.Verticle instead. This test runs okay.

[Narigo]

Ok, here are my findings:
1st and 2nd: The module doesn't get deployed in both cases, so 2nd won't register the handler -> times out. It's the same root cause.
3rd: Okay, since you just use Java here.

I'm not sure what to do with 1st/2nd test cases. If I prepend a "scala:" right before the deployed verticle name, I get a class cast exception, that it cannot be casted to org.vertx.scala.platform.Verticle - but debug output says that it is. Maybe someone with more inside view can handle this.

@raniejade from what I can see, the "scala:" doesn't get prepend to the Verticle automatically. But to be honest I think that's good as you might want to start Java Verticles, too - and I'm not sure whether there is a java: prefix available. Anyways, I see a problem here about these class cast exceptions, can you have a look at it? Don't know too much about ClassLoaders, maybe it gets multiple org.vertx.scala.platform.Verticle and selects the wrong one?!

[edgarchan]

Hi, I'm not sure if it's possible to deploy scala verticles under the current testtools infraestructure (issue #23). But you can use the same trick of the scala test suite. Create a java verticle and add all the needed conversions manually, e.g.

class LocalTestVerticle1 extends org.vertx.java.platform.Verticle {
  import org.vertx.scala.core.eventbus.EventBus._
  lazy val eb:EventBus = EventBus(vertx.eventBus)
    ...
  override def start() {
    eb.registerHandler("some-address")(hdl, rst => {
      if (!rst.succeeded)
        fail()
      else
        testComplete()
    })
  }
} 

look at local "eb" val and it's use.

[angeloh]

Yeah. This is exactly what I did in LocalTestVerticle3.

https://github.com/angeloh/mod-lang-scala/blob/dea3d8de68b5d8478a805f919e152878a43e132e/src/test/scala/org/vertx/scala/tests/local/LocalVerticleTest3.scala

[galderz]

Sorry guys for the delay. Just getting around to catching up with this (I've been working on some improvements to be able to run Scala scripts as well as Scala classes).

Do we have a fix for this? Do you need me to look into it?

[Narigo]

Can you try this again with the branch of #63 ? I hope everything is fixed with that then as we had a lot of refactorings and class loading stuff changed in vert.x itself.

[brendanator]

This doesn't work in 1.0.0

I'm trying to avoid having a langs.properties file so that I can specify the language implementation in the mod.json and keep each module fully modular.

Unfortunately I need to use "scala:" when deploying the verticle to avoid the class cast exception. This then means I need to provide a langs.properties so it runs

Ideally when deploying a scala class from within a scala module you wouldn't need to specify the prefix it would just use the current ScalaVerticleFactory

[galderz]

@brendanator Thanks for the info! I'll look into it and see if we can fix it and release a patch version.