publisher

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

type Destination string

type MessageBoolOptFunc func(msg *message.Message) (bool, error)

type MessageIntOptFunc func(msg *message.Message) (int, error)

type MessagePublisher[T any] struct {
	RoutingFunc             RoutingFunc
	MessageMarshaller       func(msg *message.Message) (T, error)
	GetDestinationPublisher func(d Destination) (MessagesPublisherImpl[T], error)
	// contains filtered or unexported fields
}

type MessageStringOptFunc func(msg *message.Message) (string, error)

type MessagesPublisherImpl[T any] interface {
	io.Closer
	Publish(ctx context.Context, message T) error
	GetMessageID(message T) string
}

type Publisher interface {
	io.Closer
	Publish(message *message.Message) error
}

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

type RoutingFunc func(msg *message.Message) (Destination, error)