Uses of Class
com.espertech.esperio.amqp.QueueingConsumer.Delivery
-
Uses of QueueingConsumer.Delivery in com.espertech.esperio.amqp
Modifier and TypeMethodDescriptionAMQPToObjectCollectorContext.getDelivery()
QueueingConsumer.nextDelivery()
Main application-side API: wait for the next message delivery and return it.QueueingConsumer.nextDelivery
(long timeout) Main application-side API: wait for the next message delivery and return it.Modifier and TypeMethodDescriptionvoid
AMQPToObjectCollectorContext.setDelivery
(QueueingConsumer.Delivery delivery) ModifierConstructorDescriptionAMQPToObjectCollectorContext
(com.espertech.esper.common.internal.epl.dataflow.interfaces.EPDataFlowEmitter emitter, byte[] bytes, QueueingConsumer.Delivery delivery, com.espertech.esper.common.client.EventType outputEventType) ModifierConstructorDescriptionQueueingConsumer
(com.rabbitmq.client.Channel ch, BlockingQueue<QueueingConsumer.Delivery> q)