Class KymaEventEmitStrategy
java.lang.Object
de.hybris.platform.kymaintegrationservices.strategies.impl.KymaEventEmitStrategy
- All Implemented Interfaces:
EventEmitStrategy
Implementation of @
EventEmitStrategy for kyma event emitting with retries-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected DestinationService<AbstractDestinationModel>protected org.springframework.messaging.MessageChannelprotected AbstractDestinationModelDeprecated, for removal: This API element is subject to removal in a future version.since 1905.protected AbstractDestinationModelgetEventDestination(String destinationTargetId) protected EventDlqServiceprotected com.fasterxml.jackson.databind.ObjectMapperprotected Converter<PublishRequestData,JsonPublishRequestData> protected ModelServiceprotected RestTemplateWrapperDeprecated, for removal: This API element is subject to removal in a future version.since 1905, for naming convention.protected RestTemplateWrapperprotected TaskServiceprotected voidhandleFailedEvent(Exception e, PublishRequestData publishRequestData) protected booleanretryEventEmitting(org.springframework.http.HttpEntity<String> request, PublishRequestData publishRequestData, String url, AbstractDestinationModel destination) protected voidscheduleEventEmitTask(org.springframework.messaging.Message message, PublishRequestData publishRequestData) voidprotected voidsendPublishRequestData(org.springframework.messaging.Message message, PublishRequestData publishRequestData) protected voidsendToDlq(PublishRequestData publishRequestData, DestinationTargetModel destinationTarget, String error) voidsetDestinationService(DestinationService<AbstractDestinationModel> destinationService) voidsetEventChannel(org.springframework.messaging.MessageChannel eventChannel) voidsetEventDlqService(EventDlqService eventDlqService) voidsetJacksonObjectMapper(com.fasterxml.jackson.databind.ObjectMapper jacksonObjectMapper) voidsetKymaJsonEventConverter(Converter<PublishRequestData, JsonPublishRequestData> kymaJsonEventConverter) voidsetModelService(ModelService modelService) voidsetRestTemplate(RestTemplateWrapper restTemplate) Deprecated, for removal: This API element is subject to removal in a future version.since 1905, for naming convention.voidsetRestTemplateWrapper(RestTemplateWrapper restTemplateWrapper) voidsetTaskService(TaskService taskService) protected boolean
-
Constructor Details
-
KymaEventEmitStrategy
public KymaEventEmitStrategy()
-
-
Method Details
-
sendEvent
- Specified by:
sendEventin interfaceEventEmitStrategy
-
sendPublishRequestData
protected void sendPublishRequestData(org.springframework.messaging.Message message, PublishRequestData publishRequestData) -
handleFailedEvent
-
scheduleEventEmitTask
protected void scheduleEventEmitTask(org.springframework.messaging.Message message, PublishRequestData publishRequestData) -
retryEventEmitting
protected boolean retryEventEmitting(org.springframework.http.HttpEntity<String> request, PublishRequestData publishRequestData, String url, AbstractDestinationModel destination) -
shouldSendToDlq
-
sendToDlq
protected void sendToDlq(PublishRequestData publishRequestData, DestinationTargetModel destinationTarget, String error) -
getEventDestination
Deprecated, for removal: This API element is subject to removal in a future version.since 1905. UsegetEventDestination(String) -
getEventDestination
-
getModelService
-
setModelService
-
getTaskService
-
setTaskService
-
getRestTemplate
Deprecated, for removal: This API element is subject to removal in a future version.since 1905, for naming convention. Use getRestTemplateWrapper instead. -
getRestTemplateWrapper
-
setRestTemplate
@Deprecated(since="1905", forRemoval=true) public void setRestTemplate(RestTemplateWrapper restTemplate) Deprecated, for removal: This API element is subject to removal in a future version.since 1905, for naming convention. Use setRestTemplateWrapper instead. -
setRestTemplateWrapper
-
getDestinationService
-
setDestinationService
-
getEventDlqService
-
setEventDlqService
-
getJacksonObjectMapper
protected com.fasterxml.jackson.databind.ObjectMapper getJacksonObjectMapper() -
setJacksonObjectMapper
public void setJacksonObjectMapper(com.fasterxml.jackson.databind.ObjectMapper jacksonObjectMapper) -
getEventChannel
protected org.springframework.messaging.MessageChannel getEventChannel() -
setEventChannel
public void setEventChannel(org.springframework.messaging.MessageChannel eventChannel) -
getKymaJsonEventConverter
-
setKymaJsonEventConverter
public void setKymaJsonEventConverter(Converter<PublishRequestData, JsonPublishRequestData> kymaJsonEventConverter)
-