com.caucho.cloud.heartbeat
Class HeartbeatActor

java.lang.Object
  extended by com.caucho.bam.stream.AbstractMessageStream
      extended by com.caucho.bam.actor.SimpleActor
          extended by com.caucho.cloud.bam.AbstractCloudActor
              extended by com.caucho.cloud.heartbeat.HeartbeatActor
All Implemented Interfaces:
Actor, ActorHolder, ManagedActor, MessageStream, ClusterLinkListener

public class HeartbeatActor
extends AbstractCloudActor
implements ClusterLinkListener

Service for handling the cache messages


Field Summary
static java.lang.String UID
           
 
Constructor Summary
HeartbeatActor(CloudServer selfServer)
           
 
Method Summary
protected  MailboxType getMailboxType()
          The heartbeat messages must be processed immediately without queuing.
 void onLinkClose(java.lang.Object payload)
          Notification that a cluster link has closed.
 void serverHeartbeat(java.lang.String to, java.lang.String from, HeartbeatMessage msg)
          Triad receives message that a server has started
 void start()
          Sends a server start message to the pod
 void stop()
          Sends a server start message to the pod
 
Methods inherited from class com.caucho.cloud.bam.AbstractCloudActor
dbgId, getBamSender, getManagedBroker, getPod, registerActor
 
Methods inherited from class com.caucho.bam.actor.SimpleActor
getActor, getAddress, getBroker, getMailbox, getSender, setAddress, setBroker, setMailbox
 
Methods inherited from class com.caucho.bam.stream.AbstractMessageStream
isClosed, message, messageError, query, queryError, queryResult, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface com.caucho.bam.stream.MessageStream
isClosed, message, messageError, query, queryError, queryResult
 

Field Detail

UID

public static final java.lang.String UID
See Also:
Constant Field Values
Constructor Detail

HeartbeatActor

public HeartbeatActor(CloudServer selfServer)
Method Detail

getMailboxType

protected MailboxType getMailboxType()
The heartbeat messages must be processed immediately without queuing.

Overrides:
getMailboxType in class AbstractCloudActor

start

public void start()
Sends a server start message to the pod


stop

public void stop()
Sends a server start message to the pod


serverHeartbeat

@Message
public void serverHeartbeat(java.lang.String to,
                                    java.lang.String from,
                                    HeartbeatMessage msg)
Triad receives message that a server has started


onLinkClose

public void onLinkClose(java.lang.Object payload)
Description copied from interface: ClusterLinkListener
Notification that a cluster link has closed.

Specified by:
onLinkClose in interface ClusterLinkListener