Interface GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder
-
- All Superinterfaces:
org.apache.camel.builder.EndpointConsumerBuilder
,org.apache.camel.EndpointConsumerResolver
,org.apache.camel.builder.EndpointProducerBuilder
,org.apache.camel.EndpointProducerResolver
,GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder
,GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointProducerBuilder
- Enclosing interface:
- GooglePubsubEndpointBuilderFactory
public static interface GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder extends GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder, GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointProducerBuilder
Builder for endpoint for the Google Pubsub component.
-
-
Method Summary
All Methods Instance Methods Default Methods Modifier and Type Method Description default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder
ackMode(String ackMode)
AUTO = exchange gets ack'ed/nack'ed on completion.default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder
ackMode(GooglePubsubEndpointBuilderFactory.AckMode ackMode)
AUTO = exchange gets ack'ed/nack'ed on completion.default GooglePubsubEndpointBuilderFactory.AdvancedGooglePubsubEndpointBuilder
advanced()
default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder
concurrentConsumers(Integer concurrentConsumers)
The number of parallel streams consuming from the subscription.default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder
concurrentConsumers(String concurrentConsumers)
The number of parallel streams consuming from the subscription.default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder
loggerId(String loggerId)
Logger ID to use when a match to the parent route required.default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder
maxMessagesPerPoll(Integer maxMessagesPerPoll)
The max number of messages to receive from the server in a single API call.default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder
maxMessagesPerPoll(String maxMessagesPerPoll)
The max number of messages to receive from the server in a single API call.default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder
serviceAccountKey(String serviceAccountKey)
The Service account key that can be used as credentials for the PubSub publisher/subscriber.default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder
synchronousPull(boolean synchronousPull)
Synchronously pull batches of messages.default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder
synchronousPull(String synchronousPull)
Synchronously pull batches of messages.-
Methods inherited from interface org.apache.camel.builder.EndpointConsumerBuilder
doSetMultiValueProperties, doSetMultiValueProperty, doSetProperty, expr, expr, getUri
-
Methods inherited from interface org.apache.camel.builder.EndpointProducerBuilder
doSetMultiValueProperties, doSetMultiValueProperty, doSetProperty, expr, expr, getUri
-
Methods inherited from interface org.apache.camel.builder.endpoint.dsl.GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder
bridgeErrorHandler, bridgeErrorHandler
-
Methods inherited from interface org.apache.camel.builder.endpoint.dsl.GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointProducerBuilder
lazyStartProducer, lazyStartProducer
-
-
-
-
Method Detail
-
advanced
default GooglePubsubEndpointBuilderFactory.AdvancedGooglePubsubEndpointBuilder advanced()
- Specified by:
advanced
in interfaceGooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder
- Specified by:
advanced
in interfaceGooglePubsubEndpointBuilderFactory.GooglePubsubEndpointProducerBuilder
-
ackMode
default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder ackMode(GooglePubsubEndpointBuilderFactory.AckMode ackMode)
AUTO = exchange gets ack'ed/nack'ed on completion. NONE = downstream process has to ack/nack explicitly. The option is a: <code>org.apache.camel.component.google.pubsub.GooglePubsubConstants$AckMode</code> type. Default: AUTO Group: common- Specified by:
ackMode
in interfaceGooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder
- Specified by:
ackMode
in interfaceGooglePubsubEndpointBuilderFactory.GooglePubsubEndpointProducerBuilder
- Parameters:
ackMode
- the value to set- Returns:
- the dsl builder
-
ackMode
default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder ackMode(String ackMode)
AUTO = exchange gets ack'ed/nack'ed on completion. NONE = downstream process has to ack/nack explicitly. The option will be converted to a <code>org.apache.camel.component.google.pubsub.GooglePubsubConstants$AckMode</code> type. Default: AUTO Group: common- Specified by:
ackMode
in interfaceGooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder
- Specified by:
ackMode
in interfaceGooglePubsubEndpointBuilderFactory.GooglePubsubEndpointProducerBuilder
- Parameters:
ackMode
- the value to set- Returns:
- the dsl builder
-
concurrentConsumers
default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder concurrentConsumers(Integer concurrentConsumers)
The number of parallel streams consuming from the subscription. The option is a: <code>java.lang.Integer</code> type. Default: 1 Group: common- Specified by:
concurrentConsumers
in interfaceGooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder
- Specified by:
concurrentConsumers
in interfaceGooglePubsubEndpointBuilderFactory.GooglePubsubEndpointProducerBuilder
- Parameters:
concurrentConsumers
- the value to set- Returns:
- the dsl builder
-
concurrentConsumers
default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder concurrentConsumers(String concurrentConsumers)
The number of parallel streams consuming from the subscription. The option will be converted to a <code>java.lang.Integer</code> type. Default: 1 Group: common- Specified by:
concurrentConsumers
in interfaceGooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder
- Specified by:
concurrentConsumers
in interfaceGooglePubsubEndpointBuilderFactory.GooglePubsubEndpointProducerBuilder
- Parameters:
concurrentConsumers
- the value to set- Returns:
- the dsl builder
-
loggerId
default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder loggerId(String loggerId)
Logger ID to use when a match to the parent route required. The option is a: <code>java.lang.String</code> type. Group: common- Specified by:
loggerId
in interfaceGooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder
- Specified by:
loggerId
in interfaceGooglePubsubEndpointBuilderFactory.GooglePubsubEndpointProducerBuilder
- Parameters:
loggerId
- the value to set- Returns:
- the dsl builder
-
maxMessagesPerPoll
default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder maxMessagesPerPoll(Integer maxMessagesPerPoll)
The max number of messages to receive from the server in a single API call. The option is a: <code>java.lang.Integer</code> type. Default: 1 Group: common- Specified by:
maxMessagesPerPoll
in interfaceGooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder
- Specified by:
maxMessagesPerPoll
in interfaceGooglePubsubEndpointBuilderFactory.GooglePubsubEndpointProducerBuilder
- Parameters:
maxMessagesPerPoll
- the value to set- Returns:
- the dsl builder
-
maxMessagesPerPoll
default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder maxMessagesPerPoll(String maxMessagesPerPoll)
The max number of messages to receive from the server in a single API call. The option will be converted to a <code>java.lang.Integer</code> type. Default: 1 Group: common- Specified by:
maxMessagesPerPoll
in interfaceGooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder
- Specified by:
maxMessagesPerPoll
in interfaceGooglePubsubEndpointBuilderFactory.GooglePubsubEndpointProducerBuilder
- Parameters:
maxMessagesPerPoll
- the value to set- Returns:
- the dsl builder
-
serviceAccountKey
default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder serviceAccountKey(String serviceAccountKey)
The Service account key that can be used as credentials for the PubSub publisher/subscriber. It can be loaded by default from classpath, but you can prefix with classpath:, file:, or http: to load the resource from different systems. The option is a: <code>java.lang.String</code> type. Required: true Group: common- Specified by:
serviceAccountKey
in interfaceGooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder
- Specified by:
serviceAccountKey
in interfaceGooglePubsubEndpointBuilderFactory.GooglePubsubEndpointProducerBuilder
- Parameters:
serviceAccountKey
- the value to set- Returns:
- the dsl builder
-
synchronousPull
default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder synchronousPull(boolean synchronousPull)
Synchronously pull batches of messages. The option is a: <code>boolean</code> type. Default: false Group: common- Specified by:
synchronousPull
in interfaceGooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder
- Specified by:
synchronousPull
in interfaceGooglePubsubEndpointBuilderFactory.GooglePubsubEndpointProducerBuilder
- Parameters:
synchronousPull
- the value to set- Returns:
- the dsl builder
-
synchronousPull
default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder synchronousPull(String synchronousPull)
Synchronously pull batches of messages. The option will be converted to a <code>boolean</code> type. Default: false Group: common- Specified by:
synchronousPull
in interfaceGooglePubsubEndpointBuilderFactory.GooglePubsubEndpointConsumerBuilder
- Specified by:
synchronousPull
in interfaceGooglePubsubEndpointBuilderFactory.GooglePubsubEndpointProducerBuilder
- Parameters:
synchronousPull
- the value to set- Returns:
- the dsl builder
-
-