Vert.xからfluent-plugin-websocketへ繋げる為のVert.x client #shibuyarb

vertx_client.rb

require "vertx"

client = Vertx::HttpClient.new
client.host = 'localhost'
client.port = 9000

client.connect_web_socket('/') do |websocket|
  websocket.data_handler do |buffer|
    puts "received: #{buffer}"
    res ={:status => 'ok', :data => buffer}
    Vertx::EventBus.send('subscriber', res)
  end
end

Vertx::EventBus.register_handler('subscriber') do |message|
  puts "subscriber: #{message.body}"
  message.reply('reply!')
end

puts 'client start'

起動コマンド

$ vertx run vertx_client.rb