Uses of Class
com.rabbitmq.client.Delivery
-
Packages that use Delivery Package Description com.rabbitmq.client The client API proper: classes and interfaces representing the AMQP connections, channels, and wire-protocol framing descriptors. -
-
Uses of Delivery in com.rabbitmq.client
Fields in com.rabbitmq.client declared as Delivery Modifier and Type Field Description private static Delivery
RpcServer.DefaultRpcConsumer. POISON
Fields in com.rabbitmq.client with type parameters of type Delivery Modifier and Type Field Description private java.util.concurrent.BlockingQueue<Delivery>
RpcServer.DefaultRpcConsumer. _queue
Methods in com.rabbitmq.client that return Delivery Modifier and Type Method Description private Delivery
RpcServer.DefaultRpcConsumer. handle(Delivery delivery)
If delivery is not POISON nor null, return it.Delivery
RpcServer.DefaultRpcConsumer. nextDelivery()
Delivery
RpcServer.RpcConsumer. nextDelivery()
Methods in com.rabbitmq.client with parameters of type Delivery Modifier and Type Method Description void
DeliverCallback. handle(java.lang.String consumerTag, Delivery message)
Called when abasic.deliver
is received for this consumer.private Delivery
RpcServer.DefaultRpcConsumer. handle(Delivery delivery)
If delivery is not POISON nor null, return it.byte[]
RpcServer. handleCall(Delivery request, AMQP.BasicProperties replyProperties)
Lowest-level response method.void
RpcServer. handleCast(Delivery request)
Lowest-level handler method.protected AMQP.BasicProperties
RpcServer. postprocessReplyProperties(Delivery request, AMQP.BasicProperties.Builder builder)
Gives a chance to set/modify reply properties after the handling callprotected AMQP.BasicProperties
RpcServer. preprocessReplyProperties(Delivery request, AMQP.BasicProperties.Builder builder)
Gives a chance to set/modify reply properties before handling call.void
RpcServer. processRequest(Delivery request)
Private API - Process a single request.Constructor parameters in com.rabbitmq.client with type arguments of type Delivery Constructor Description DefaultRpcConsumer(Channel ch, java.util.concurrent.BlockingQueue<Delivery> q)
-