fix npe

PeerDB-io · Sep 28, 2023 · c57fb1f · c57fb1f
1 parent a3104ef
commit c57fb1f
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/flow/connectors/eventhub/hubmanager.go b/flow/connectors/eventhub/hubmanager.go
@@ -32,15 +32,18 @@ func NewEventHubManager(
 ) *EventHubManager {
 	hubs := cmap.New[*azeventhubs.ProducerClient]()
 	peerConfig := cmap.New[*protos.EventHubConfig]()
+	peerNames := cmap.New[string]()
 
 	for name, config := range groupConfig.Eventhubs {
 		peerConfig.Set(name, config)
 	}
 
 	return &EventHubManager{
-		ctx:   ctx,
-		creds: creds,
-		hubs:  hubs,
+		ctx:        ctx,
+		creds:      creds,
+		hubs:       hubs,
+		peerConfig: peerConfig,
+		peerNames:  peerNames,
 	}
 }