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 and Description
KymaEventEmitStrategy()

Method Summary

Modifier and Type	Method and Description
protected DestinationService<AbstractDestinationModel>	getDestinationService()
protected MessageChannel	getEventChannel()
protected AbstractDestinationModel	getEventDestination()
protected EventDlqService	getEventDlqService()
protected ObjectMapper	getJacksonObjectMapper()
protected Converter<PublishRequestData,JsonPublishRequestData>	getKymaJsonEventConverter()
protected ModelService	getModelService()
protected RestTemplateWrapper	getRestTemplate()
protected TaskService	getTaskService()
protected boolean	retryEventEmitting(<any> request, PublishRequestData publishRequestData, java.lang.String url)
void	sendEvent(java.lang.Object object)
protected void	sendToDlq(PublishRequestData publishRequestData, DestinationTargetModel destinationTarget, java.lang.String error)
void	setDestinationService(DestinationService<AbstractDestinationModel> destinationService)
void	setEventChannel(MessageChannel eventChannel)
void	setEventDlqService(EventDlqService eventDlqService)
void	setJacksonObjectMapper(ObjectMapper jacksonObjectMapper)
void	setKymaJsonEventConverter(Converter<PublishRequestData,JsonPublishRequestData> kymaJsonEventConverter)
void	setModelService(ModelService modelService)
void	setRestTemplate(RestTemplateWrapper restTemplate)
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

retryEventEmitting

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

shouldSendToDlq

protected boolean shouldSendToDlq(java.lang.Exception e)

sendToDlq

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

getEventDestination

protected AbstractDestinationModel getEventDestination()

getModelService

protected ModelService getModelService()

setModelService

public void setModelService(ModelService modelService)

getTaskService

protected TaskService getTaskService()

setTaskService

public void setTaskService(TaskService taskService)

getRestTemplate

protected RestTemplateWrapper getRestTemplate()

setRestTemplate

public void setRestTemplate(RestTemplateWrapper restTemplate)

getDestinationService

protected DestinationService<AbstractDestinationModel> getDestinationService()

setDestinationService

public void setDestinationService(DestinationService<AbstractDestinationModel> destinationService)

getEventDlqService

protected EventDlqService getEventDlqService()

setEventDlqService

public void setEventDlqService(EventDlqService eventDlqService)

getJacksonObjectMapper

protected ObjectMapper getJacksonObjectMapper()

setJacksonObjectMapper

public void setJacksonObjectMapper(ObjectMapper jacksonObjectMapper)

getEventChannel

protected MessageChannel getEventChannel()

setEventChannel

public void setEventChannel(MessageChannel eventChannel)

getKymaJsonEventConverter

protected Converter<PublishRequestData,JsonPublishRequestData> getKymaJsonEventConverter()

setKymaJsonEventConverter

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