default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder |
GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder.ackMode(String ackMode) |
AUTO = exchange gets ack'ed/nack'ed on completion.
|
default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder |
GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder.ackMode(GooglePubsubEndpointBuilderFactory.AckMode ackMode) |
AUTO = exchange gets ack'ed/nack'ed on completion.
|
default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder |
GooglePubsubEndpointBuilderFactory.AdvancedGooglePubsubEndpointBuilder.basic() |
|
default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder |
GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder.concurrentConsumers(Integer concurrentConsumers) |
The number of parallel streams consuming from the subscription.
|
default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder |
GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder.concurrentConsumers(String concurrentConsumers) |
The number of parallel streams consuming from the subscription.
|
static GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder |
GooglePubsubEndpointBuilderFactory.endpointBuilder(String componentName,
String path) |
|
default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder |
GooglePubsubEndpointBuilderFactory.GooglePubsubBuilders.googlePubsub(String path) |
Google Pubsub (camel-google-pubsub)
Send and receive messages to/from Google Cloud Platform PubSub
Service.
|
default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder |
GooglePubsubEndpointBuilderFactory.GooglePubsubBuilders.googlePubsub(String componentName,
String path) |
Google Pubsub (camel-google-pubsub)
Send and receive messages to/from Google Cloud Platform PubSub
Service.
|
default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder |
GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder.loggerId(String loggerId) |
Logger ID to use when a match to the parent route required.
|
default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder |
GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder.maxMessagesPerPoll(Integer maxMessagesPerPoll) |
The max number of messages to receive from the server in a single API
call.
|
default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder |
GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder.maxMessagesPerPoll(String maxMessagesPerPoll) |
The max number of messages to receive from the server in a single API
call.
|
default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder |
GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder.synchronousPull(boolean synchronousPull) |
Synchronously pull batches of messages.
|
default GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder |
GooglePubsubEndpointBuilderFactory.GooglePubsubEndpointBuilder.synchronousPull(String synchronousPull) |
Synchronously pull batches of messages.
|