public void onCacheStart(GridCacheContext ctx) throws IgniteCheckedException {
  for (  Map.Entry<UUID,RemoteRoutineInfo> entry : rmtInfos.entrySet()) {
    UUID routineId=entry.getKey();
    RemoteRoutineInfo rmtInfo=entry.getValue();
    GridContinuousHandler hnd=rmtInfo.hnd;
    if (hnd.isQuery() && F.eq(ctx.name(),hnd.cacheName()) && rmtInfo.clearDelayedRegister()) {
      GridContinuousHandler.RegisterStatus status=hnd.register(rmtInfo.nodeId,routineId,this.ctx);
      assert status != GridContinuousHandler.RegisterStatus.DELAYED;
    }
  }
}

public void onCacheStart ( GridCacheContext ctx ) throws IgniteCheckedException { for ( Map . Entry < UUID , RemoteRoutineInfo > entry : rmtInfos . entrySet ( ) ) { UUID routineId = entry . getKey ( ) ; RemoteRoutineInfo rmtInfo = entry . getValue ( ) ; GridContinuousHandler hnd = rmtInfo . hnd ; if ( hnd . isQuery ( ) && F . eq ( ctx . name ( ) , hnd . cacheName ( ) ) && rmtInfo . clearDelayedRegister ( ) ) { GridContinuousHandler . RegisterStatus status = hnd . register ( rmtInfo . nodeId , routineId , this . ctx ) ; assert status != GridContinuousHandler . RegisterStatus . DELAYED ; } } }
callback invoked when cache is started .
