public class MessageSourceNode extends ErrorCapableEndpointNode implements ReceiveCountersAware
Modifier and Type | Class and Description |
---|---|
static class |
MessageSourceNode.Stats |
Constructor and Description |
---|
MessageSourceNode(int nodeId,
String name,
MessageSource<?> messageSource,
String output,
String errors) |
Modifier and Type | Method and Description |
---|---|
ReceiveCounters |
getReceiveCounters() |
void |
receiveCounters(java.util.function.Supplier<ReceiveCounters> counters) |
getErrors
getOutput
addProperties, addProperty, getComponentType, getIntegrationPatternCategory, getIntegrationPatternType, getName, getNodeId, getProperties, getStats
public MessageSourceNode(int nodeId, String name, MessageSource<?> messageSource, String output, String errors)
@Nullable public ReceiveCounters getReceiveCounters()
public void receiveCounters(java.util.function.Supplier<ReceiveCounters> counters)
receiveCounters
in interface ReceiveCountersAware