New package for rabbitmq

[jensloe-nhn]

Usage examples:

c, err := rabbitmq.NewConsumer(myHandler, rabbitmq.WithAuthenticator(myAuthenticator), rabbitmq.WithLogger(myLogger))
if err != nil {
  log.Fatal(err)
}
defer func() {
  _ = c.Shutdown(context.Background)
}()

c.Consume(context.Background)

[havardelnan]

Maybe move it to pkg/clients

[havardelnan]

Maybe return a cancel function so we can defere cancelfunc() or add a cacel method that can be called from defere

defere c.Cancel()

[jensloe-nhn]

Maybe move it to pkg/clients

Package is now moved to pkg/clients/rabbitmq

[jensloe-nhn]

Maybe return a cancel function so we can defere cancelfunc() or add a cacel method that can be called from defere

defere c.Cancel()

The underlying connection interface has a Shutdown method that can be deferred and should handle context cancel. Would this cancel method be on the consumer/producer?

[havardelnan]

Maybe return a cancel function so we can defere cancelfunc() or add a cacel method that can be called from defere

defere c.Cancel()

The underlying connection interface has a Shutdown method that can be deferred and should handle context cancel. Would this cancel method be on the consumer/producer?

Fair, could do i guess

defere c.Shutdown(context.Background)