ingest method

TTGraphConnector ingest(
  1. List<TTMsg> msgs
)

Queue incoming messages for processing

@param msgs

Implementation

TTGraphConnector ingest(List<TTMsg> msgs) {
  inputQueue.enqueueMany(msgs).process();

  return this;
}