-
Notifications
You must be signed in to change notification settings - Fork 26
Open
Description
@WangJunTYTL 你好,我在springboot 里集成task框架 在发送异步任务时抛出了一个错误。
IDE:Intellij 15,
jdk:1.7
redis:本地启动 6379端口。
项目类型:spring boot maven
构建:task项目已经在本地构建成功。
测试:在另外eclipse中导入了task工程,在task-system中的/task-system/src/test/java/com/peaceful/task/system包下的测试代码都可以执行成功。
在报错工程中的resources目录中配置了taskContainer.conf
内容如下:
task {
# 系统命名,主要用于创建多个系统实例时的命名空间的区分
name = "task"
// 启动模式,如果是client模式,只可以提交任务,不会调度任务执行,server模式可提交任务,也可以调度任务执行
boot-mode = "server"
develop-mode = "test"
// 任务存取队列
queue = "com.peaceful.task.queue.redis.RedisQueue"
// 任务实例的bean实例获取工厂
bean-factory="com.peaceful.task.context.dispatch.TaskBeanFactoryImpl"
// 任务执行器
executor = [
{
name: "default"
# 系统默认的executor实现,基于akka的actor并发模型
implementation: "com.peaceful.task.executor.impl.actor.ActorTaskExecutor"
},
{
name: "simple"
# 最简单的executor实现
implementation: "com.peaceful.task.executor.impl.SimpleTaskExecutor"
},
{
name: "jucExecutor"
implementation: "com.peaceful.task.executor.impl.JUCTaskExecutor"
}
]
# 从MQ中拉取任务的频率
dispatch-tick = 2s
}在一个业务方法中执行:
ActionMappingTask task = Task.registerASyncClass(ActionMappingTask.class); //此处抛出异常,就是标题中的异常。猜测:
Metadata
Metadata
Assignees
Labels
No labels