import { JobExecutor } from 'job-executor'
import { init, act } from './hemera'

const config = require('../config');

//启动hemera
init({ nats: config.nats, hemera: config.hemera })

var jobExecutor = new JobExecutor(config);

jobExecutor.register("hemera", async (args) => {
    // {
    //     topic: 'account',
    //     cmd: 'queryUserDetail',
    //     data: { userid: id }
    // }
    return act(args, true);
})