Sign in
apache
/
storm
/
0.5.0
/
.
/
src
/
dev
/
resources
/
tester.rb
blob: a59a93c478ae897adc29d4f4a6434812e185e914 [
file
] [
log
] [
blame
]
require
File
.
expand_path
(
"storm"
,
File
.
dirname
(
__FILE__
))
class
TesterBolt
<
Storm
::
Bolt
def
process
(
tuple
)
emit
[
tuple
.
values
[
0
]
+
"lalala"
]
ack tuple
end
end
TesterBolt
.
new
.
run