messaging

type OriginalMessage interface {
	// Ack acknowledges the message.
	Ack() error
	// Nack rejects the message.
	// If requeue is true, the message will be put back in the original queue.
	// If requeue is false, the message will be discarded or sent to a DLQ.
	Nack(requeue bool, err error) error
}

type Producer struct {
	// contains filtered or unexported fields
}

type ProviderMessage struct {
	ID            uuid.UUID                       `json:"id"`
	Origin        string                          `json:"origin"`
	Action        string                          `json:"action"`
	Message       any                             `json:"message"`
	AuthContext   *security.AuthenticationContext `json:"authenticationContext"`
	CorrelationID string                          `json:"correlationId,omitempty"`
	// contains filtered or unexported fields
}

type QueueConsumer interface {

	// Consume processes a ProviderMessage in a given context and returns an error if the processing fails.
	Consume(ctx context.Context, providerMessage *ProviderMessage) error

	// QueueName retrieves the name of the queue associated with the consumer.
	QueueName() string
}

type TestProducer[T any] struct {
	// contains filtered or unexported fields
}