de.hybris.platform.outboundservices.monitoring

Class DefaultOutboundRequestResponseInterceptor

java.lang.Object

de.hybris.platform.outboundservices.monitoring.DefaultOutboundRequestResponseInterceptor

public class DefaultOutboundRequestResponseInterceptor
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DefaultOutboundRequestResponseInterceptor.WrappedClientHttpResponse

Constructor Summary

Constructors

Constructor and Description
DefaultOutboundRequestResponseInterceptor()

Method Summary

Modifier and Type	Method and Description
protected java.lang.String	extractError(ClientHttpResponse response)
protected java.lang.String	extractMessageId(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)
ClientHttpResponse	intercept(HttpRequest request, byte[] payload, 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 ClientHttpResponse	updateOutboundRequestWithResponse(OutboundRequestModel outboundRequestModel, byte[] payload, java.lang.String messageId, ClientHttpResponse clientHttpResponse)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultOutboundRequestResponseInterceptor

public DefaultOutboundRequestResponseInterceptor()

Method Detail

intercept

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

Throws:

java.io.IOException

updateOutboundRequestWithException

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

extractMessageId

protected java.lang.String extractMessageId(HttpRequest request)

findOutboundRequest

protected OutboundRequestModel findOutboundRequest(java.lang.String messageId)

extractError

protected java.lang.String extractError(ClientHttpResponse response)
                                 throws java.io.IOException

Throws:

java.io.IOException

getPayload

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

updateOutboundRequestWithResponse

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

Throws:

java.io.IOException

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)