Package | Description |
---|---|
com.rabbitmq.client |
The client API proper: classes and interfaces representing the AMQP
connections, channels, and wire-protocol framing descriptors.
|
com.rabbitmq.tools.jsonrpc |
JSON-RPC client and server classes for supporting JSON-RPC over an AMQP transport.
|
Modifier and Type | Method and Description |
---|---|
RpcClientParams |
RpcClientParams.channel(Channel channel) |
RpcClientParams |
RpcClientParams.correlationIdSupplier(Supplier<String> correlationIdGenerator)
Logic to generate correlation IDs.
|
RpcClientParams |
RpcClientParams.exchange(String exchange) |
RpcClientParams |
RpcClientParams.replyHandler(Function<Object,RpcClient.Response> replyHandler)
Set the behavior to use when receiving replies.
|
RpcClientParams |
RpcClientParams.replyTo(String replyTo)
Set the queue where the server should put replies on.
|
RpcClientParams |
RpcClientParams.routingKey(String routingKey)
Set the routing key to use for requests.
|
RpcClientParams |
RpcClientParams.timeout(int timeout)
Set the timeout in milliseconds to use on call responses.
|
RpcClientParams |
RpcClientParams.useMandatory()
Instructs to use the mandatory flag when publishing RPC requests.
|
RpcClientParams |
RpcClientParams.useMandatory(boolean useMandatory)
Whether to publish RPC requests with the mandatory flag or not.
|
Constructor and Description |
---|
RpcClient(RpcClientParams params)
Construct a
RpcClient with the passed-in RpcClientParams . |
Constructor and Description |
---|
JsonRpcClient(RpcClientParams rpcClientParams,
JsonRpcMapper mapper)
|
Copyright © 2022 VMware, Inc. or its affiliates.. All rights reserved.