org.springframework.integration.graph

Class MessageSourceNode

java.lang.Object

org.springframework.integration.graph.IntegrationNode

org.springframework.integration.graph.EndpointNode

org.springframework.integration.graph.ErrorCapableEndpointNode

org.springframework.integration.graph.MessageSourceNode

All Implemented Interfaces:

ErrorCapableNode, ReceiveCountersAware

public class MessageSourceNode
extends ErrorCapableEndpointNode
implements ReceiveCountersAware

Represents a message source.

Since:

4.3

Author:

Gary Russell, Artem Bilan

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MessageSourceNode.Stats

Constructor Summary

Constructors

Constructor and Description
MessageSourceNode(int nodeId, String name, MessageSource<?> messageSource, String output, String errors)

Method Summary

Modifier and Type	Method and Description
ReceiveCounters	getReceiveCounters()
void	receiveCounters(java.util.function.Supplier<ReceiveCounters> counters)

Methods inherited from class org.springframework.integration.graph.ErrorCapableEndpointNode

getErrors

Methods inherited from class org.springframework.integration.graph.EndpointNode

getOutput

Methods inherited from class org.springframework.integration.graph.IntegrationNode

addProperties, addProperty, getComponentType, getName, getNodeId, getProperties, getStats

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MessageSourceNode

public MessageSourceNode(int nodeId,
                         String name,
                         MessageSource<?> messageSource,
                         String output,
                         String errors)

Method Detail

getReceiveCounters

@Nullable
public ReceiveCounters getReceiveCounters()

receiveCounters

public void receiveCounters(java.util.function.Supplier<ReceiveCounters> counters)

Specified by:

receiveCounters in interface ReceiveCountersAware