Class KymaEventEmitTaskRunner
java.lang.Object
de.hybris.platform.kymaintegrationservices.task.KymaEventEmitTaskRunner
- All Implemented Interfaces:
TaskRunner<TaskModel>
A Task Runner for Event Emitting
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected DestinationService<AbstractDestinationModel>protected org.springframework.messaging.MessageChannelprotected EventServiceprotected Converter<PublishRequestData,JsonPublishRequestData> protected RestTemplateWrappervoidhandleError(TaskService taskService, TaskModel taskModel, Throwable error) protected voidlogException(Exception e, PublishRequestData publishRequestData) protected booleanretryEventEmitting(org.springframework.http.HttpEntity<String> request, PublishRequestData publishRequestData, String url, AbstractDestinationModel destination) voidrun(TaskService taskService, TaskModel task) protected Stringprotected voidscheduleEventEmitTask(org.springframework.messaging.Message message, PublishRequestData publishRequestData, Integer retry) protected voidvoidsetDestinationService(DestinationService<AbstractDestinationModel> destinationService) voidsetEventChannel(org.springframework.messaging.MessageChannel eventChannel) voidsetEventService(EventService eventService) voidsetKymaJsonEventConverter(Converter<PublishRequestData, JsonPublishRequestData> kymaJsonEventConverter) voidsetRestTemplate(RestTemplateWrapper restTemplate) Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface de.hybris.platform.task.TaskRunner
initLoggingCtx, isLoggingSupported, stopLoggingCtx
-
Constructor Details
-
KymaEventEmitTaskRunner
public KymaEventEmitTaskRunner()
-
-
Method Details
-
run
- Specified by:
runin interfaceTaskRunner<TaskModel>
-
scheduleEventEmitTask
protected void scheduleEventEmitTask(org.springframework.messaging.Message message, PublishRequestData publishRequestData, Integer retry) -
logException
-
handleError
- Specified by:
handleErrorin interfaceTaskRunner<TaskModel>
-
scheduleRetry
protected void scheduleRetry() -
retryEventEmitting
protected boolean retryEventEmitting(org.springframework.http.HttpEntity<String> request, PublishRequestData publishRequestData, String url, AbstractDestinationModel destination) -
sanitize
-
getRestTemplate
-
setRestTemplate
-
getDestinationService
-
setDestinationService
-
getEventChannel
protected org.springframework.messaging.MessageChannel getEventChannel() -
setEventChannel
public void setEventChannel(org.springframework.messaging.MessageChannel eventChannel) -
getEventService
-
setEventService
-
getKymaJsonEventConverter
-
setKymaJsonEventConverter
public void setKymaJsonEventConverter(Converter<PublishRequestData, JsonPublishRequestData> kymaJsonEventConverter)
-