QueueNode
constructor(label: String, source: PushInputChannel<T>, destination: PullOutputChannel<T>, policy: QueuePolicy<T> = FIFOQueuePolicy())
Parameters
T
the type of entities in the queue
label
the name of this node
source
the input channel from which entities are received
destination
the output channel where entities are sent
policy
the QueuePolicy that determines entity ordering (defaults to FIFO)