dapr
/
components-contrib
mirror of https://github.com/dapr/components-contrib.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fixed panic when not using Azure AD 

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
This commit is contained in:
ItalyPaleAle 2023-02-16 17:44:33 +00:00
parent a8957062f0
commit 5616866edc
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
internal/component/azure/eventhubs/eventhubs.go
View File

@ -73,13 +73,12 @@ func (aeh *AzureEventHubs) Init(metadata map[string]string) error {
}
aeh.metadata = m
if aeh.metadata.ConnectionString == "" {
// If connecting via Azure AD, we need to do some more initialization
aeh.metadata.azEnvSettings, err = azauth.NewEnvironmentSettings("eventhubs", metadata)
if err != nil {
return fmt.Errorf("failed to initialize Azure AD credentials: %w", err)
}
aeh.metadata.azEnvSettings, err = azauth.NewEnvironmentSettings("eventhubs", metadata)
if err != nil {
return fmt.Errorf("failed to initialize Azure environment: %w", err)
}
if aeh.metadata.ConnectionString == "" {
aeh.logger.Info("connecting to Azure Event Hub using Azure AD; the connection will be established on first publish/subscribe and req.Topic field in incoming requests will be honored")
if aeh.metadata.EnableEntityManagement {