messaging

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

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

type KafkaSubscription struct {
	Name    string
	Topic   string
	GroupID string
	// contains filtered or unexported fields
}

type Listener interface {
	HealthCheck(ctx context.Context) error
	Close()
	BrokerType() string
}

type MessageHandlerFunc func(topicName string, payload []byte) error

type NatsSubscription struct {
	Name            string
	Topic           string
	Stream          string
	DurableConsumer string
	QueueGroup      string
	// contains filtered or unexported fields
}

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

type RabbitMQSubscription struct {
	Name        string
	Queue       string
	Exchange    string
	RoutingKey  string
	ConsumerTag string
	// contains filtered or unexported fields
}