GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder.advanced()
GooglePubsubEndpointBuilderFactory.AdvancedGooglePubsubEndpointConsumerBuilder.bridgeErrorHandler(boolean bridgeErrorHandler)
Allows for bridging the consumer to the Camel routing Error Handler,
which mean any exceptions (if possible) occurred while the Camel
consumer is trying to pickup incoming messages, or the likes, will
now be processed as a message and handled by the routing Error
Handler.
GooglePubsubEndpointBuilderFactory.AdvancedGooglePubsubEndpointConsumerBuilder.bridgeErrorHandler(String bridgeErrorHandler)
Allows for bridging the consumer to the Camel routing Error Handler,
which mean any exceptions (if possible) occurred while the Camel
consumer is trying to pickup incoming messages, or the likes, will
now be processed as a message and handled by the routing Error
Handler.
The number of parallel streams consuming from the subscription.
GooglePubsubEndpointBuilderFactory.AdvancedGooglePubsubEndpointConsumerBuilder.concurrentConsumers(String concurrentConsumers)
The number of parallel streams consuming from the subscription.
GooglePubsubEndpointBuilderFactory.AdvancedGooglePubsubEndpointConsumerBuilder.exceptionHandler(String exceptionHandler)
To let the consumer use a custom ExceptionHandler.
GooglePubsubEndpointBuilderFactory.AdvancedGooglePubsubEndpointConsumerBuilder.exceptionHandler(org.apache.camel.spi.ExceptionHandler exceptionHandler)
To let the consumer use a custom ExceptionHandler.
GooglePubsubEndpointBuilderFactory.AdvancedGooglePubsubEndpointConsumerBuilder.exchangePattern(String exchangePattern)
Sets the exchange pattern when the consumer creates an exchange.
GooglePubsubEndpointBuilderFactory.AdvancedGooglePubsubEndpointConsumerBuilder.exchangePattern(org.apache.camel.ExchangePattern exchangePattern)
Sets the exchange pattern when the consumer creates an exchange.
To use a custom HeaderFilterStrategy to filter headers to and from
Camel message.
GooglePubsubEndpointBuilderFactory.AdvancedGooglePubsubEndpointConsumerBuilder.headerFilterStrategy(org.apache.camel.spi.HeaderFilterStrategy headerFilterStrategy)
To use a custom HeaderFilterStrategy to filter headers to and from
Camel message.
GooglePubsubEndpointBuilderFactory.AdvancedGooglePubsubEndpointConsumerBuilder.includeAllGoogleProperties(boolean includeAllGoogleProperties)
Whether to include all Google headers when mapping from Pubsub to
Camel Message.
Whether to include all Google headers when mapping from Pubsub to
Camel Message.
GooglePubsubEndpointBuilderFactory.AdvancedGooglePubsubEndpointConsumerBuilder.loggerId(String loggerId)
GooglePubsubEndpointBuilderFactory.AdvancedGooglePubsubEndpointConsumerBuilder.maxAckExtensionPeriod(int maxAckExtensionPeriod)
Set the maximum period a message ack deadline will be extended.
Set the maximum period a message ack deadline will be extended.
GooglePubsubEndpointBuilderFactory.AdvancedGooglePubsubEndpointConsumerBuilder.maxDeliveryAttempts(int maxDeliveryAttempts)
The maximum number of delivery attempts for each message.
GooglePubsubEndpointBuilderFactory.AdvancedGooglePubsubEndpointConsumerBuilder.maxDeliveryAttempts(String maxDeliveryAttempts)
The maximum number of delivery attempts for each message.
GooglePubsubEndpointBuilderFactory.AdvancedGooglePubsubEndpointConsumerBuilder.maxMessagesPerPoll(Integer maxMessagesPerPoll)
The max number of messages to receive from the server in a single API
call.
GooglePubsubEndpointBuilderFactory.AdvancedGooglePubsubEndpointConsumerBuilder.maxMessagesPerPoll(String maxMessagesPerPoll)
The max number of messages to receive from the server in a single API
call.
GooglePubsubEndpointBuilderFactory.AdvancedGooglePubsubEndpointConsumerBuilder.synchronousPull(boolean synchronousPull)
Synchronously pull batches of messages.
GooglePubsubEndpointBuilderFactory.AdvancedGooglePubsubEndpointConsumerBuilder.synchronousPull(String synchronousPull)
Synchronously pull batches of messages.