aiagent.RabbitQueue¶
- class RabbitQueue(queueInfo)¶
- __init__(queueInfo)¶
Methods
__init__(queueInfo)add_listener(callback[, autoAck])push(body)push_document_chunk(chunk, metadata, user_name)Creates a queue message for the chunk for a worker to process
successfully_processed(msgKey)