starter.rb

require "vertx"

Vertx.deploy_verticle('concurrent.rb', nil, 10)

msg = {
    "foo" => "bar",
    "quux" => "wibble"
}

Vertx.set_periodic(1) {
  1000.times do
    Vertx::EventBus.publish('test.address', msg)
  end
}