This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 715f4106c1e002004ba97f1e3f69ac9d5b95c83e
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Wed Mar 3 15:38:14 2021 +0100
CAMEL-16273 - Camel-google-* cloud components: Make the serviceAccountKey
explicitly configurable - Camel-google-pubsub
---
.../catalog/docs/google-pubsub-component.adoc | 3 +-
.../pubsub/GooglePubsubEndpointConfigurer.java | 6 +++
.../pubsub/GooglePubsubEndpointUriFactory.java | 3 +-
.../component/google/pubsub/google-pubsub.json | 1 +
.../src/main/docs/google-pubsub-component.adoc | 3 +-
.../google/pubsub/GooglePubsubComponent.java | 54 +++++++++++++++++-----
.../google/pubsub/GooglePubsubConsumer.java | 7 +--
.../google/pubsub/GooglePubsubEndpoint.java | 13 ++++++
.../google/pubsub/GooglePubsubProducer.java | 2 +-
.../dsl/GooglePubsubEndpointBuilderFactory.java | 54 ++++++++++++++++++++++
.../ROOT/pages/google-pubsub-component.adoc | 3 +-
11 files changed, 130 insertions(+), 19 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/google-pubsub-component.adoc
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/google-pubsub-component.adoc
index a7c67af..83d4535 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/google-pubsub-component.adoc
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/google-pubsub-component.adoc
@@ -81,7 +81,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (12 parameters):
+=== Query Parameters (13 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -91,6 +91,7 @@ with the following path and query parameters:
| *concurrentConsumers* (common) | The number of parallel streams consuming
from the subscription | 1 | Integer
| *loggerId* (common) | Logger ID to use when a match to the parent route
required | | String
| *maxMessagesPerPoll* (common) | The max number of messages to receive from
the server in a single API call | 1 | Integer
+| *serviceAccountKey* (common) | The Service account key that can be used as
credentials for the Storage client. It can be loaded by default from classpath,
but you can prefix with classpath:, file:, or http: to load the resource from
different systems. | | String
| *synchronousPull* (common) | Synchronously pull batches of messages | false
| boolean
| *bridgeErrorHandler* (consumer) | 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. By default the
consumer will use the org.apache.camel.spi.ExceptionHandler to deal with
exceptions, that will be logged at WARN or ERROR level and ignored. | false |
boolean
| *exceptionHandler* (consumer) | To let the consumer use a custom
ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this
option is not in use. By default the consumer will deal with exceptions, that
will be logged at WARN or ERROR level and ignored. | | ExceptionHandler
diff --git
a/components/camel-google-pubsub/src/generated/java/org/apache/camel/component/google/pubsub/GooglePubsubEndpointConfigurer.java
b/components/camel-google-pubsub/src/generated/java/org/apache/camel/component/google/pubsub/GooglePubsubEndpointConfigurer.java
index 8b8737b..b794579 100644
---
a/components/camel-google-pubsub/src/generated/java/org/apache/camel/component/google/pubsub/GooglePubsubEndpointConfigurer.java
+++
b/components/camel-google-pubsub/src/generated/java/org/apache/camel/component/google/pubsub/GooglePubsubEndpointConfigurer.java
@@ -42,6 +42,8 @@ public class GooglePubsubEndpointConfigurer extends
PropertyConfigurerSupport im
case "pubsubendpoint":
case "pubsubEndpoint": target.setPubsubEndpoint(property(camelContext,
java.lang.String.class, value)); return true;
case "serializer": target.setSerializer(property(camelContext,
org.apache.camel.component.google.pubsub.serializer.GooglePubsubSerializer.class,
value)); return true;
+ case "serviceaccountkey":
+ case "serviceAccountKey":
target.setServiceAccountKey(property(camelContext, java.lang.String.class,
value)); return true;
case "synchronouspull":
case "synchronousPull":
target.setSynchronousPull(property(camelContext, boolean.class, value)); return
true;
default: return false;
@@ -77,6 +79,8 @@ public class GooglePubsubEndpointConfigurer extends
PropertyConfigurerSupport im
case "pubsubendpoint":
case "pubsubEndpoint": return java.lang.String.class;
case "serializer": return
org.apache.camel.component.google.pubsub.serializer.GooglePubsubSerializer.class;
+ case "serviceaccountkey":
+ case "serviceAccountKey": return java.lang.String.class;
case "synchronouspull":
case "synchronousPull": return boolean.class;
default: return null;
@@ -108,6 +112,8 @@ public class GooglePubsubEndpointConfigurer extends
PropertyConfigurerSupport im
case "pubsubendpoint":
case "pubsubEndpoint": return target.getPubsubEndpoint();
case "serializer": return target.getSerializer();
+ case "serviceaccountkey":
+ case "serviceAccountKey": return target.getServiceAccountKey();
case "synchronouspull":
case "synchronousPull": return target.isSynchronousPull();
default: return null;
diff --git
a/components/camel-google-pubsub/src/generated/java/org/apache/camel/component/google/pubsub/GooglePubsubEndpointUriFactory.java
b/components/camel-google-pubsub/src/generated/java/org/apache/camel/component/google/pubsub/GooglePubsubEndpointUriFactory.java
index a54d3b7..dcee6c6 100644
---
a/components/camel-google-pubsub/src/generated/java/org/apache/camel/component/google/pubsub/GooglePubsubEndpointUriFactory.java
+++
b/components/camel-google-pubsub/src/generated/java/org/apache/camel/component/google/pubsub/GooglePubsubEndpointUriFactory.java
@@ -20,7 +20,8 @@ public class GooglePubsubEndpointUriFactory extends
org.apache.camel.support.com
private static final Set<String> PROPERTY_NAMES;
private static final Set<String> SECRET_PROPERTY_NAMES;
static {
- Set<String> props = new HashSet<>(14);
+ Set<String> props = new HashSet<>(15);
+ props.add("serviceAccountKey");
props.add("exchangePattern");
props.add("serializer");
props.add("synchronousPull");
diff --git
a/components/camel-google-pubsub/src/generated/resources/org/apache/camel/component/google/pubsub/google-pubsub.json
b/components/camel-google-pubsub/src/generated/resources/org/apache/camel/component/google/pubsub/google-pubsub.json
index 71a44e4..d17dacf 100644
---
a/components/camel-google-pubsub/src/generated/resources/org/apache/camel/component/google/pubsub/google-pubsub.json
+++
b/components/camel-google-pubsub/src/generated/resources/org/apache/camel/component/google/pubsub/google-pubsub.json
@@ -37,6 +37,7 @@
"concurrentConsumers": { "kind": "parameter", "displayName": "Concurrent
Consumers", "group": "common", "label": "", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "1", "description": "The number of
parallel streams consuming from the subscription" },
"loggerId": { "kind": "parameter", "displayName": "Logger Id", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"description": "Logger ID to use when a match to the parent route required" },
"maxMessagesPerPoll": { "kind": "parameter", "displayName": "Max Messages
Per Poll", "group": "common", "label": "", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "1", "description": "The max number of
messages to receive from the server in a single API call" },
+ "serviceAccountKey": { "kind": "parameter", "displayName": "Service
Account Key", "group": "common", "label": "common", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "description": "The Service account key that can be
used as credentials for the Storage client. It can be loaded by default from
classpath, but you can prefix with classpath:, file:, or http: to load the
resource from different systems." },
"synchronousPull": { "kind": "parameter", "displayName": "Synchronous
Pull", "group": "common", "label": "", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "description": "Synchronously pull batches of
messages" },
"bridgeErrorHandler": { "kind": "parameter", "displayName": "Bridge Error
Handler", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "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 m [...]
"exceptionHandler": { "kind": "parameter", "displayName": "Exception
Handler", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.spi.ExceptionHandler", "optionalPrefix": "consumer.",
"deprecated": false, "autowired": false, "secret": false, "description": "To
let the consumer use a custom ExceptionHandler. Notice if the option
bridgeErrorHandler is enabled then this option is not in use. By default the
con [...]
diff --git
a/components/camel-google-pubsub/src/main/docs/google-pubsub-component.adoc
b/components/camel-google-pubsub/src/main/docs/google-pubsub-component.adoc
index a7c67af..83d4535 100644
--- a/components/camel-google-pubsub/src/main/docs/google-pubsub-component.adoc
+++ b/components/camel-google-pubsub/src/main/docs/google-pubsub-component.adoc
@@ -81,7 +81,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (12 parameters):
+=== Query Parameters (13 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -91,6 +91,7 @@ with the following path and query parameters:
| *concurrentConsumers* (common) | The number of parallel streams consuming
from the subscription | 1 | Integer
| *loggerId* (common) | Logger ID to use when a match to the parent route
required | | String
| *maxMessagesPerPoll* (common) | The max number of messages to receive from
the server in a single API call | 1 | Integer
+| *serviceAccountKey* (common) | The Service account key that can be used as
credentials for the Storage client. It can be loaded by default from classpath,
but you can prefix with classpath:, file:, or http: to load the resource from
different systems. | | String
| *synchronousPull* (common) | Synchronously pull batches of messages | false
| boolean
| *bridgeErrorHandler* (consumer) | 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. By default the
consumer will use the org.apache.camel.spi.ExceptionHandler to deal with
exceptions, that will be logged at WARN or ERROR level and ignored. | false |
boolean
| *exceptionHandler* (consumer) | To let the consumer use a custom
ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this
option is not in use. By default the consumer will deal with exceptions, that
will be logged at WARN or ERROR level and ignored. | | ExceptionHandler
diff --git
a/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubComponent.java
b/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubComponent.java
index a727380..dbc2aca 100644
---
a/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubComponent.java
+++
b/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubComponent.java
@@ -17,15 +17,18 @@
package org.apache.camel.component.google.pubsub;
import java.io.IOException;
+import java.io.InputStream;
import java.util.Map;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;
import com.google.api.gax.core.CredentialsProvider;
+import com.google.api.gax.core.FixedCredentialsProvider;
import com.google.api.gax.core.NoCredentialsProvider;
import com.google.api.gax.grpc.GrpcTransportChannel;
import com.google.api.gax.rpc.FixedTransportChannelProvider;
import com.google.api.gax.rpc.TransportChannelProvider;
+import com.google.auth.oauth2.ServiceAccountCredentials;
import com.google.cloud.pubsub.v1.MessageReceiver;
import com.google.cloud.pubsub.v1.Publisher;
import com.google.cloud.pubsub.v1.Subscriber;
@@ -40,6 +43,8 @@ import org.apache.camel.Endpoint;
import org.apache.camel.spi.Metadata;
import org.apache.camel.spi.annotations.Component;
import org.apache.camel.support.DefaultComponent;
+import org.apache.camel.support.ResourceHelper;
+import org.apache.camel.util.ObjectHelper;
import org.apache.camel.util.StringHelper;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -119,19 +124,29 @@ public class GooglePubsubComponent extends
DefaultComponent {
super.doShutdown();
}
- public Publisher getPublisher(String topicName, GooglePubsubEndpoint
googlePubsubEndpoint) throws ExecutionException {
- return cachedPublishers.get(topicName, () -> buildPublisher(topicName,
googlePubsubEndpoint));
+ public Publisher getPublisher(String topicName, GooglePubsubEndpoint
googlePubsubEndpoint, String serviceAccountKey)
+ throws ExecutionException {
+ return cachedPublishers.get(topicName, () -> buildPublisher(topicName,
googlePubsubEndpoint, serviceAccountKey));
}
- private Publisher buildPublisher(String topicName, GooglePubsubEndpoint
googlePubsubEndpoint) throws IOException {
+ private Publisher buildPublisher(String topicName, GooglePubsubEndpoint
googlePubsubEndpoint, String serviceAccountKey)
+ throws IOException {
Publisher.Builder builder = Publisher.newBuilder(topicName);
if (StringHelper.trimToNull(endpoint) != null) {
ManagedChannel channel =
ManagedChannelBuilder.forTarget(endpoint).usePlaintext().build();
TransportChannelProvider channelProvider
=
FixedTransportChannelProvider.create(GrpcTransportChannel.create(channel));
- CredentialsProvider credentialsProvider =
NoCredentialsProvider.create();
-
builder.setChannelProvider(channelProvider).setCredentialsProvider(credentialsProvider);
+ builder.setChannelProvider(channelProvider);
}
+ CredentialsProvider credentialsProvider;
+ if (ObjectHelper.isEmpty(serviceAccountKey)) {
+ credentialsProvider = NoCredentialsProvider.create();
+ } else {
+ InputStream serviceAccountFile
+ =
ResourceHelper.resolveMandatoryResourceAsInputStream(getCamelContext(),
serviceAccountKey);
+ credentialsProvider =
FixedCredentialsProvider.create(ServiceAccountCredentials.fromStream(serviceAccountFile));
+ }
+ builder.setCredentialsProvider(credentialsProvider);
if (StringHelper.trimToNull(googlePubsubEndpoint.getPubsubEndpoint())
!= null) {
builder.setEndpoint(googlePubsubEndpoint.getPubsubEndpoint());
}
@@ -145,19 +160,28 @@ public class GooglePubsubComponent extends
DefaultComponent {
return builder.build();
}
- public Subscriber getSubscriber(String subscriptionName, MessageReceiver
messageReceiver) {
+ public Subscriber getSubscriber(String subscriptionName, MessageReceiver
messageReceiver, String serviceAccountKey)
+ throws IOException {
Subscriber.Builder builder = Subscriber.newBuilder(subscriptionName,
messageReceiver);
if (StringHelper.trimToNull(endpoint) != null) {
ManagedChannel channel =
ManagedChannelBuilder.forTarget(endpoint).usePlaintext().build();
TransportChannelProvider channelProvider
=
FixedTransportChannelProvider.create(GrpcTransportChannel.create(channel));
- CredentialsProvider credentialsProvider =
NoCredentialsProvider.create();
-
builder.setChannelProvider(channelProvider).setCredentialsProvider(credentialsProvider);
+ builder.setChannelProvider(channelProvider);
+ }
+ CredentialsProvider credentialsProvider;
+ if (ObjectHelper.isEmpty(serviceAccountKey)) {
+ credentialsProvider = NoCredentialsProvider.create();
+ } else {
+ InputStream serviceAccountFile
+ =
ResourceHelper.resolveMandatoryResourceAsInputStream(getCamelContext(),
serviceAccountKey);
+ credentialsProvider =
FixedCredentialsProvider.create(ServiceAccountCredentials.fromStream(serviceAccountFile));
}
+ builder.setCredentialsProvider(credentialsProvider);
return builder.build();
}
- public SubscriberStub getSubscriberStub() throws IOException {
+ public SubscriberStub getSubscriberStub(String serviceAccountKey) throws
IOException {
SubscriberStubSettings.Builder builder =
SubscriberStubSettings.newBuilder().setTransportChannelProvider(
SubscriberStubSettings.defaultGrpcTransportProviderBuilder().build());
@@ -165,9 +189,17 @@ public class GooglePubsubComponent extends
DefaultComponent {
ManagedChannel channel =
ManagedChannelBuilder.forTarget(endpoint).usePlaintext().build();
TransportChannelProvider channelProvider
=
FixedTransportChannelProvider.create(GrpcTransportChannel.create(channel));
- CredentialsProvider credentialsProvider =
NoCredentialsProvider.create();
-
builder.setTransportChannelProvider(channelProvider).setCredentialsProvider(credentialsProvider);
+ builder.setTransportChannelProvider(channelProvider);
+ }
+ CredentialsProvider credentialsProvider;
+ if (ObjectHelper.isEmpty(serviceAccountKey)) {
+ credentialsProvider = NoCredentialsProvider.create();
+ } else {
+ InputStream serviceAccountFile
+ =
ResourceHelper.resolveMandatoryResourceAsInputStream(getCamelContext(),
serviceAccountKey);
+ credentialsProvider =
FixedCredentialsProvider.create(ServiceAccountCredentials.fromStream(serviceAccountFile));
}
+ builder.setCredentialsProvider(credentialsProvider);
return builder.build().createStub();
}
diff --git
a/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubConsumer.java
b/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubConsumer.java
index 8adc5e1..a08b892 100644
---
a/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubConsumer.java
+++
b/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubConsumer.java
@@ -121,11 +121,12 @@ public class GooglePubsubConsumer extends DefaultConsumer
{
}
}
- private void asynchronousPull(String subscriptionName) {
+ private void asynchronousPull(String subscriptionName) throws
IOException {
while (isRunAllowed() && !isSuspendingOrSuspended()) {
MessageReceiver messageReceiver = new
CamelMessageReceiver(GooglePubsubConsumer.this, endpoint, processor);
- Subscriber subscriber =
endpoint.getComponent().getSubscriber(subscriptionName, messageReceiver);
+ Subscriber subscriber =
endpoint.getComponent().getSubscriber(subscriptionName, messageReceiver,
+ endpoint.getServiceAccountKey());
try {
subscribers.add(subscriber);
subscriber.startAsync().awaitRunning();
@@ -141,7 +142,7 @@ public class GooglePubsubConsumer extends DefaultConsumer {
private void synchronousPull(String subscriptionName) {
while (isRunAllowed() && !isSuspendingOrSuspended()) {
- try (SubscriberStub subscriber =
endpoint.getComponent().getSubscriberStub()) {
+ try (SubscriberStub subscriber =
endpoint.getComponent().getSubscriberStub(endpoint.getServiceAccountKey())) {
PullRequest pullRequest = PullRequest.newBuilder()
.setMaxMessages(endpoint.getMaxMessagesPerPoll())
diff --git
a/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubEndpoint.java
b/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubEndpoint.java
index 94ca30f..b36df5e 100644
---
a/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubEndpoint.java
+++
b/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubEndpoint.java
@@ -54,6 +54,11 @@ public class GooglePubsubEndpoint extends DefaultEndpoint {
@Metadata(required = true)
private String destinationName;
+ @UriParam(label = "common",
+ description = "The Service account key that can be used as
credentials for the Storage client. It can be loaded by default from "
+ + " classpath, but you can prefix with classpath:,
file:, or http: to load the resource from different systems.")
+ private String serviceAccountKey;
+
@UriParam(name = "loggerId", description = "Logger ID to use when a match
to the parent route required")
private String loggerId;
@@ -160,6 +165,14 @@ public class GooglePubsubEndpoint extends DefaultEndpoint {
this.loggerId = loggerId;
}
+ public String getServiceAccountKey() {
+ return serviceAccountKey;
+ }
+
+ public void setServiceAccountKey(String serviceAccountKey) {
+ this.serviceAccountKey = serviceAccountKey;
+ }
+
public String getDestinationName() {
return destinationName;
}
diff --git
a/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubProducer.java
b/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubProducer.java
index 233fbb0..604062a 100644
---
a/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubProducer.java
+++
b/components/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubProducer.java
@@ -84,7 +84,7 @@ public class GooglePubsubProducer extends DefaultProducer {
GooglePubsubEndpoint endpoint = (GooglePubsubEndpoint) getEndpoint();
String topicName = String.format("projects/%s/topics/%s",
endpoint.getProjectId(), endpoint.getDestinationName());
- Publisher publisher = endpoint.getComponent().getPublisher(topicName,
endpoint);
+ Publisher publisher = endpoint.getComponent().getPublisher(topicName,
endpoint, endpoint.getServiceAccountKey());
Object body = exchange.getIn().getBody();
ByteString byteString;
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/GooglePubsubEndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/GooglePubsubEndpointBuilderFactory.java
index 2d3aebe..a3a7fac 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/GooglePubsubEndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/GooglePubsubEndpointBuilderFactory.java
@@ -158,6 +158,24 @@ public interface GooglePubsubEndpointBuilderFactory {
return this;
}
/**
+ * The Service account key that can be used as credentials for the
+ * Storage client. 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.
+ *
+ * Group: common
+ *
+ * @param serviceAccountKey the value to set
+ * @return the dsl builder
+ */
+ default GooglePubsubEndpointConsumerBuilder serviceAccountKey(
+ String serviceAccountKey) {
+ doSetProperty("serviceAccountKey", serviceAccountKey);
+ return this;
+ }
+ /**
* Synchronously pull batches of messages.
*
* The option is a: <code>boolean</code> type.
@@ -444,6 +462,24 @@ public interface GooglePubsubEndpointBuilderFactory {
return this;
}
/**
+ * The Service account key that can be used as credentials for the
+ * Storage client. 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.
+ *
+ * Group: common
+ *
+ * @param serviceAccountKey the value to set
+ * @return the dsl builder
+ */
+ default GooglePubsubEndpointProducerBuilder serviceAccountKey(
+ String serviceAccountKey) {
+ doSetProperty("serviceAccountKey", serviceAccountKey);
+ return this;
+ }
+ /**
* Synchronously pull batches of messages.
*
* The option is a: <code>boolean</code> type.
@@ -749,6 +785,24 @@ public interface GooglePubsubEndpointBuilderFactory {
return this;
}
/**
+ * The Service account key that can be used as credentials for the
+ * Storage client. 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.
+ *
+ * Group: common
+ *
+ * @param serviceAccountKey the value to set
+ * @return the dsl builder
+ */
+ default GooglePubsubEndpointBuilder serviceAccountKey(
+ String serviceAccountKey) {
+ doSetProperty("serviceAccountKey", serviceAccountKey);
+ return this;
+ }
+ /**
* Synchronously pull batches of messages.
*
* The option is a: <code>boolean</code> type.
diff --git a/docs/components/modules/ROOT/pages/google-pubsub-component.adoc
b/docs/components/modules/ROOT/pages/google-pubsub-component.adoc
index c2d3476..ad8f5f3 100644
--- a/docs/components/modules/ROOT/pages/google-pubsub-component.adoc
+++ b/docs/components/modules/ROOT/pages/google-pubsub-component.adoc
@@ -83,7 +83,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (12 parameters):
+=== Query Parameters (13 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -93,6 +93,7 @@ with the following path and query parameters:
| *concurrentConsumers* (common) | The number of parallel streams consuming
from the subscription | 1 | Integer
| *loggerId* (common) | Logger ID to use when a match to the parent route
required | | String
| *maxMessagesPerPoll* (common) | The max number of messages to receive from
the server in a single API call | 1 | Integer
+| *serviceAccountKey* (common) | The Service account key that can be used as
credentials for the Storage client. It can be loaded by default from classpath,
but you can prefix with classpath:, file:, or http: to load the resource from
different systems. | | String
| *synchronousPull* (common) | Synchronously pull batches of messages | false
| boolean
| *bridgeErrorHandler* (consumer) | 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. By default the
consumer will use the org.apache.camel.spi.ExceptionHandler to deal with
exceptions, that will be logged at WARN or ERROR level and ignored. | false |
boolean
| *exceptionHandler* (consumer) | To let the consumer use a custom
ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this
option is not in use. By default the consumer will deal with exceptions, that
will be logged at WARN or ERROR level and ignored. | | ExceptionHandler
