6 writes to EventHubName
Aspire.Azure.Messaging.EventHubs (2)
AzureMessagingEventHubsSettings.cs (1)
130
EventHubName
= entityPath!.ToString();
EventHubsComponent.cs (1)
148
settings.
EventHubName
= props.EventHubName;
Aspire.Hosting.Azure.Tests (4)
AzureEventHubsExtensionsTests.cs (4)
90
hb.AddAzureEventHubProducerClient("eventhubns", settings => settings.
EventHubName
= eventHub.Resource.HubName);
91
hb.AddAzureEventHubConsumerClient("eventhubns", settings => settings.
EventHubName
= eventHub.Resource.HubName);
136
hb.AddAzureEventHubProducerClient("eventhubns", settings => settings.
EventHubName
= eventHub.Resource.HubName);
137
hb.AddAzureEventHubConsumerClient("eventhubns", settings => settings.
EventHubName
= eventHub.Resource.HubName);
25 references to EventHubName
Aspire.Azure.Messaging.EventHubs (24)
EventHubBufferedProducerClientComponent.cs (3)
40
return new EventHubBufferedProducerClient(settings.FullyQualifiedNamespace, settings.
EventHubName
, cred, options);
44
if (string.IsNullOrEmpty(settings.
EventHubName
))
49
return new EventHubBufferedProducerClient(settings.ConnectionString, settings.
EventHubName
, options);
EventHubConsumerClientComponent.cs (3)
41
return new EventHubConsumerClient(consumerGroup, settings.FullyQualifiedNamespace, settings.
EventHubName
, cred, options);
45
if (string.IsNullOrEmpty(settings.
EventHubName
))
50
return new EventHubConsumerClient(consumerGroup, settings.ConnectionString, settings.
EventHubName
, options);
EventHubProducerClientComponent.cs (3)
39
return new EventHubProducerClient(settings.FullyQualifiedNamespace, settings.
EventHubName
, cred, options);
43
if (string.IsNullOrEmpty(settings.
EventHubName
))
48
return new EventHubProducerClient(settings.ConnectionString, settings.
EventHubName
, options);
EventHubsComponent.cs (6)
42
Identifier = $"AspireEventHubHealthCheck-{settings.
EventHubName
}",
48
_healthCheckClient = new EventHubProducerClient(settings.FullyQualifiedNamespace, settings.
EventHubName
, settings.Credential ?? new DefaultAzureCredential(), producerClientOptions);
51
else if (string.IsNullOrEmpty(settings.
EventHubName
))
57
_healthCheckClient = new EventHubProducerClient(settings.ConnectionString, settings.
EventHubName
, producerClientOptions);
135
if (string.IsNullOrWhiteSpace(settings.
EventHubName
))
152
else if (!string.IsNullOrWhiteSpace(settings.FullyQualifiedNamespace) && string.IsNullOrWhiteSpace(settings.
EventHubName
))
EventProcessorClientComponent.cs (5)
45
options.Identifier ??= GenerateClientIdentifier(settings.
EventHubName
, settings.ConsumerGroup);
56
settings.
EventHubName
, cred, options);
59
if (string.IsNullOrEmpty(settings.
EventHubName
))
69
settings.
EventHubName
, options);
106
settings.BlobContainerName = $"{ns}-{settings.
EventHubName
}-{consumerGroup}";
PartitionReceiverClientComponent.cs (4)
44
options.Identifier ??= GenerateClientIdentifier(settings.
EventHubName
, settings.ConsumerGroup);
53
settings.
EventHubName
,
57
if (string.IsNullOrEmpty(settings.
EventHubName
))
72
settings.
EventHubName
,
Aspire.Azure.Messaging.EventHubs.Tests (1)
AspireEventHubsExtensionsTests.cs (1)
661
Assert.Equal(expectedEventHubName, settings.
EventHubName
);