public class JobInfo extends Object implements scala.Serializable
JobManager
. The JobInfo stores which actor
submitted the job, when the start time and, if already terminated, the end time was.
Additionally, it stores whether the job was started in the detached mode. Detached means that
the submitting actor does not wait for the job result once the job has terminated.
Important: This class is serializable, but needs to be deserialized in the context of an actor
system in order to resolve the client ActorRef
. It is possible to serialize the Akka URL
manually, but it is cumbersome and complicates testing in certain scenarios, where you need to
make sure to resolve the correct ActorRef
s when submitting jobs (RepointableActorRef vs.
RemoteActorRef).
Constructor and Description |
---|
JobInfo(akka.actor.ActorRef client,
ListeningBehaviour listeningBehaviour,
long start,
long sessionTimeout) |
Modifier and Type | Method and Description |
---|---|
static JobInfo |
apply(akka.actor.ActorRef client,
ListeningBehaviour listeningBehaviour,
long start,
long sessionTimeout) |
akka.actor.ActorRef |
client() |
long |
duration() |
long |
end() |
long |
lastActive() |
ListeningBehaviour |
listeningBehaviour() |
boolean |
sessionAlive() |
long |
sessionTimeout() |
void |
setLastActive() |
long |
start() |
String |
toString() |
public JobInfo(akka.actor.ActorRef client, ListeningBehaviour listeningBehaviour, long start, long sessionTimeout)
public static JobInfo apply(akka.actor.ActorRef client, ListeningBehaviour listeningBehaviour, long start, long sessionTimeout)
public akka.actor.ActorRef client()
public ListeningBehaviour listeningBehaviour()
public long start()
public long sessionTimeout()
public boolean sessionAlive()
public long lastActive()
public long end()
public long duration()
public void setLastActive()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.