@ Start ( priority = 20 ) public void start ( ) { cacheName = cache . wired ( ) . getName ( ) ; isInvalidationMode = configuration . clustering ( ) . cacheMode ( ) . isInvalidation ( ) ; isTransactional = configuration . transaction ( ) . transactionMode ( ) . isTransactional ( ) ; isTotalOrder = configuration . transaction ( ) . transactionProtocol ( ) . isTotalOrder ( ) ; timeout = configuration . clustering ( ) . stateTransfer ( ) . timeout ( ) ; CacheMode mode = configuration . clustering ( ) . cacheMode ( ) ; isFetchEnabled = mode . needsStateTransfer ( ) && ( configuration . clustering ( ) . stateTransfer ( ) . fetchInMemoryState ( ) || configuration . persistence ( ) . fetchPersistentState ( ) ) ; rpcOptions = new RpcOptions ( DeliverOrder . NONE , timeout , TimeUnit . MILLISECONDS ) ; stateRequestExecutor = new LimitedExecutor ( "StateRequest-" + cacheName , stateTransferExecutor , 1 ) ; running = true ; }
Must run after the PersistenceManager