Package org.apache.storm.utils
Interface ShellLogHandler
- All Known Implementing Classes:
DefaultShellLogHandler
public interface ShellLogHandler
Handle logging from non-JVM processes.
-
Method Summary
Modifier and TypeMethodDescriptionvoid
Called by spouts and bolts when they receive a 'log' command from a multilang process.void
setUpContext
(Class<?> ownerCls, ShellProcess process, TopologyContext context) Called at least once beforelog(org.apache.storm.multilang.ShellMsg)
for each spout and bolt.
-
Method Details
-
setUpContext
Called at least once beforelog(org.apache.storm.multilang.ShellMsg)
for each spout and bolt. Allows implementing classes to save information about the current running context e.g. pid, thread, task.- Parameters:
ownerCls
- - the class which instantiated this ShellLogHandler.process
- - the currentShellProcess
.context
- - the currentTopologyContext
.
-
log
Called by spouts and bolts when they receive a 'log' command from a multilang process.- Parameters:
msg
- - theShellMsg
containing the message to log.
-