rabbitmq

https://github.com/Azure/azure-sdk-for-net/blob/main/sdk/servicebus/Azure.Messaging.ServiceBus/MigrationGuide.md

Under the hood, Benthos csv input uses the standard encoding/csv packages's csv.Reader struct.

The current implementation of csv input doesn't allow setting the LazyQuotes field.

We have a use case where we need to set the LazyQuotes field in order to make things work correctly.

i'm attempting to write a health check for a service that uses watermill and i'd like to be able to easily determine if the router is still up and running

Router exposes a channel at .Running(), and it's possible to infer if the router is closed with a little indirection:

running := false
go func() {
  r := router.Running()

  for {
    if _, open := <-r; open {
      running 

我看到可以通过Prometheus搭建监控环境，如果有图文，更容易理解．