org.openehealth.ipf.platform.camel.ihe.mllp.core.intercept.consumer

Class ConsumerInPayloadLoggerInterceptor

java.lang.Object

org.openehealth.ipf.commons.ihe.core.chain.ChainableImpl

org.openehealth.ipf.platform.camel.ihe.core.InterceptorSupport<MllpEndpoint<?,?,?>>

org.openehealth.ipf.platform.camel.ihe.mllp.core.intercept.consumer.ConsumerInPayloadLoggerInterceptor

All Implemented Interfaces:

org.apache.camel.Processor, Chainable, Interceptor<MllpEndpoint<?,?,?>>

public class ConsumerInPayloadLoggerInterceptor
extends InterceptorSupport<MllpEndpoint<?,?,?>>

Consumer-side MLLP interceptor which stores incoming payload into files with user-defined name patterns.

Members of MllpPayloadLoggerBase are mixed into this class.

Author:

Dmytro Rud

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ConsumerInPayloadLoggerInterceptor.Factory

Constructor Summary

Constructors

Constructor and Description
ConsumerInPayloadLoggerInterceptor(ExpressionResolver resolver) Instantiation, explicitly using a ExpressionResolver instance
ConsumerInPayloadLoggerInterceptor(String fileNamePattern) Instantiation, implicitly using a SpringExpressionResolver

Method Summary

Modifier and Type	Method and Description
boolean	canProcess()
int	getErrorCountLimit()
ExpressionResolver	getExpressionResolver()
boolean	isEnabled()
boolean	isLocallyEnabled() Deprecated.
void	logPayload(org.apache.camel.Exchange exchange, boolean useOutMessage)
void	process(org.apache.camel.Exchange exchange)
void	resetErrorCount()
void	setEnabled(boolean enabled)
void	setErrorCountLimit(int errorCountLimit)
void	setExpressionResolver(ExpressionResolver resolver)
void	setLocallyEnabled(boolean locallyEnabled) Deprecated.

Methods inherited from class org.openehealth.ipf.platform.camel.ihe.core.InterceptorSupport

characterSet, getEndpoint, getWrappedProcessor, setEndpoint, setWrappedProcessor

Methods inherited from class org.openehealth.ipf.commons.ihe.core.chain.ChainableImpl

addAfter, addBefore, getAfter, getBefore, getId, setId

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.openehealth.ipf.commons.ihe.core.chain.Chainable

getAfter, getBefore, getId

Constructor Detail

ConsumerInPayloadLoggerInterceptor

public ConsumerInPayloadLoggerInterceptor(String fileNamePattern)

Instantiation, implicitly using a SpringExpressionResolver

Parameters:

fileNamePattern - file name pattern

ConsumerInPayloadLoggerInterceptor

public ConsumerInPayloadLoggerInterceptor(ExpressionResolver resolver)

Instantiation, explicitly using a ExpressionResolver instance

Parameters:

resolver - ExpressionResolver instance

Since:

3.1

Method Detail

process

public void process(org.apache.camel.Exchange exchange)
             throws Exception

Throws:

Exception

logPayload

@Generated(value="lombok")
public void logPayload(org.apache.camel.Exchange exchange,
                                                   boolean useOutMessage)

canProcess

@Generated(value="lombok")
public boolean canProcess()

resetErrorCount

@Generated(value="lombok")
public void resetErrorCount()

isEnabled

@Generated(value="lombok")
public boolean isEnabled()

setEnabled

@Generated(value="lombok")
public void setEnabled(boolean enabled)

isLocallyEnabled

@Deprecated
 @Generated(value="lombok")
public boolean isLocallyEnabled()

Deprecated.

setLocallyEnabled

@Deprecated
 @Generated(value="lombok")
public void setLocallyEnabled(boolean locallyEnabled)

Deprecated.

getErrorCountLimit

@Generated(value="lombok")
public int getErrorCountLimit()

setErrorCountLimit

@Generated(value="lombok")
public void setErrorCountLimit(int errorCountLimit)

getExpressionResolver

@Generated(value="lombok")
public ExpressionResolver getExpressionResolver()

setExpressionResolver

@Generated(value="lombok")
public void setExpressionResolver(ExpressionResolver resolver)