default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder |
GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder.ackMode(String ackMode) |
AUTO = exchange gets ack'ed/nack'ed on completion.
|
default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder |
GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder.ackMode(GooglePubsubEndpointBuilderFactory.AckMode ackMode) |
AUTO = exchange gets ack'ed/nack'ed on completion.
|
default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder |
GooglePubsubEndpointBuilderFactory.AdvancedGooglePubsubEndpointConsumerBuilder.basic() |
|
default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder |
GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder.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 GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder |
GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder.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 GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder |
GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder.concurrentConsumers(Integer concurrentConsumers) |
The number of parallel streams consuming from the subscription.
|
default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder |
GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder.concurrentConsumers(String concurrentConsumers) |
The number of parallel streams consuming from the subscription.
|
default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder |
GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder.loggerId(String loggerId) |
Logger ID to use when a match to the parent route required.
|
default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder |
GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder.maxMessagesPerPoll(Integer maxMessagesPerPoll) |
The max number of messages to receive from the server in a single API
call.
|
default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder |
GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder.maxMessagesPerPoll(String maxMessagesPerPoll) |
The max number of messages to receive from the server in a single API
call.
|
default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder |
GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder.serviceAccountKey(String serviceAccountKey) |
The Service account key that can be used as credentials for the
PubSub publisher/subscriber.
|
default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder |
GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder.synchronousPull(boolean synchronousPull) |
Synchronously pull batches of messages.
|
default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder |
GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder.synchronousPull(String synchronousPull) |
Synchronously pull batches of messages.
|