com.caucho.cloud.heartbeat
Class HeartbeatActor

java.lang.Object
  com.caucho.bam.stream.AbstractMessageStream
      com.caucho.bam.actor.SimpleActor
          com.caucho.cloud.bam.AbstractCloudActor
              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