public static interface RMQDeserializationSchema.RMQCollector<T> extends Collector<T>
It extends the Collector
to give the ability to collect more than 1 message and
the ability to set the message correlationId and deliveryTag.
Modifier and Type | Method and Description |
---|---|
boolean |
setMessageIdentifiers(String correlationId,
long deliveryTag)
Sets the correlation id and the delivery tag that corresponds to the records originating
from the RMQ event.
|
boolean setMessageIdentifiers(String correlationId, long deliveryTag)
If not set explicitly, the AMQP.BasicProperties#getCorrelationId()
and Envelope.getDeliveryTag()
will be used.
NOTE:Can be called once for a single invocation of a RMQDeserializationSchema.deserialize(Envelope, AMQP.BasicProperties, byte[],
RMQCollector)
method.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.