added amqp error

2023-01-08 16:18:46 +01:00 · 2023-01-08 16:18:46 +01:00 · 932f5efad1
parent b89789c4fc
commit 932f5efad1
1 changed files with 6 additions and 2 deletions
--- a/client.go
+++ b/client.go
@ -16,8 +16,12 @@ var (
 	errShutdown      = errors.New("client is shutting down")
 )

-func AmqpError() amqp.Error {
-	return amqp.Error{}
+// copied from amqp library
+type Error struct {
+	Code    int
+	Reason  string
+	Server  bool
+	Recover bool
 }

 const (