Package | Description |
---|---|
com.espertech.esperio.amqp |
AMQP input and output adapter classes.
|
Modifier and Type | Method and Description |
---|---|
QueueingConsumer.Delivery |
AMQPToObjectCollectorContext.getDelivery() |
QueueingConsumer.Delivery |
QueueingConsumer.nextDelivery()
Main application-side API: wait for the next message delivery and return it.
|
QueueingConsumer.Delivery |
QueueingConsumer.nextDelivery(long timeout)
Main application-side API: wait for the next message delivery and return it.
|
Modifier and Type | Method and Description |
---|---|
void |
AMQPToObjectCollectorContext.setDelivery(QueueingConsumer.Delivery delivery) |
Constructor and Description |
---|
AMQPToObjectCollectorContext(com.espertech.esper.common.internal.epl.dataflow.interfaces.EPDataFlowEmitter emitter,
byte[] bytes,
QueueingConsumer.Delivery delivery) |
Constructor and Description |
---|
QueueingConsumer(com.rabbitmq.client.Channel ch,
java.util.concurrent.BlockingQueue<QueueingConsumer.Delivery> q) |