Package com.eka.middleware.distributed

Class QueueTaskExecuter

java.lang.Object

com.eka.middleware.distributed.QueueTaskExecuter

public class QueueTaskExecuter
extends Object

Constructor Summary

Constructors

Constructor	Description
QueueTaskExecuter()

Method Summary

Modifier and Type	Method	Description
static void	execute(Tenant tenant, String json, String fqn)
static List<Map>	listActiveServices(Tenant tenant)
static List<String>	listPendingBatches(Tenant tenant)
static List<Map>	listPendingTasks(Tenant tenant)
static void	start(Tenant tenant)
static void	start(Tenant tenant, String queueName, String fqn)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

QueueTaskExecuter

public QueueTaskExecuter()

Method Details

listPendingBatches

public static List<String> listPendingBatches(Tenant tenant)

listPendingTasks

public static List<Map> listPendingTasks(Tenant tenant)

listActiveServices

public static List<Map> listActiveServices(Tenant tenant)

start

public static void start(Tenant tenant)

start

public static void start(Tenant tenant,
 String queueName,
 String fqn)

execute

public static void execute(Tenant tenant,
 String json,
 String fqn)