NAME
IO::Storm::Component - The base class for Bolts and Spouts.
VERSION
version 0.13
METHODS
_setup_component
Add helpful instance variables to component after initial handshake with Storm.
read_message
Read a message from the ShellBolt. Reads until it finds a "end" line.
read_tuple
Turn the incoming Tuple structure into an <IO::Storm::Tuple>.
read_handshake
Read and process an initial handshake message from Storm
send_message
Send a message to Storm, encoding it as JSON.
sync
Send a sync command to Storm.
log
Send a log command to Storm
AUTHORS
Dan Blanchard <dblanchard@ets.org>
Cory G Watson <gphat@cpan.org>
COPYRIGHT AND LICENSE
This software is copyright (c) 2014 by Educational Testing Service.
This is free software; you can redistribute it and/or modify it under the same terms as the Perl 5 programming language system itself.