default IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder |
IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder.autoUnsubscribe(boolean autoUnsubscribe) |
Whether auto unsubscribe is enabled in the Continuous Query Consumer.
|
default IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder |
IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder.autoUnsubscribe(String autoUnsubscribe) |
Whether auto unsubscribe is enabled in the Continuous Query Consumer.
|
default IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder |
IgniteCacheEndpointBuilderFactory.AdvancedIgniteCacheEndpointConsumerBuilder.basic() |
|
default IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder |
IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder.bridgeErrorHandler(boolean bridgeErrorHandler) |
Allows for bridging the consumer to the Camel routing Error Handler,
which mean any exceptions occurred while the consumer is trying to
pickup incoming messages, or the likes, will now be processed as a
message and handled by the routing Error Handler.
|
default IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder |
IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder.bridgeErrorHandler(String bridgeErrorHandler) |
Allows for bridging the consumer to the Camel routing Error Handler,
which mean any exceptions occurred while the consumer is trying to
pickup incoming messages, or the likes, will now be processed as a
message and handled by the routing Error Handler.
|
default IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder |
IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder.fireExistingQueryResults(boolean fireExistingQueryResults) |
Whether to process existing results that match the query.
|
default IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder |
IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder.fireExistingQueryResults(String fireExistingQueryResults) |
Whether to process existing results that match the query.
|
default IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder |
IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder.oneExchangePerUpdate(boolean oneExchangePerUpdate) |
Whether to pack each update in an individual Exchange, even if
multiple updates are received in one batch.
|
default IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder |
IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder.oneExchangePerUpdate(String oneExchangePerUpdate) |
Whether to pack each update in an individual Exchange, even if
multiple updates are received in one batch.
|
default IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder |
IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder.pageSize(int pageSize) |
The page size.
|
default IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder |
IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder.pageSize(String pageSize) |
The page size.
|
default IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder |
IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder.propagateIncomingBodyIfNoReturnValue(boolean propagateIncomingBodyIfNoReturnValue) |
Sets whether to propagate the incoming body if the return type of the
underlying Ignite operation is void.
|
default IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder |
IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder.propagateIncomingBodyIfNoReturnValue(String propagateIncomingBodyIfNoReturnValue) |
Sets whether to propagate the incoming body if the return type of the
underlying Ignite operation is void.
|
default IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder |
IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder.remoteFilter(Object remoteFilter) |
The remote filter, only used by the Continuous Query Consumer.
|
default IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder |
IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder.remoteFilter(String remoteFilter) |
The remote filter, only used by the Continuous Query Consumer.
|
default IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder |
IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder.timeInterval(long timeInterval) |
The time interval for the Continuous Query Consumer.
|
default IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder |
IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder.timeInterval(String timeInterval) |
The time interval for the Continuous Query Consumer.
|
default IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder |
IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder.treatCollectionsAsCacheObjects(boolean treatCollectionsAsCacheObjects) |
Sets whether to treat Collections as cache objects or as Collections
of items to insert/update/compute, etc.
|
default IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder |
IgniteCacheEndpointBuilderFactory.IgniteCacheEndpointConsumerBuilder.treatCollectionsAsCacheObjects(String treatCollectionsAsCacheObjects) |
Sets whether to treat Collections as cache objects or as Collections
of items to insert/update/compute, etc.
|