Package de.hybris.platform.outboundservices.monitoring

Class DefaultOutboundRequestResponseInterceptor

java.lang.Object

de.hybris.platform.outboundservices.monitoring.DefaultOutboundRequestResponseInterceptor

All Implemented Interfaces:

org.springframework.http.client.ClientHttpRequestInterceptor

public class DefaultOutboundRequestResponseInterceptor
extends java.lang.Object
implements org.springframework.http.client.ClientHttpRequestInterceptor

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DefaultOutboundRequestResponseInterceptor.WrappedClientHttpResponse

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	OUTBOUND_REQ_CANNOT_BE_UPDATED_WITHOUT_UNIQUE_ITEM

Constructor Summary

Constructors

Constructor	Description
DefaultOutboundRequestResponseInterceptor()

Method Summary

Modifier and Type	Method	Description
protected java.lang.String	extractError(java.lang.Throwable t)
protected java.lang.String	extractError(org.springframework.http.client.ClientHttpResponse response)
protected java.lang.String	extractMessageId(org.springframework.http.HttpRequest request)
protected OutboundRequestModel	findOutboundRequest(java.lang.String messageId)
protected java.util.List<MonitoredRequestErrorParser<MonitoredRequestErrorModel>>	getErrorParsers()
protected MonitoredRequestErrorParser<MonitoredRequestErrorModel>	getExceptionErrorParser()
protected MonitoredRequestErrorParser<MonitoredRequestErrorModel>	getFallbackErrorParser()
protected FlexibleSearchService	getFlexibleSearchService()
protected MediaPersistenceService	getMediaPersistenceService()
protected ModelService	getModelService()
protected OutboundServicesConfiguration	getOutboundServicesConfiguration()
protected OutboundRequestMediaModel	getPayload(byte[] payload, java.lang.String messageId)
protected org.springframework.http.client.ClientHttpResponse	handleError(OutboundRequestModel outboundRequestModel, byte[] payload, java.lang.String messageId, org.springframework.http.client.ClientHttpResponse clientHttpResponse)
protected org.springframework.http.client.ClientHttpResponse	handleSuccess(OutboundRequestModel outboundRequestModel, byte[] payload, java.lang.String messageId, org.springframework.http.client.ClientHttpResponse clientHttpResponse)
org.springframework.http.client.ClientHttpResponse	intercept(org.springframework.http.HttpRequest request, byte[] payload, org.springframework.http.client.ClientHttpRequestExecution requestExecution)
void	setErrorParsers(java.util.List<MonitoredRequestErrorParser<MonitoredRequestErrorModel>> errorParsers)
void	setExceptionErrorParser(MonitoredRequestErrorParser<MonitoredRequestErrorModel> exceptionErrorParser)
void	setFallbackErrorParser(MonitoredRequestErrorParser<MonitoredRequestErrorModel> fallbackErrorParser)
void	setFlexibleSearchService(FlexibleSearchService flexibleSearchService)
void	setMediaPersistenceService(MediaPersistenceService mediaPersistenceService)
void	setModelService(ModelService modelService)
void	setOutboundServicesConfiguration(OutboundServicesConfiguration outboundServicesConfiguration)
protected void	updateOutboundRequestWithException(OutboundRequestModel outboundRequestModel, byte[] payload, java.lang.String messageId, java.lang.Throwable t)
protected org.springframework.http.client.ClientHttpResponse	updateOutboundRequestWithResponse(OutboundRequestModel outboundRequestModel, byte[] payload, java.lang.String messageId, org.springframework.http.client.ClientHttpResponse clientHttpResponse)

Methods inherited from class java.lang.Object

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

Field Detail

OUTBOUND_REQ_CANNOT_BE_UPDATED_WITHOUT_UNIQUE_ITEM

public static final java.lang.String OUTBOUND_REQ_CANNOT_BE_UPDATED_WITHOUT_UNIQUE_ITEM

See Also:

Constant Field Values

Constructor Detail

DefaultOutboundRequestResponseInterceptor

public DefaultOutboundRequestResponseInterceptor()

Method Detail

intercept

public org.springframework.http.client.ClientHttpResponse intercept(org.springframework.http.HttpRequest request,
                                                                    byte[] payload,
                                                                    org.springframework.http.client.ClientHttpRequestExecution requestExecution)
                                                             throws java.io.IOException

Specified by:

intercept in interface org.springframework.http.client.ClientHttpRequestInterceptor

Throws:

java.io.IOException

updateOutboundRequestWithException

protected void updateOutboundRequestWithException(OutboundRequestModel outboundRequestModel,
                                                  byte[] payload,
                                                  java.lang.String messageId,
                                                  java.lang.Throwable t)

updateOutboundRequestWithResponse

protected org.springframework.http.client.ClientHttpResponse updateOutboundRequestWithResponse(OutboundRequestModel outboundRequestModel,
                                                                                               byte[] payload,
                                                                                               java.lang.String messageId,
                                                                                               org.springframework.http.client.ClientHttpResponse clientHttpResponse)
                                                                                        throws java.io.IOException

Throws:

java.io.IOException

extractMessageId

protected java.lang.String extractMessageId(org.springframework.http.HttpRequest request)

findOutboundRequest

protected OutboundRequestModel findOutboundRequest(java.lang.String messageId)

handleError

protected org.springframework.http.client.ClientHttpResponse handleError(OutboundRequestModel outboundRequestModel,
                                                                         byte[] payload,
                                                                         java.lang.String messageId,
                                                                         org.springframework.http.client.ClientHttpResponse clientHttpResponse)
                                                                  throws java.io.IOException

Throws:

java.io.IOException

handleSuccess

protected org.springframework.http.client.ClientHttpResponse handleSuccess(OutboundRequestModel outboundRequestModel,
                                                                           byte[] payload,
                                                                           java.lang.String messageId,
                                                                           org.springframework.http.client.ClientHttpResponse clientHttpResponse)

extractError

protected java.lang.String extractError(org.springframework.http.client.ClientHttpResponse response)
                                 throws java.io.IOException

Throws:

java.io.IOException

extractError

protected java.lang.String extractError(java.lang.Throwable t)

getPayload

protected OutboundRequestMediaModel getPayload(byte[] payload,
                                               java.lang.String messageId)

getModelService

protected ModelService getModelService()

setModelService

public void setModelService(ModelService modelService)

getFlexibleSearchService

protected FlexibleSearchService getFlexibleSearchService()

setFlexibleSearchService

public void setFlexibleSearchService(FlexibleSearchService flexibleSearchService)

getMediaPersistenceService

protected MediaPersistenceService getMediaPersistenceService()

setMediaPersistenceService

public void setMediaPersistenceService(MediaPersistenceService mediaPersistenceService)

getErrorParsers

protected java.util.List<MonitoredRequestErrorParser<MonitoredRequestErrorModel>> getErrorParsers()

setErrorParsers

public void setErrorParsers(java.util.List<MonitoredRequestErrorParser<MonitoredRequestErrorModel>> errorParsers)

getFallbackErrorParser

protected MonitoredRequestErrorParser<MonitoredRequestErrorModel> getFallbackErrorParser()

setFallbackErrorParser

public void setFallbackErrorParser(MonitoredRequestErrorParser<MonitoredRequestErrorModel> fallbackErrorParser)

getExceptionErrorParser

protected MonitoredRequestErrorParser<MonitoredRequestErrorModel> getExceptionErrorParser()

setExceptionErrorParser

public void setExceptionErrorParser(MonitoredRequestErrorParser<MonitoredRequestErrorModel> exceptionErrorParser)

getOutboundServicesConfiguration

protected OutboundServicesConfiguration getOutboundServicesConfiguration()

setOutboundServicesConfiguration

public void setOutboundServicesConfiguration(OutboundServicesConfiguration outboundServicesConfiguration)