messaging

type DirectMessaging interface {
	Listen(target string, handler func(data []byte)) (Subscription, error)
	Send(target string, data []byte) error
}

type EnqueueOptions struct {
	IdempotententKey string
}

type MessageQueue interface {
	Enqueue(topic string, message []byte, options *EnqueueOptions) error
	Dequeue(topic string, handler func(message []byte) error) error
	Close()
}

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

type PubSub interface {
	Publish(topic string, message []byte) error
	PublishWithReply(ttopic, reply string, data []byte) error
	Subscribe(topic string, handler func(msg *nats.Msg)) (Subscription, error)
}

type StreamPubsub interface {
	Publish(topic string, message []byte) error
	Subscribe(name string, topic string, handler func(msg jetstream.Msg)) (Subscription, error)
}

type StreamPubsubOption func(*streamPubSubConfig)

type Subscription interface {
	Unsubscribe() error
}