protected class ConnectorSource.AnnotatedReceiverQueues
extends java.lang.Object
ReceiverQueues
, holding their
DataDescription
and offering the ability to hold several
ReceiverQueues in one context to provide data for multiple Sink
s.Constructor and Description |
---|
ConnectorSource.AnnotatedReceiverQueues(ReceiverQueues queues,
DataDescription description)
Creates a new
ConnectorSource.AnnotatedReceiverQueues . |
Modifier and Type | Method and Description |
---|---|
void |
addReceiver(java.util.concurrent.LinkedBlockingQueue<DataEntry> queues)
Adds a new
LinkedBlockingQueue to the ReceiverQueues 's queue-pool. |
DataDescription |
getDescription()
Returns the associated
DataDescription describing the data the queues are expecting to receive. |
ReceiverQueues |
getQueues()
Returns the associated
ReceiverQueues . |
public ConnectorSource.AnnotatedReceiverQueues(ReceiverQueues queues, DataDescription description)
ConnectorSource.AnnotatedReceiverQueues
.queues
- ReceiverQueues
to be managed.description
- DataDescription
describing the data the queues
expect to get.public ReceiverQueues getQueues()
ReceiverQueues
.ReceiverQueues
.public DataDescription getDescription()
DataDescription
describing the data the queues are expecting to receive.DataDescription
.public void addReceiver(java.util.concurrent.LinkedBlockingQueue<DataEntry> queues)
LinkedBlockingQueue
to the ReceiverQueues
's queue-pool.queues
- LinkedBlockingQueue
to be added.