akka.actor.ActorPath.address()方法的使用及代码示例

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

ActorPath.address介绍

暂无

代码示例

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

@Override
public BlobCache checkedApply(Object result) throws IOException {
Option hostOption = jobManager.actor().path().address().host();
String host = hostOption.isDefined() ? hostOption.get() : "localhost";
int port = (int) result;
return new BlobCache(new InetSocketAddress(host, port), config, blobView);
}
}, executor);

代码示例来源：origin: org.opendaylight.controller/sal-remoterpc-connector

@Override
public Void apply(Object msg) {
if (msg instanceof GetBucketsByMembersReply) {
Map buckets = ((GetBucketsByMembersReply) msg).getBuckets();
if(log.isTraceEnabled()) {
log.trace("Buckets to send from {}: {}", selfAddress, buckets);
}
GossipEnvelope envelope = new GossipEnvelope(selfAddress, sender.path().address(), buckets);
sender.tell(envelope, getSelf());
}
return null;
}
};

代码示例来源：origin: opendaylight/controller

remote.tell(new GossipEnvelope(selfAddress, remote.path().address(), buckets), getSelf());
});

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

private Tuple2 extractAddressHostname(ActorRef actorRef) {
final String actorAddress = AkkaUtils.getAkkaURL(actorSystem, actorRef);
final String hostname;
Option host = actorRef.path().address().host();
if (host.isEmpty()) {
hostname = "localhost";
} else {
hostname = host.get();
}
return Tuple2.of(actorAddress, hostname);
}

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

public AkkaJobManagerGateway(ActorGateway jobManagerGateway) {
this.jobManagerGateway = Preconditions.checkNotNull(jobManagerGateway);
final Option optHostname = jobManagerGateway.actor().path().address().host();
hostname = optHostname.isDefined() ? optHostname.get() : "localhost";
}

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

private Tuple2 extractAddressHostname(ActorRef actorRef) {
final String actorAddress = AkkaUtils.getAkkaURL(actorSystem, actorRef);
final String hostname;
Option host = actorRef.path().address().host();
if (host.isEmpty()) {
hostname = "localhost";
} else {
hostname = host.get();
}
return Tuple2.of(actorAddress, hostname);
}

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

public AkkaJobManagerGateway(ActorGateway jobManagerGateway) {
this.jobManagerGateway = Preconditions.checkNotNull(jobManagerGateway);
final Option optHostname = jobManagerGateway.actor().path().address().host();
hostname = optHostname.isDefined() ? optHostname.get() : "localhost";
}

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

private Tuple2 extractAddressHostname(ActorRef actorRef) {
final String actorAddress = AkkaUtils.getAkkaURL(actorSystem, actorRef);
final String hostname;
Option host = actorRef.path().address().host();
if (host.isEmpty()) {
hostname = "localhost";
} else {
hostname = host.get();
}
return Tuple2.of(actorAddress, hostname);
}

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

public AkkaJobManagerGateway(ActorGateway jobManagerGateway) {
this.jobManagerGateway = Preconditions.checkNotNull(jobManagerGateway);
final Option optHostname = jobManagerGateway.actor().path().address().host();
hostname = optHostname.isDefined() ? optHostname.get() : "localhost";
}

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

AkkaInvocationHandler(
String address,
String hostname,
ActorRef rpcEndpoint,
Time timeout,
long maximumFramesize,
@Nullable CompletableFuture 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

LOG.info("Blob client connecting to " + jobManager.path());
Option jmHost = jobManager.actor().path().address().host();
String jmHostname = jmHost.isDefined() ? jmHost.get() : "localhost";
InetSocketAddress serverAddress = new InetSocketAddress(jmHostname, port);

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

AkkaInvocationHandler(
String address,
String hostname,
ActorRef rpcEndpoint,
Time timeout,
long maximumFramesize,
@Nullable CompletableFuture 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 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: com.alibaba.blink/flink-runtime

Option host = actorRef.path().address().host();
if (host.isEmpty()) {
hostname = "localhost";

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

Option host = actorRef.path().address().host();
if (host.isEmpty()) {
hostname = "localhost";

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

Option host = actorRef.path().address().host();
if (host.isEmpty()) {
hostname = "localhost";

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

AkkaInvocationHandler(
String address,
String hostname,
ActorRef rpcEndpoint,
Time timeout,
long maximumFramesize,
Future 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.opendaylight.controller/sal-akka-raft

Address leaderAddress = leaderActor.anchorPath().address();

代码示例来源：origin: org.eclipse.ditto/ditto-services-connectivity-messaging

aggregatedResults.add((CommandResponse) any);
} else if (any instanceof Status.Status) {
aggregatedStatus.put(getSender().path().address().hostPort(),
(Status.Status) any);
} else if (any instanceof DittoRuntimeException) {

代码示例来源：origin: eclipse/ditto

aggregatedResults.add((CommandResponse) any);
} else if (any instanceof Status.Status) {
aggregatedStatus.put(getSender().path().address().hostPort(),
(Status.Status) any);
} else if (any instanceof DittoRuntimeException) {