Package org.infinispan.xsite.statetransfer

Class XSiteStateConsumerImpl

  • All Implemented Interfaces:
    XSiteStateConsumer
    public class XSiteStateConsumerImpl
extends java.lang.Object
implements XSiteStateConsumer
    It contains the logic needed to consume the state sent from other site.
    Since:
    7.0
    Author:
    Pedro Ruivo

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void applyState​(XSiteState[] chunk)
      It applies state from other site.
      void endStateTransfer​(java.lang.String sendingSite)
      It notifies the end of state transfer from other site.
      java.lang.String getSendingSiteName()  
      void startStateTransfer​(java.lang.String sendingSite)
      It notifies the start of state transfer from other site.

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • XSiteStateConsumerImpl

        public XSiteStateConsumerImpl()

    • Method Detail

      • startStateTransfer

        public void startStateTransfer​(java.lang.String sendingSite)
        Description copied from interface: XSiteStateConsumer
        It notifies the start of state transfer from other site.
        Specified by:
        startStateTransfer in interface XSiteStateConsumer
        Parameters:
        sendingSite - the site name that will send the state.

      • endStateTransfer

        public void endStateTransfer​(java.lang.String sendingSite)
        Description copied from interface: XSiteStateConsumer
        It notifies the end of state transfer from other site.
        Specified by:
        endStateTransfer in interface XSiteStateConsumer
        Parameters:
        sendingSite - the site name that is sending the state.

      • applyState

        public void applyState​(XSiteState[] chunk)
                throws java.lang.Exception
        Description copied from interface: XSiteStateConsumer
        It applies state from other site.
        Specified by:
        applyState in interface XSiteStateConsumer
        Parameters:
        chunk - a chunk of keys
        Throws:
        java.lang.Exception - if something go wrong while applying the state

      • getSendingSiteName

        public java.lang.String getSendingSiteName()
        Specified by:
        getSendingSiteName in interface XSiteStateConsumer
        Returns:
        the site name that is sending the state.