com.caucho.server.distlock
Class VoteActor

java.lang.Object
  com.caucho.bam.stream.AbstractMessageStream
      com.caucho.bam.actor.SimpleActor
          com.caucho.cloud.bam.AbstractCloudActor
              com.caucho.server.distlock.VoteActor

All Implemented Interfaces:

Actor, ActorHolder, ManagedActor, MessageStream, ClusterServerListener

public class VoteActor
extends AbstractCloudActor
implements ClusterServerListener

Service for handling the distributed lock

Constructor Summary

VoteActor(CloudServer selfServer)

Method Summary

ProVoteManager	getManager()
void	serverStart(ClusterServer server) Called when a server starts.
void	serverStop(ClusterServer server) Called when a server stops.
java.lang.String	toString()
void	voteGet(long id, java.lang.String to, java.lang.String from, VoteMessage msg)

Methods inherited from class com.caucho.cloud.bam.AbstractCloudActor

dbgId, getBamSender, getMailboxType, 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

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

Constructor Detail

VoteActor

public VoteActor(CloudServer selfServer)

Method Detail

getManager

public ProVoteManager getManager()

serverStart

public void serverStart(ClusterServer server)

Called when a server starts.

Specified by:

serverStart in interface ClusterServerListener

serverStop

public void serverStop(ClusterServer server)

Called when a server stops.

Specified by:

serverStop in interface ClusterServerListener

voteGet

@Query
public void voteGet(long id,
                          java.lang.String to,
                          java.lang.String from,
                          VoteMessage msg)

toString

public java.lang.String toString()

Overrides:

toString in class AbstractMessageStream