Class RedisStreamIntakeIngressProducer

java.lang.Object

ai.pipeline.connector.intake.ingress.RedisStreamIntakeIngressProducer

All Implemented Interfaces:

IntakeIngressProducer

@ApplicationScoped
public class RedisStreamIntakeIngressProducer
extends Object
implements IntakeIngressProducer

Nested Class Summary

Nested classes/interfaces inherited from interface IntakeIngressProducer

IntakeIngressProducer.EnqueueResult

Constructor Summary

Constructors

Constructor	Description
RedisStreamIntakeIngressProducer()

Method Summary

Modifier and Type	Method	Description
IntakeIngressProducer.EnqueueResult	enqueue(ai.pipestream.engine.v1.IntakeHandoffRequest request, String sourceDocId)

Methods inherited from class Object

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

Constructor Details

RedisStreamIntakeIngressProducer

public RedisStreamIntakeIngressProducer()

Method Details

enqueue

public IntakeIngressProducer.EnqueueResult enqueue(ai.pipestream.engine.v1.IntakeHandoffRequest request,
 String sourceDocId)

Specified by:

enqueue in interface IntakeIngressProducer