public sealed class SubscriberClientBuilder : ClientBuilderBase<SubscriberClient>
Builder class for SubscriberClient to provide simple configuration of credentials, endpoint, client count, subscription settings etc.
Namespace
Google.Cloud.PubSub.V1Assembly
Google.Cloud.PubSub.V1.dll
Constructors
SubscriberClientBuilder()
public SubscriberClientBuilder()
Creates a new instance with default settings. TopicName must be set before calling either Build() or BuildAsync(CancellationToken).
Properties
ApiSettings
public SubscriberServiceApiSettings ApiSettings { get; set; }
The settings to use when creatingSubscriberServiceApiClient instances. Default settings will be used if this is null.
Property Value | |
---|---|
Type | Description |
SubscriberServiceApiSettings |
ClientCount
public int? ClientCount { get; set; }
The number of SubscriberServiceApiClients to create and use within a SubscriberClient instance. If this is null, the number of clients created will depend on the processor count.
Property Value | |
---|---|
Type | Description |
Nullable<Int32> |
EmulatorDetection
public EmulatorDetection EmulatorDetection { get; set; }
Specifies how to respond to the presence of emulator environment variables.
Property Value | |
---|---|
Type | Description |
EmulatorDetection |
This property defaults to None, meaning that environment variables are ignored.
Settings
public SubscriberClient.Settings Settings { get; set; }
Additional settings for batching, message ordering etc. Default settings will be used if this is null.
Property Value | |
---|---|
Type | Description |
SubscriberClient.Settings |
SubscriptionName
public SubscriptionName SubscriptionName { get; set; }
The name of the subscription that the subscriber subscribes to. This must be non-null by the time Build() or BuildAsync(CancellationToken) is called.
Property Value | |
---|---|
Type | Description |
SubscriptionName |
Methods
Build()
public override SubscriberClient Build()
Builds the resulting client.
Returns | |
---|---|
Type | Description |
SubscriberClient |
BuildAsync(CancellationToken)
public override Task<SubscriberClient> BuildAsync(CancellationToken cancellationToken = default(CancellationToken))
Builds the resulting client asynchronously.
Parameter | |
---|---|
Name | Description |
cancellationToken | CancellationToken |
Returns | |
---|---|
Type | Description |
Task<SubscriberClient> |
GetChannelPool()
protected override ChannelPool GetChannelPool()
Returns | |
---|---|
Type | Description |
ChannelPool |
Validate()
protected override void Validate()