messagequeue

type Consumer interface {
	Consume(stopChan chan bool, errors chan error)
}

type ConsumerProvider interface {
	ProvideConsumer(ctx context.Context, topic string, handlerFunc func(context.Context, []byte) error) (Consumer, error)
}

type NoopConsumer struct{}

type Publisher interface {
	Stop()
	Publish(ctx context.Context, data any) error
}

type PublisherProvider interface {
	Close()
	ProvidePublisher(topic string) (Publisher, error)
}