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 DeliveryRpcServer.DefaultRpcConsumer. POISONFields in com.rabbitmq.client with type parameters of type Delivery Modifier and Type Field Description private java.util.concurrent.BlockingQueue<Delivery>RpcServer.DefaultRpcConsumer. _queueMethods in com.rabbitmq.client that return Delivery Modifier and Type Method Description private DeliveryRpcServer.DefaultRpcConsumer. handle(Delivery delivery)If delivery is not POISON nor null, return it.DeliveryRpcServer.DefaultRpcConsumer. nextDelivery()DeliveryRpcServer.RpcConsumer. nextDelivery()Methods in com.rabbitmq.client with parameters of type Delivery Modifier and Type Method Description voidDeliverCallback. handle(java.lang.String consumerTag, Delivery message)Called when abasic.deliveris received for this consumer.private DeliveryRpcServer.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.voidRpcServer. handleCast(Delivery request)Lowest-level handler method.protected AMQP.BasicPropertiesRpcServer. postprocessReplyProperties(Delivery request, AMQP.BasicProperties.Builder builder)Gives a chance to set/modify reply properties after the handling callprotected AMQP.BasicPropertiesRpcServer. preprocessReplyProperties(Delivery request, AMQP.BasicProperties.Builder builder)Gives a chance to set/modify reply properties before handling call.voidRpcServer. 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)
-