Upgrade GCP BOM to 26.50.0

bom/pom.xml

@@ -18,7 +18,7 @@
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
 
-        <google-cloud-sdk.version>26.45.0</google-cloud-sdk.version>
+        <google-cloud-sdk.version>26.50.0</google-cloud-sdk.version>
 
         <!-- Dependency convergence issues -->
         <opencensus.version>0.31.1</opencensus.version><!-- mess in google-pubsub and grpc deps; should be rather stable as OpenCensus has been sunsetted already - see https://github.com/GoogleCloudPlatform/cloud-opensource-java/issues/862 -->

docs/modules/ROOT/pages/includes/quarkus-google-cloud-pubsub.adoc

@@ -75,5 +75,25 @@ endif::add-copy-button-to-env-var[]
 |string
 |
 
+a| [[quarkus-google-cloud-pubsub_quarkus-google-cloud-pubsub-use-emulator-credentials]] [.property-path]##link:#quarkus-google-cloud-pubsub_quarkus-google-cloud-pubsub-use-emulator-credentials[`quarkus.google.cloud.pubsub.use-emulator-credentials`]##
+
+[.description]
+--
+Forces the usage of emulator credentials. The logic automatically uses emulator credentials in case the emulatorHost is set.
+
+ - If true: force usage of emulator credentials
+ - If false: force not using emulator credentials
+
+
+ifdef::add-copy-button-to-env-var[]
+Environment variable: env_var_with_copy_button:+++QUARKUS_GOOGLE_CLOUD_PUBSUB_USE_EMULATOR_CREDENTIALS+++[]
+endif::add-copy-button-to-env-var[]
+ifndef::add-copy-button-to-env-var[]
+Environment variable: `+++QUARKUS_GOOGLE_CLOUD_PUBSUB_USE_EMULATOR_CREDENTIALS+++`
+endif::add-copy-button-to-env-var[]
+--
+|boolean
+|`true`
+
 |===
 

docs/modules/ROOT/pages/includes/quarkus-google-cloud-pubsub_quarkus.google.adoc

@@ -75,5 +75,25 @@ endif::add-copy-button-to-env-var[]
 |string
 |
 
+a| [[quarkus-google-cloud-pubsub_quarkus-google-cloud-pubsub-use-emulator-credentials]] [.property-path]##link:#quarkus-google-cloud-pubsub_quarkus-google-cloud-pubsub-use-emulator-credentials[`quarkus.google.cloud.pubsub.use-emulator-credentials`]##
+
+[.description]
+--
+Forces the usage of emulator credentials. The logic automatically uses emulator credentials in case the emulatorHost is set.
+
+ - If true: force usage of emulator credentials
+ - If false: force not using emulator credentials
+
+
+ifdef::add-copy-button-to-env-var[]
+Environment variable: env_var_with_copy_button:+++QUARKUS_GOOGLE_CLOUD_PUBSUB_USE_EMULATOR_CREDENTIALS+++[]
+endif::add-copy-button-to-env-var[]
+ifndef::add-copy-button-to-env-var[]
+Environment variable: `+++QUARKUS_GOOGLE_CLOUD_PUBSUB_USE_EMULATOR_CREDENTIALS+++`
+endif::add-copy-button-to-env-var[]
+--
+|boolean
+|`true`
+
 |===
 

integration-tests/main/src/main/java/io/quarkiverse/googlecloudservices/it/BigtableResource.java

@@ -22,6 +22,7 @@
 import com.google.cloud.bigtable.admin.v2.stub.EnhancedBigtableTableAdminStub;
 import com.google.cloud.bigtable.data.v2.BigtableDataClient;
 import com.google.cloud.bigtable.data.v2.BigtableDataSettings;
+import com.google.cloud.bigtable.data.v2.internal.TableAdminRequestContext;
 import com.google.cloud.bigtable.data.v2.models.Row;
 import com.google.cloud.bigtable.data.v2.models.RowCell;
 import com.google.cloud.bigtable.data.v2.models.RowMutation;
@@ -63,7 +64,8 @@ void initBigtable() throws IOException {
                             .newBuilder()
                             .setTransportChannelProvider(channelProvider)
                             .setCredentialsProvider(credentialsProvider)
-                            .build());
+                            .build(),
+                    TableAdminRequestContext.create(projectId, INSTANCE_ID));
 
             try (BigtableTableAdminClient adminClient = BigtableTableAdminClient.create(projectId, INSTANCE_ID, stub)) {
                 if (!adminClient.exists(TABLE_ID)) {

logging/runtime/src/test/java/io/quarkiverse/googlecloudservices/logging/runtime/LoggingHandlerTest.java

@@ -58,6 +58,9 @@ void shouldLogToStdoutWithTraceInfoAndLabels() {
 
         ArcContainer container = createArcContainer(traceId, spanId);
 
+        // There can be JVM logs before our log so we clean the output stream captor
+        outputStreamCaptor.reset();
+
         try (MockedStatic<Arc> arc = Mockito.mockStatic(Arc.class)) {
             arc.when(Arc::container).thenReturn(container);
 

pubsub/runtime/src/main/java/io/quarkiverse/googlecloudservices/pubsub/QuarkusPubSub.java

@@ -4,14 +4,14 @@
 import java.util.Optional;
 import java.util.stream.StreamSupport;
 
-import com.google.api.gax.core.NoCredentialsProvider;
 import jakarta.annotation.PostConstruct;
 import jakarta.annotation.PreDestroy;
 import jakarta.enterprise.context.ApplicationScoped;
 import jakarta.enterprise.inject.Instance;
 import jakarta.inject.Inject;
 
 import com.google.api.gax.core.CredentialsProvider;
+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;