I want to broadcast some Apache Ignite task for some entity with ID stored
in DB of my app. At some moment I want to stop this task (may be even after
restart of my app). For this I think that I need to broadcast this task,
somehow return UUID of this task, save this task UUID near entity ID in DB
of my app. For example, if I know this task UUID (taskUuid), then I can
stop this task like this (scala code):

val clusterGroup = ignite$.cluster().forServers()
ignite$.compute(clusterGroup).broadcast(new IgniteRunnable {
  override def run(): Unit = {
    ignite$.compute().activeTaskFutures().asScala.filter(
      e => e._1.toString == taskUuid).foreach(e => e._2.cancel())
  }
})

So, my question is, how I can return this taskUuid, when I submit some task
with IgniteCompute.broadcast(...) method?

-- 
_______________             _______________
Best regards,                    С уважением
Vadim Dedkov.                  Вадим Дедков.

Reply via email to