public class FilterEndpointSpec extends ConsumerEndpointSpec<FilterEndpointSpec,MessageFilter>
ConsumerEndpointSpec
implementation for the MessageFilter
.adviceChain
componentsToRegister, endpointFactoryBean, handler
PARSER, target
logger
DEFAULT_PHASE
OBJECT_TYPE_ATTRIBUTE
Modifier | Constructor and Description |
---|---|
protected |
FilterEndpointSpec(MessageFilter messageFilter) |
Modifier and Type | Method and Description |
---|---|
FilterEndpointSpec |
discardChannel(MessageChannel discardChannel)
Specify a channel where rejected Messages should be sent.
|
FilterEndpointSpec |
discardChannel(String discardChannelName)
Specify a channel name where rejected Messages should be sent.
|
FilterEndpointSpec |
discardFlow(IntegrationFlow discardFlow)
Configure a subflow to run for discarded messages instead of a
discardChannel(MessageChannel) . |
FilterEndpointSpec |
discardWithinAdvice(boolean discardWithinAdvice)
Set to 'true' if you wish the discard processing to occur within any
request handler advice applied to this filter.
|
FilterEndpointSpec |
throwExceptionOnRejection(boolean throwExceptionOnRejection)
The default value is
false meaning that rejected
Messages will be quietly dropped or sent to the discard channel if
available. |
advice, async, autoStartup, doGet, notPropagatedHeaders, order, phase, poller, requiresReply, role, sendTimeout, taskScheduler, transactional, transactional, transactional, transactional, transactional
assertHandler, getComponentsToRegister, id, obtainInputChannelFromFlow, obtainInputChannelFromFlow, poller, poller
_this, createInstance, destroyInstance, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop
afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton
protected FilterEndpointSpec(MessageFilter messageFilter)
public FilterEndpointSpec throwExceptionOnRejection(boolean throwExceptionOnRejection)
false
meaning that rejected
Messages will be quietly dropped or sent to the discard channel if
available. Typically this value would not be true
when
a discard channel is provided, but if so, it will still apply
(in such a case, the Message will be sent to the discard channel,
and then the exception will be thrown).throwExceptionOnRejection
- the throwExceptionOnRejection.MessageFilter.setThrowExceptionOnRejection(boolean)
public FilterEndpointSpec discardChannel(MessageChannel discardChannel)
discardChannel
- the discardChannel.MessageFilter.setDiscardChannel(MessageChannel)
public FilterEndpointSpec discardChannel(String discardChannelName)
discardChannelName
- the discardChannelName.MessageFilter.setDiscardChannelName(String)
public FilterEndpointSpec discardFlow(IntegrationFlow discardFlow)
discardChannel(MessageChannel)
.discardFlow
- the discard flow.public FilterEndpointSpec discardWithinAdvice(boolean discardWithinAdvice)
discardWithinAdvice
- the discardWithinAdvice.MessageFilter.setDiscardWithinAdvice(boolean)