added amqp error

alpha v1.0.21
alex 2023-01-08 16:17:24 +01:00
parent 627b994275
commit b89789c4fc
1 changed files with 4 additions and 2 deletions

View File

@ -14,10 +14,12 @@ var (
errNotConnected = errors.New("not connected to a server")
errAlreadyClosed = errors.New("already closed: not connected to the server")
errShutdown = errors.New("client is shutting down")
AmqpError = amqp.Error{}
)
func AmqpError() amqp.Error {
return amqp.Error{}
}
const (
DeliveryModeTransient = amqp.Transient
DeliveryModePersistent = amqp.Persistent