public UUID registerStaticRoutine(String cacheName,CacheEntryUpdatedListener<?,?> locLsnr,CacheEntryEventSerializableFilter rmtFilter,@Nullable IgnitePredicate<ClusterNode> prjPred) throws IgniteCheckedException {
  String topicPrefix="CONTINUOUS_QUERY_STATIC" + "_" + cacheName;
  CacheContinuousQueryHandler hnd=new CacheContinuousQueryHandler(cacheName,TOPIC_CACHE.topic(topicPrefix,ctx.localNodeId(),seq.incrementAndGet()),locLsnr,rmtFilter,true,false,true,false);
  hnd.internal(true);
  final UUID routineId=UUID.randomUUID();
  LocalRoutineInfo routineInfo=new LocalRoutineInfo(prjPred,hnd,1,0,true);
  locInfos.put(routineId,routineInfo);
  registerMessageListener(hnd);
  return routineId;
}

public UUID registerStaticRoutine ( String cacheName , CacheEntryUpdatedListener < ? , ? > locLsnr , CacheEntryEventSerializableFilter rmtFilter , @ Nullable IgnitePredicate < ClusterNode > prjPred ) throws IgniteCheckedException { String topicPrefix = "CONTINUOUS_QUERY_STATIC" + "_" + cacheName ; CacheContinuousQueryHandler hnd = new CacheContinuousQueryHandler ( cacheName , TOPIC_CACHE . topic ( topicPrefix , ctx . localNodeId ( ) , seq . incrementAndGet ( ) ) , locLsnr , rmtFilter , true , false , true , false ) ; hnd . internal ( true ) ; final UUID routineId = UUID . randomUUID ( ) ; LocalRoutineInfo routineInfo = new LocalRoutineInfo ( prjPred , hnd , 1 , 0 , true ) ; locInfos . put ( routineId , routineInfo ) ; registerMessageListener ( hnd ) ; return routineId ; }
registers routine info to be sent in discovery data during this node join ( to be used for internal queries started from client nodes ) .
