public class MessageHandlerNode extends EndpointNode implements SendTimersAware
| Modifier and Type | Class and Description |
|---|---|
static class |
MessageHandlerNode.Stats |
| Constructor and Description |
|---|
MessageHandlerNode(int nodeId,
String name,
MessageHandler handler,
String input,
String output) |
| Modifier and Type | Method and Description |
|---|---|
String |
getInput() |
SendTimers |
getSendTimers() |
void |
sendTimers(java.util.function.Supplier<SendTimers> timers) |
getOutputaddProperties, addProperty, getComponentType, getName, getNodeId, getProperties, getStatspublic MessageHandlerNode(int nodeId,
String name,
MessageHandler handler,
String input,
String output)
public String getInput()
@Nullable public SendTimers getSendTimers()
public void sendTimers(java.util.function.Supplier<SendTimers> timers)
sendTimers in interface SendTimersAware