Package 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	Description
KymaEventEmitTaskRunner()

Method Summary

Modifier and Type	Method	Description
protected DestinationService<AbstractDestinationModel>	getDestinationService()
protected org.springframework.messaging.MessageChannel	getEventChannel()
protected EventService	getEventService()
protected Converter<PublishRequestData,JsonPublishRequestData>	getKymaJsonEventConverter()
protected RestTemplateWrapper	getRestTemplate()
void	handleError(TaskService taskService, TaskModel taskModel, java.lang.Throwable error)
protected void	logException(java.lang.Exception e, PublishRequestData publishRequestData)
protected boolean	retryEventEmitting(org.springframework.http.HttpEntity<java.lang.String> request, PublishRequestData publishRequestData, java.lang.String url, AbstractDestinationModel destination)
void	run(TaskService taskService, TaskModel task)
protected java.lang.String	sanitize(java.lang.String logMsg)
protected void	scheduleEventEmitTask(org.springframework.messaging.Message message, PublishRequestData publishRequestData, java.lang.Integer retry)
protected void	scheduleRetry()
void	setDestinationService(DestinationService<AbstractDestinationModel> destinationService)
void	setEventChannel(org.springframework.messaging.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>

scheduleEventEmitTask

protected void scheduleEventEmitTask(org.springframework.messaging.Message message,
                                     PublishRequestData publishRequestData,
                                     java.lang.Integer retry)

logException

protected void logException(java.lang.Exception e,
                            PublishRequestData publishRequestData)

handleError

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

Specified by:

handleError in interface TaskRunner<TaskModel>

scheduleRetry

protected void scheduleRetry()

retryEventEmitting

protected boolean retryEventEmitting(org.springframework.http.HttpEntity<java.lang.String> request,
                                     PublishRequestData publishRequestData,
                                     java.lang.String url,
                                     AbstractDestinationModel destination)

sanitize

protected java.lang.String sanitize(java.lang.String logMsg)

getRestTemplate

protected RestTemplateWrapper getRestTemplate()

setRestTemplate

public void setRestTemplate(RestTemplateWrapper restTemplate)

getDestinationService

protected DestinationService<AbstractDestinationModel> getDestinationService()

setDestinationService

public void setDestinationService(DestinationService<AbstractDestinationModel> destinationService)

getEventChannel

protected org.springframework.messaging.MessageChannel getEventChannel()

setEventChannel

public void setEventChannel(org.springframework.messaging.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)