org.jboss.cache.statetransfer

Class DefaultStateTransferIntegrator

java.lang.Object

org.jboss.cache.statetransfer.DefaultStateTransferIntegrator

All Implemented Interfaces:

StateTransferIntegrator

public class DefaultStateTransferIntegrator
extends Object
implements StateTransferIntegrator

Constructor Summary

Constructors

Constructor and Description
DefaultStateTransferIntegrator()

Method Summary

Methods

Modifier and Type	Method and Description
void	inject(CacheSPI<?,?> cache, Configuration cfg, RPCManager rpcManager, TransactionLog txLog, InvocationContextContainer container, InterceptorChain chain, ComponentRegistry registry, CommandsFactory commandsFactory)
protected void	integratePersistentState(ObjectInputStream in, Fqn targetFqn)
void	integrateState(ObjectInputStream ois, Object target, Fqn targetRoot, boolean integratePersistentState)
protected void	integrateTransientState(ObjectInputStream in, InternalNode target)
void	start()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultStateTransferIntegrator

public DefaultStateTransferIntegrator()

Method Detail

inject

public void inject(CacheSPI<?,?> cache,
          Configuration cfg,
          RPCManager rpcManager,
          TransactionLog txLog,
          InvocationContextContainer container,
          InterceptorChain chain,
          ComponentRegistry registry,
          CommandsFactory commandsFactory)

start

public void start()

integrateState

public void integrateState(ObjectInputStream ois,
                  Object target,
                  Fqn targetRoot,
                  boolean integratePersistentState)
                    throws Exception

Specified by:

integrateState in interface StateTransferIntegrator

Throws:

Exception

integrateTransientState

protected void integrateTransientState(ObjectInputStream in,
                           InternalNode target)
                                throws Exception

Throws:

Exception

integratePersistentState

protected void integratePersistentState(ObjectInputStream in,
                            Fqn targetFqn)
                                 throws Exception

Throws:

Exception