Package de.hybris.platform.kymaintegrationservices.strategies.impl

Class KymaEventEmitStrategy

java.lang.Object

de.hybris.platform.kymaintegrationservices.strategies.impl.KymaEventEmitStrategy

All Implemented Interfaces:

EventEmitStrategy

public class KymaEventEmitStrategy
extends java.lang.Object
implements EventEmitStrategy

Implementation of @EventEmitStrategy for kyma event emitting with retries

Constructor Summary

Constructors

Constructor	Description
KymaEventEmitStrategy()

Method Summary

Modifier and Type	Method	Description
protected DestinationService<AbstractDestinationModel>	getDestinationService()
protected org.springframework.messaging.MessageChannel	getEventChannel()
protected AbstractDestinationModel	getEventDestination()	Deprecated, for removal: This API element is subject to removal in a future version. since 1905.
protected AbstractDestinationModel	getEventDestination(java.lang.String destinationTargetId)
protected EventDlqService	getEventDlqService()
protected com.fasterxml.jackson.databind.ObjectMapper	getJacksonObjectMapper()
protected Converter<PublishRequestData,JsonPublishRequestData>	getKymaJsonEventConverter()
protected ModelService	getModelService()
protected RestTemplateWrapper	getRestTemplate()	Deprecated, for removal: This API element is subject to removal in a future version. since 1905, for naming convention.
protected RestTemplateWrapper	getRestTemplateWrapper()
protected TaskService	getTaskService()
protected void	handleFailedEvent(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)
protected void	scheduleEventEmitTask(org.springframework.messaging.Message message, PublishRequestData publishRequestData)
void	sendEvent(java.lang.Object object)
protected void	sendPublishRequestData(org.springframework.messaging.Message message, PublishRequestData publishRequestData)
protected void	sendToDlq(PublishRequestData publishRequestData, DestinationTargetModel destinationTarget, java.lang.String error)
void	setDestinationService(DestinationService<AbstractDestinationModel> destinationService)
void	setEventChannel(org.springframework.messaging.MessageChannel eventChannel)
void	setEventDlqService(EventDlqService eventDlqService)
void	setJacksonObjectMapper(com.fasterxml.jackson.databind.ObjectMapper jacksonObjectMapper)
void	setKymaJsonEventConverter(Converter<PublishRequestData,JsonPublishRequestData> kymaJsonEventConverter)
void	setModelService(ModelService modelService)
void	setRestTemplate(RestTemplateWrapper restTemplate)	Deprecated, for removal: This API element is subject to removal in a future version. since 1905, for naming convention.
void	setRestTemplateWrapper(RestTemplateWrapper restTemplateWrapper)
void	setTaskService(TaskService taskService)
protected boolean	shouldSendToDlq(java.lang.Exception e)

Methods inherited from class java.lang.Object

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

Constructor Detail

KymaEventEmitStrategy

public KymaEventEmitStrategy()

Method Detail

sendEvent

public void sendEvent(java.lang.Object object)

Specified by:

sendEvent in interface EventEmitStrategy

sendPublishRequestData

protected void sendPublishRequestData(org.springframework.messaging.Message message,
                                      PublishRequestData publishRequestData)

handleFailedEvent

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

scheduleEventEmitTask

protected void scheduleEventEmitTask(org.springframework.messaging.Message message,
                                     PublishRequestData publishRequestData)

retryEventEmitting

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

shouldSendToDlq

protected boolean shouldSendToDlq(java.lang.Exception e)

sendToDlq

protected void sendToDlq(PublishRequestData publishRequestData,
                         DestinationTargetModel destinationTarget,
                         java.lang.String error)

getEventDestination

@Deprecated(since="1905",
            forRemoval=true)
protected AbstractDestinationModel getEventDestination()

Deprecated, for removal: This API element is subject to removal in a future version.

since 1905. Use getEventDestination(String)

getEventDestination

protected AbstractDestinationModel getEventDestination(java.lang.String destinationTargetId)

getModelService

protected ModelService getModelService()

setModelService

public void setModelService(ModelService modelService)

getTaskService

protected TaskService getTaskService()

setTaskService

public void setTaskService(TaskService taskService)

getRestTemplate

@Deprecated(since="1905",
            forRemoval=true)
protected RestTemplateWrapper getRestTemplate()

Deprecated, for removal: This API element is subject to removal in a future version.

since 1905, for naming convention. Use getRestTemplateWrapper instead.

getRestTemplateWrapper

protected RestTemplateWrapper 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

public void setRestTemplateWrapper(RestTemplateWrapper restTemplateWrapper)

getDestinationService

protected DestinationService<AbstractDestinationModel> getDestinationService()

setDestinationService

public void setDestinationService(DestinationService<AbstractDestinationModel> destinationService)

getEventDlqService

protected EventDlqService getEventDlqService()

setEventDlqService

public void setEventDlqService(EventDlqService eventDlqService)

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

protected Converter<PublishRequestData,JsonPublishRequestData> getKymaJsonEventConverter()

setKymaJsonEventConverter

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