rabbitmq

type BaseStream struct {
	Name     string
	Exchange string
	// contains filtered or unexported fields
}

type Input struct {
	BaseStream

	Stream <-chan amqp.Delivery
}

type Output struct {
	BaseStream
}

type OutputDestination struct {
	Exchange  string `yaml:"exchange"`  // Exchange
	QueueName string `yaml:"queueName"` // Name of queue
}

type RabbitMq struct {
	Host          string                        `yaml:"host"`          // Host
	Port          int32                         `yaml:"port"`          // Port
	User          string                        `yaml:"user"`          // User
	Password      string                        `yaml:"password"`      // Password
	Exchange      string                        `yaml:"exchange"`      // Exchange
	QueueName     *string                       `yaml:"queueName"`     // Name of queue
	PrefetchSize  *int                          `yaml:"prefetchSize"`  // Prefetch size
	PrefetchCount *int                          `yaml:"prefetchCount"` // Prefetch count
	Destinations  *map[string]OutputDestination `yaml:"destinations"`  // Defined destination
	// contains filtered or unexported fields
}