com.caucho.distcache.cluster
Class CacheDataTriadActor

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