Package io.micronaut.gcp.pubsub.support

Class PubSubConfigurationFactory

java.lang.Object

io.micronaut.gcp.pubsub.support.PubSubConfigurationFactory

@Factory
@Requires(classes=com.google.cloud.pubsub.v1.Publisher.class)
public class PubSubConfigurationFactory
extends java.lang.Object

Factory class to create default settings for PubSub Publisher and subscriber beans.

Since:

2.0.0

Author:

Vinicius Carvalho

Constructor Summary

Constructors

Constructor	Description
PubSubConfigurationFactory(PubSubConfigurationProperties pubSubConfigurationProperties, GoogleCloudConfiguration googleCloudConfiguration)

Method Summary

Modifier and Type	Method	Description
com.google.api.gax.core.CredentialsProvider	credentialsProvider(com.google.auth.oauth2.GoogleCredentials credentials)	Returns a default CredentialsProvider, allows users to override it and provide their own implementation.
com.google.api.gax.core.ExecutorProvider	publisherExecutorProvider()
com.google.api.gax.rpc.TransportChannelProvider	transportChannelProvider()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PubSubConfigurationFactory

public PubSubConfigurationFactory(PubSubConfigurationProperties pubSubConfigurationProperties,
                                  GoogleCloudConfiguration googleCloudConfiguration)

Method Detail

publisherExecutorProvider

@Singleton
public com.google.api.gax.core.ExecutorProvider publisherExecutorProvider()

Returns:

default ExecutorProvider

transportChannelProvider

@Singleton
public com.google.api.gax.rpc.TransportChannelProvider transportChannelProvider()

Returns:

default TransportChannelProvideransportChannelProvider

credentialsProvider

@Singleton
public com.google.api.gax.core.CredentialsProvider credentialsProvider(com.google.auth.oauth2.GoogleCredentials credentials)

Returns a default CredentialsProvider, allows users to override it and provide their own implementation.

Parameters:

credentials - default credentials, if not overriden by user should be provided by GoogleCredentialsFactory

Returns:

A FixedCredentialsProvider holding the given credentials.