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"`
	// contains filtered or unexported fields
}

type QueueConfiguration struct {
	TopicName string
}

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 QueueConsumerConfig interface {
	QueueConsumer

	// Config returns the queue configuration details by providing access to a QueueConfiguration object.
	Config() *QueueConfiguration
}

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