usecase

package

v0.0.0-...-32727c2 Latest Latest Go to latest Published: Mar 4, 2025 License: GPL-3.0 Imports: 4 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrQueueExists = errors.New("message queue already exists")
	ErrNoQueue     = errors.New("queue doesn't exist")
)

This section is empty.

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

func NewBus(logger *slog.Logger) Bus

func (uc Bus) PostMessage(queueName string, msg domain.Message) error

PostMessage размещает сообщение в указанной очереди.

func (uc Bus) RegisterQueue(name string, maxSize, maxConsumers int) error

RegisterQueue создает новую [Queue] с указанными параметрами.

func (uc Bus) Subscribe(queueName, clientURI string) error

Subscribe подписывает клиента на события очереди.