akka.actor.Address.hasLocalScope()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(2.5k)|赞(0)|评价(0)|浏览(128)

本文整理了Java中akka.actor.Address.hasLocalScope()方法的一些代码示例,展示了Address.hasLocalScope()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Address.hasLocalScope()方法的具体详情如下:
包路径:akka.actor.Address
类名称:Address
方法名:hasLocalScope

Address.hasLocalScope介绍

暂无

代码示例

代码示例来源:origin: com.alibaba.blink/flink-runtime

AkkaInvocationHandler(
    String address,
    String hostname,
    ActorRef rpcEndpoint,
    Time timeout,
    long maximumFramesize,
    @Nullable CompletableFuture<Void> terminationFuture) {
  this.address = Preconditions.checkNotNull(address);
  this.hostname = Preconditions.checkNotNull(hostname);
  this.rpcEndpoint = Preconditions.checkNotNull(rpcEndpoint);
  this.isLocal = this.rpcEndpoint.path().address().hasLocalScope();
  this.timeout = Preconditions.checkNotNull(timeout);
  this.maximumFramesize = maximumFramesize;
  this.terminationFuture = terminationFuture;
}

代码示例来源:origin: org.apache.flink/flink-runtime

AkkaInvocationHandler(
    String address,
    String hostname,
    ActorRef rpcEndpoint,
    Time timeout,
    long maximumFramesize,
    @Nullable CompletableFuture<Void> terminationFuture) {
  this.address = Preconditions.checkNotNull(address);
  this.hostname = Preconditions.checkNotNull(hostname);
  this.rpcEndpoint = Preconditions.checkNotNull(rpcEndpoint);
  this.isLocal = this.rpcEndpoint.path().address().hasLocalScope();
  this.timeout = Preconditions.checkNotNull(timeout);
  this.maximumFramesize = maximumFramesize;
  this.terminationFuture = terminationFuture;
}

代码示例来源:origin: org.apache.flink/flink-runtime_2.11

AkkaInvocationHandler(
    String address,
    String hostname,
    ActorRef rpcEndpoint,
    Time timeout,
    long maximumFramesize,
    @Nullable CompletableFuture<Void> terminationFuture) {
  this.address = Preconditions.checkNotNull(address);
  this.hostname = Preconditions.checkNotNull(hostname);
  this.rpcEndpoint = Preconditions.checkNotNull(rpcEndpoint);
  this.isLocal = this.rpcEndpoint.path().address().hasLocalScope();
  this.timeout = Preconditions.checkNotNull(timeout);
  this.maximumFramesize = maximumFramesize;
  this.terminationFuture = terminationFuture;
}

代码示例来源:origin: org.apache.flink/flink-runtime_2.10

AkkaInvocationHandler(
    String address,
    String hostname,
    ActorRef rpcEndpoint,
    Time timeout,
    long maximumFramesize,
    Future<Void> terminationFuture) {
  this.address = Preconditions.checkNotNull(address);
  this.hostname = Preconditions.checkNotNull(hostname);
  this.rpcEndpoint = Preconditions.checkNotNull(rpcEndpoint);
  this.isLocal = this.rpcEndpoint.path().address().hasLocalScope();
  this.timeout = Preconditions.checkNotNull(timeout);
  this.maximumFramesize = maximumFramesize;
  this.terminationFuture = terminationFuture;
}

相关文章