Interface ClusterAwareService

  • All Superinterfaces:
    java.lang.Comparable<KieService>, KieService

    public interface ClusterAwareService
    extends KieService
    Interface that allows to rise some awareness about the cluster environment
    • Method Detail

      • isCoordinator

        boolean isCoordinator()
        Computes whether the jbpm engine instance is the coordinator therefore the one to provide singleton cluster active features.
        Returns:
        whether this instance of jbpm engine is the one coordinating or not.
      • getActiveClusterNodes

        java.util.Collection<ClusterNode> getActiveClusterNodes()
        Get all active members of the cluster
      • removeData

        <T> void removeData​(java.lang.String key,
                            java.lang.String partition,
                            T value)
      • addData

        <T> void addData​(java.lang.String key,
                         java.lang.String partition,
                         T value)
      • getData

        <T> java.util.List<T> getData​(java.lang.String key)
      • getDataFromPartition

        <T> java.util.List<T> getDataFromPartition​(java.lang.String key,
                                                   java.lang.String partition)
      • addClusterListener

        void addClusterListener​(ClusterListener listener)
        Add cluster listener for join and left members
        Parameters:
        listener -