com.caucho.distcache.cluster
Class CacheDataTriadActor

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.distcache.cluster.CacheDataActor
                  extended by com.caucho.distcache.cluster.CacheDataTriadActor
All Implemented Interfaces:
Actor, ActorHolder, ManagedActor, MessageStream

public class CacheDataTriadActor
extends CacheDataActor

Actor on a triad server handling the cache data requests.


Method Summary
 void dataError(java.lang.String to, java.lang.String from, DataPut msg, BamError error)
          Handles an error from a write back to a triad
 void dataError(java.lang.String to, java.lang.String from, DataPutTriad msg, BamError error)
          Handles an error from a write back to a triad
 void dataGet(long id, java.lang.String to, java.lang.String from, DataGet msg)
          Called as a request for data from another server.
 void dataPut(long id, java.lang.String to, java.lang.String from, DataPut msg)
          receive updated data
 void dataPutMessage(java.lang.String to, java.lang.String from, DataPut msg)
          receive updated data
 void dataPutTriad(long id, java.lang.String to, java.lang.String from, DataPutTriad msg)
          updated data
 
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, 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
 

Method Detail

dataGet

@Query
public void dataGet(long id,
                          java.lang.String to,
                          java.lang.String from,
                          DataGet msg)
Called as a request for data from another server.


dataPut

@Query
public void dataPut(long id,
                          java.lang.String to,
                          java.lang.String from,
                          DataPut msg)
receive updated data


dataPutMessage

@Message
public void dataPutMessage(java.lang.String to,
                                   java.lang.String from,
                                   DataPut msg)
receive updated data


dataPutTriad

@Query
public void dataPutTriad(long id,
                               java.lang.String to,
                               java.lang.String from,
                               DataPutTriad msg)
updated data


dataError

@MessageError
public void dataError(java.lang.String to,
                                   java.lang.String from,
                                   DataPut msg,
                                   BamError error)
Handles an error from a write back to a triad


dataError

@MessageError
public void dataError(java.lang.String to,
                                   java.lang.String from,
                                   DataPutTriad msg,
                                   BamError error)
Handles an error from a write back to a triad