Palermo作業(yè)處理系統(tǒng)

Palermo 是一個基于 JVM 的作業(yè)處理系統(tǒng)，其靈感來自于 Resque，后端基于 RabbitMQ。 整個系統(tǒng)采用 Clojure 語言開發(fā)。

主要特性：

• 定義作業(yè) Defining jobs

• 定義作業(yè)隊列 Defining job queues

• 定義 workers

• 作業(yè)的序列化和反序列化

• 隊列管理

Palermo 同時包含一個基于 Web 的前端管理系統(tǒng)，可作為獨立的 Jetty 應用來運行。

作業(yè)任務：

package palermotests;

import palermo.job.PalermoJob;

public class SleepyJob implements PalermoJob {

    public SleepyJob(){}

    @Override
    public void process(Object arguments) throws Exception {
        int timeout = (Integer) arguments;
        System.out.println("SLEEPING...");
        try {
            Thread.sleep(timeout);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("BACK!");
    }

}