errors.go

package rabbitmq

import (
	"errors"
	"fmt"

	"github.com/Clarilab/clarimq/v2"
	eh "github.com/Clarilab/eventhorizon"
)

const (
	headerErrorMessage = "errorMessage"
)

var (
	// ErrCouldNotBeRouted is returned when a mandatory message could not be routed.
	ErrCouldNotBeRouted = errors.New("message could not be routed")

	// ErrFailedToPublishChannelClosed occurs when the channel accessed but is closed.
	ErrFailedToPublishChannelClosed = errors.New("amqp channel is closed")

	// ErrErrHandlerNotRegistered is returned when calling RemoveHandler with a handler that is not registered.
	ErrHandlerNotRegistered = errors.New("handler not registered")

	// ErrInvalidEventHandler when an invalid eventhorizon.EventHandler was provided.
	ErrInvalidEventHandler = errors.New("invalid event handler")
)

type AMQPError clarimq.AMQPError

func (e *AMQPError) Error() string {
	return fmt.Sprintf("Exception (%d) Reason: %q", e.Code, e.Reason)
}

// ErrRecoveryFailed occurs when the recovery failed after a connection loss.
type RecoveryFailedError struct {
	err            error
	connectionName string
}

// Error implements the Error method of the error interface.
func (e *RecoveryFailedError) Error() string {
	var str = "recovery failed: "

	if e.err != nil {
		str += e.err.Error()
	} else {
		str += "unknown error"
	}

	return str
}

// ConnectionName returns the name of the connection that failed to recover.
func (e *RecoveryFailedError) ConnectionName() string {
	return e.connectionName
}

// EventBusError is an async error containing the error returned from a handler and the event that it happened on.
// Its a wrapper around the eventhorizon.EventBusError with extra information about the handler.
type EventBusError struct {
	eh.EventBusError
	HandlerType eh.EventHandlerType
}