DBZ-4450 Pick up default project if not provided
This commit is contained in:
parent
d376faa8e0
commit
d9739aa71a
@ -18,6 +18,7 @@
|
|||||||
import javax.inject.Inject;
|
import javax.inject.Inject;
|
||||||
import javax.inject.Named;
|
import javax.inject.Named;
|
||||||
|
|
||||||
|
import com.google.cloud.ServiceOptions;
|
||||||
import org.eclipse.microprofile.config.Config;
|
import org.eclipse.microprofile.config.Config;
|
||||||
import org.eclipse.microprofile.config.ConfigProvider;
|
import org.eclipse.microprofile.config.ConfigProvider;
|
||||||
import org.eclipse.microprofile.config.inject.ConfigProperty;
|
import org.eclipse.microprofile.config.inject.ConfigProperty;
|
||||||
@ -75,7 +76,7 @@ public static interface PublisherBuilder {
|
|||||||
@PostConstruct
|
@PostConstruct
|
||||||
void connect() {
|
void connect() {
|
||||||
final Config config = ConfigProvider.getConfig();
|
final Config config = ConfigProvider.getConfig();
|
||||||
String projectId = config.getValue(PROP_PROJECT_ID, String.class);
|
String projectId = config.getOptionalValue(PROP_PROJECT_ID, String.class).orElse(ServiceOptions.getDefaultProjectId());
|
||||||
String region = config.getValue(PROP_REGION, String.class);
|
String region = config.getValue(PROP_REGION, String.class);
|
||||||
|
|
||||||
if (customPublisherBuilder.isResolvable()) {
|
if (customPublisherBuilder.isResolvable()) {
|
||||||
@ -109,7 +110,7 @@ void close() {
|
|||||||
publisher.stopAsync().awaitTerminated();
|
publisher.stopAsync().awaitTerminated();
|
||||||
}
|
}
|
||||||
catch (Exception e) {
|
catch (Exception e) {
|
||||||
LOGGER.warn("Exception while closing publisher: {}", e);
|
LOGGER.warn("Exception while closing publisher: " + e);
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user