Package | Description |
---|---|
org.mule.transport.polling | |
org.mule.transport.polling.watermark | |
org.mule.transport.polling.watermark.selector |
Modifier and Type | Method and Description |
---|---|
abstract MessageProcessorPollingInterceptor |
MessageProcessorPollingOverride.interceptor()
Returns an interceptor instance.
|
Modifier and Type | Class and Description |
---|---|
class |
WatermarkPollingInterceptor
Implementation of
MessageProcessorPollingInterceptor that retrieves the
current watermark value before the polling flow is executed and updates it when it
is finished. |
Modifier and Type | Method and Description |
---|---|
MessageProcessorPollingInterceptor |
UpdateExpressionWatermark.interceptor() |
Modifier and Type | Class and Description |
---|---|
class |
SelectorWatermarkPollingInterceptor
Implementation of
WatermarkPollingInterceptor that uses
a WatermarkSelector to return the new watermark value. |
Modifier and Type | Method and Description |
---|---|
MessageProcessorPollingInterceptor |
SelectorWatermark.interceptor()
Returns an interceptor instance.
|
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.