messagebus

package

v0.4.6 Latest Latest Go to latest Published: Jun 26, 2026 License: Apache-2.0 Imports: 15 Imported by: 0

Details

View Source

const DefaultTopic = "/messages"

DefaultTopic is the topic messagebus uses when WithTopic is not provided.

This section is empty.

This section is empty.

type Manager interface {
	// business
	model.MessageBus
	// lifecycle
	common.Daemon
	common.Debuggable
}

func New(bus model.Pubsub, opts ...Option) Manager

type Option func(*manager)

func WithLogger(logger log.Logger) Option

func WithName(name string) Option

func WithTopic(topic string) Option

WithTopic overrides the default bus topic ("/messages"). Use this when you need multiple messagebus instances sharing one pubsub.