Ruby Thrift Code

gistfile1.rb

# Add to Gemfile 
# gem 'thrift'
# gem 'storm'

require 'storm'

# Ruby DRPC  Snippet of Code
class StormRunner

  def submit_to_storm(service_name,data,host,port)
    puts "Submitting to Storm"
    transport = Thrift::FramedTransport.new(Thrift::Socket.new(host, port))
    protocol = Thrift::BinaryProtocol.new(transport)
    client = Storm::DistributedRPC::Client.new(protocol)
    transport.open()
    return client.execute(service_name,data)
  end

end