File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -312,7 +312,7 @@ func (helper *Helper) StartWorkAgent(ctx context.Context, clusterName string) {
312312 var brokerConfig any
313313 switch helper .Broker {
314314 case "mqtt" :
315- // initilize the mqtt options
315+ // initialize the mqtt options
316316 mqttOptions , err := mqtt .BuildMQTTOptionsFromFlags (helper .Env ().Config .MessageBroker .MessageBrokerConfig )
317317 if err != nil {
318318 log .Fatalf ("Unable to build MQTT options: %s" , err .Error ())
@@ -323,14 +323,14 @@ func (helper *Helper) StartWorkAgent(ctx context.Context, clusterName string) {
323323 if ! exists {
324324 log .Fatalf ("Unable to find pubsub config for consumer %s" , clusterName )
325325 }
326- // initilize the pubsub options
326+ // initialize the pubsub options
327327 pubsubOptions , err := pubsub .BuildPubSubOptionsFromFlags (configPath )
328328 if err != nil {
329329 log .Fatalf ("Unable to build pubsub options: %s" , err .Error ())
330330 }
331331 brokerConfig = pubsubOptions
332332 default :
333- // initilize the grpc options
333+ // initialize the grpc options
334334 grpcOptions := & grpcoptions.GRPCOptions {Dialer : & grpcoptions.GRPCDialer {}}
335335 grpcOptions .Dialer .URL = fmt .Sprintf ("%s:%s" , helper .Env ().Config .HTTPServer .Hostname , helper .Env ().Config .GRPCServer .BrokerBindPort )
336336 brokerConfig = grpcOptions
You can’t perform that action at this time.
0 commit comments