org.mule.transport.polling
Class MessageProcessorPollingOverride

java.lang.Object
  org.mule.transport.polling.MessageProcessorPollingOverride

Direct Known Subclasses:

Watermark

public abstract class MessageProcessorPollingOverride
extends Object

Extension point to hook extra functionality to a message processor polling component. Implementation registered with Poll will be called on each execution to provide an interceptor which will then be called on several execution checkpoints. Note that while this class should be threadsafe, interceptors returned will be scoped on a single execution, and hence may carry state.

Constructor Summary

MessageProcessorPollingOverride()

Method Summary

abstract MessageProcessorPollingInterceptor

interceptor() Returns an interceptor instance.

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageProcessorPollingOverride

public MessageProcessorPollingOverride()

Method Detail

interceptor

public abstract MessageProcessorPollingInterceptor interceptor()

Returns an interceptor instance. This method will be called on every poll, and may return a new instance every time or always the same instance (the latter case requires the instance to be threadsafe). Interceptor's are scoped for each poll and flow execution and will be discarded after the scope ends.

Returns:

a new interceptor instance that cn be used to alter the functionality of a message processor polling component