diff --git a/examples/simple/hello_world_topology.rb b/examples/simple/hello_world_topology.rb new file mode 100644 index 0000000..63a1b2d --- /dev/null +++ b/examples/simple/hello_world_topology.rb @@ -0,0 +1,22 @@ +require 'red_storm' + +class HelloWorldSpout < RedStorm::SimpleSpout + on_init {@words = ["hello", "world"]} + on_send {@words.shift unless @words.empty?} +end + +class HelloWorldBolt < RedStorm::SimpleBolt + on_receive :emit => false do |tuple| + log.info(tuple.getString(0)) + end +end + +class HelloWorldTopology < RedStorm::SimpleTopology + spout HelloWorldSpout do + output_fields :word + end + + bolt HelloWorldBolt do + source HelloWorldSpout, :global + end +end \ No newline at end of file