6 writes to EventHubName
Aspire.Azure.Messaging.EventHubs (2)
AzureMessagingEventHubsSettings.cs (1)
130
EventHubName
= entityPath!.ToString();
EventHubsComponent.cs (1)
137
settings.
EventHubName
= props.EventHubName;
Aspire.Hosting.Azure.Tests (4)
AzureEventHubsExtensionsTests.cs (4)
92
hb.AddAzureEventHubProducerClient("eventhubns", settings => settings.
EventHubName
= "hub");
93
hb.AddAzureEventHubConsumerClient("eventhubns", settings => settings.
EventHubName
= "hub");
130
hb.AddAzureEventHubProducerClient("eventhubns", settings => settings.
EventHubName
= "hub");
131
hb.AddAzureEventHubConsumerClient("eventhubns", settings => settings.
EventHubName
= "hub");
23 references to EventHubName
Aspire.Azure.Messaging.EventHubs (22)
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 (4)
42
Identifier = $"AspireEventHubHealthCheck-{settings.
EventHubName
}",
47
new EventHubProducerClient(settings.FullyQualifiedNamespace, settings.
EventHubName
, settings.Credential ?? new DefaultAzureCredential(), producerClientOptions);
124
if (string.IsNullOrWhiteSpace(settings.
EventHubName
))
141
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
);