Java 类com.rabbitmq.client.Command 实例源码

项目:java-rabbitmq-client    文件:TracingChannel.java   
@Override
public Command rpc(Method method) throws IOException {
  return channel.rpc(method);
}
项目:java-rabbitmq-client    文件:TracingChannel.java   
@Override
public CompletableFuture<Command> asyncCompletableRpc(
    Method method) throws IOException {
  return channel.asyncCompletableRpc(method);
}
项目:rabbitmq-ha-client    文件:HaChannel.java   
/**
 * Synchronously send a method over this channel.
 * @param method method to transmit over this channel.
 * @return command response to method. Caller should cast as appropriate.
 * @throws IOException Problem transmitting method.
 */
Command rpc(Method method) throws IOException;