subscriber

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

type OnErrorListener = func(msg *message.Message, err error)

type OnPanicListener = func(msg *message.Message, r any)

type RoutingKey string

type RoutingKeyGenerator = func(msg *message.Message) RoutingKey

type Subscriber interface {
	Subscribe() (<-chan *message.Message, error)
	Close() error
}

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

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

type TypedMessageHandler[T any] interface {
	OnMessage(ctx context.Context, event *T) error
}