Uses of Interface
com.rabbitmq.client.amqp.RpcServerBuilder
Packages that use RpcServerBuilder
-
Uses of RpcServerBuilder in com.rabbitmq.client.amqp
Methods in com.rabbitmq.client.amqp that return RpcServerBuilderModifier and TypeMethodDescriptionRpcServerBuilder.closeTimeout(Duration closeTimeout) The time the server waits for all outstanding requests to be processed before closing.RpcServerBuilder.correlationIdExtractor(Function<Message, Object> correlationIdExtractor) Logic to extract the correlation ID from a request message.RpcServerBuilder.handler(RpcServer.Handler handler) The logic to process requests and issue replies.RpcServerBuilder.replyPostProcessor(BiFunction<Message, Object, Message> replyPostProcessor) A callback called after request processing but before sending the reply message.RpcServerBuilder.requestQueue(String requestQueue) The queue to wait for requests on.Connection.rpcServerBuilder()Create a builder to configure and create aRpcServerBuilder.