de.hybris.platform.kymaintegrationservices.task

Class KymaEventEmitTaskRunner

java.lang.Object

de.hybris.platform.kymaintegrationservices.task.KymaEventEmitTaskRunner

All Implemented Interfaces:

TaskRunner<TaskModel>

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

A Task Runner for Event Emitting

Constructor Summary

Constructors

Constructor and Description
KymaEventEmitTaskRunner()

Method Summary

Modifier and Type	Method and Description
protected DestinationService<AbstractDestinationModel>	getDestinationService()
protected MessageChannel	getEventChannel()
protected EventService	getEventService()
protected Converter<PublishRequestData,JsonPublishRequestData>	getKymaJsonEventConverter()
protected RestTemplateWrapper	getRestTemplate()
void	handleError(TaskService taskService, TaskModel taskModel, java.lang.Throwable error)
protected boolean	retryEventEmitting(<any> request, PublishRequestData publishRequestData, java.lang.String url)
void	run(TaskService taskService, TaskModel task)
protected void	scheduleRetry(java.lang.Integer retry, PublishRequestData publishRequestData)
void	setDestinationService(DestinationService<AbstractDestinationModel> destinationService)
void	setEventChannel(MessageChannel eventChannel)
void	setEventService(EventService eventService)
void	setKymaJsonEventConverter(Converter<PublishRequestData,JsonPublishRequestData> kymaJsonEventConverter)
void	setRestTemplate(RestTemplateWrapper restTemplate)

Methods inherited from class java.lang.Object

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

Methods inherited from interface de.hybris.platform.task.TaskRunner

initLoggingCtx, isLoggingSupported, stopLoggingCtx

Constructor Detail

KymaEventEmitTaskRunner

public KymaEventEmitTaskRunner()

Method Detail

run

public void run(TaskService taskService,
                TaskModel task)

Specified by:

run in interface TaskRunner<TaskModel>

handleError

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

Specified by:

handleError in interface TaskRunner<TaskModel>

scheduleRetry

protected void scheduleRetry(java.lang.Integer retry,
                             PublishRequestData publishRequestData)

retryEventEmitting

protected boolean retryEventEmitting(<any> request,
                                     PublishRequestData publishRequestData,
                                     java.lang.String url)

getRestTemplate

protected RestTemplateWrapper getRestTemplate()

setRestTemplate

public void setRestTemplate(RestTemplateWrapper restTemplate)

getDestinationService

protected DestinationService<AbstractDestinationModel> getDestinationService()

setDestinationService

public void setDestinationService(DestinationService<AbstractDestinationModel> destinationService)

getEventChannel

protected MessageChannel getEventChannel()

setEventChannel

public void setEventChannel(MessageChannel eventChannel)

getEventService

protected EventService getEventService()

setEventService

public void setEventService(EventService eventService)

getKymaJsonEventConverter

protected Converter<PublishRequestData,JsonPublishRequestData> getKymaJsonEventConverter()

setKymaJsonEventConverter

public void setKymaJsonEventConverter(Converter<PublishRequestData,JsonPublishRequestData> kymaJsonEventConverter)