Increase timeout for conf test + more logging for EventGrid. (#663)
This commit is contained in:
parent
795b62417e
commit
ac28629cb0
|
|
@ -99,9 +99,11 @@ func (a *AzureEventGrid) Read(handler func(*bindings.ReadResponse) error) error
|
|||
}
|
||||
}
|
||||
|
||||
fasthttp.ListenAndServe(fmt.Sprintf(":%s", a.metadata.HandshakePort), m)
|
||||
|
||||
a.logger.Debugf("listening for Event Grid events at http://localhost:%s/api/events", a.metadata.HandshakePort)
|
||||
a.logger.Debugf("About to start listening for Event Grid events at http://localhost:%s/api/events", a.metadata.HandshakePort)
|
||||
err = fasthttp.ListenAndServe(fmt.Sprintf(":%s", a.metadata.HandshakePort), m)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
|
@ -144,6 +146,8 @@ func (a *AzureEventGrid) Invoke(req *bindings.InvokeRequest) (*bindings.InvokeRe
|
|||
return nil, errors.New(string(body))
|
||||
}
|
||||
|
||||
a.logger.Debugf("Successfully posted event to %s", a.metadata.TopicEndpoint)
|
||||
|
||||
return nil, nil
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -10,6 +10,8 @@ components:
|
|||
output_blobName: $((uuid))
|
||||
- component: azure.eventgrid
|
||||
operations: ["create", "operations", "read"]
|
||||
config:
|
||||
readBindingTimeout: 120
|
||||
- component: azure.storagequeues
|
||||
operations: ["create", "operations", "read"]
|
||||
- component: azure.servicebusqueues
|
||||
|
|
|
|||
Loading…
Reference in New Issue