Class KeyAffinityServiceImpl<K>

    • Constructor Detail

    • Method Detail

      • getCollocatedKey

        public K getCollocatedKey​(K otherKey)
        Description copied from interface: KeyAffinityService
        Returns a key that will be distributed on the same node as the supplied key.
        Specified by:
        getCollocatedKey in interface KeyAffinityService<K>
        Parameters:
        otherKey - the key for which we need a collocation
        Returns:
        a key object
      • getKeyForAddress

        public K getKeyForAddress​(Address address)
        Description copied from interface: KeyAffinityService
        Returns a key that will be distributed on the cluster node identified by address.
        Specified by:
        getKeyForAddress in interface KeyAffinityService<K>
        Parameters:
        address - identifying the cluster node.
        Returns:
        a key object
      • start

        public void start()
        Description copied from interface: Lifecycle
        Invoked on component start
        Specified by:
        start in interface Lifecycle
      • stop

        public void stop()
        Description copied from interface: Lifecycle
        Invoked on component stop
        Specified by:
        stop in interface Lifecycle
      • isKeyGeneratorThreadAlive

        public boolean isKeyGeneratorThreadAlive()
      • getMaxNumberOfKeys

        public int getMaxNumberOfKeys()
      • isKeyGeneratorThreadActive

        public boolean isKeyGeneratorThreadActive()