de.hybris.platform.processing.distributed.defaultimpl

Class Dispatcher

java.lang.Object

de.hybris.platform.processing.distributed.defaultimpl.Dispatcher

All Implemented Interfaces:

TaskRunner<TaskModel>

public class Dispatcher
extends java.lang.Object
implements TaskRunner<TaskModel>

Constructor Summary

Constructors

Constructor and Description
Dispatcher(TransitionsHandler transitionsHandler, ExecutionHandler executionHandler, DistributedProcessLoggingCtxFactory distributedProcessLoggingCtxFactory)

Method Summary

Modifier and Type	Method and Description
void	handleError(TaskService taskService, TaskModel task, java.lang.Throwable error)
TaskLoggingCtx	initLoggingCtx(TaskModel task)
boolean	isLoggingSupported()
void	run(TaskService taskService, TaskModel task)
void	stopLoggingCtx(TaskLoggingCtx taskCtx)

Methods inherited from class java.lang.Object

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

Constructor Detail

Dispatcher

public Dispatcher(TransitionsHandler transitionsHandler,
                  ExecutionHandler executionHandler,
                  DistributedProcessLoggingCtxFactory distributedProcessLoggingCtxFactory)

Method Detail

run

public void run(TaskService taskService,
                TaskModel task)
         throws RetryLaterException

Specified by:

run in interface TaskRunner<TaskModel>

Throws:

RetryLaterException

handleError

public void handleError(TaskService taskService,
                        TaskModel task,
                        java.lang.Throwable error)

Specified by:

handleError in interface TaskRunner<TaskModel>

isLoggingSupported

public boolean isLoggingSupported()

Specified by:

isLoggingSupported in interface TaskRunner<TaskModel>

initLoggingCtx

public TaskLoggingCtx initLoggingCtx(TaskModel task)

Specified by:

initLoggingCtx in interface TaskRunner<TaskModel>

stopLoggingCtx

public void stopLoggingCtx(TaskLoggingCtx taskCtx)

Specified by:

stopLoggingCtx in interface TaskRunner<TaskModel>