Skip to content

Commit

Permalink
handle quoted ehnames
Browse files Browse the repository at this point in the history
  • Loading branch information
Amogh-Bharadwaj committed Jan 2, 2024
1 parent 9e0e836 commit f45a756
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion flow/connectors/eventhub/scoped_eventhub.go
Original file line number Diff line number Diff line change
Expand Up @@ -19,9 +19,12 @@ func NewScopedEventhub(raw string) (ScopedEventhub, error) {
return ScopedEventhub{}, fmt.Errorf("invalid scoped eventhub '%s'", raw)
}

// support eventhub name with hyphens etc.
eventhubPart := strings.Trim(parts[1], `"`)

return ScopedEventhub{
PeerName: parts[0],
Eventhub: parts[1],
Eventhub: eventhubPart,
Identifier: parts[2],
}, nil
}
Expand Down

0 comments on commit f45a756

Please sign in to comment.