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 TypeMethodDescriptionvoidCalled by spouts and bolts when they receive a 'log' command from a multilang process.voidsetUpContext(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- - theShellMsgcontaining the message to log.
-