com.caucho.server.distlock
Class VoteActor

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.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