rmqc

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

type ConsumerBuilder struct {
	Reconnect struct {
		MaxAttempt int
		Interval   time.Duration
	}
	// contains filtered or unexported fields
}

type ConsumerConfig struct {
	QueueName    string
	ConsumerName string
	Consumer     IConsumer
	Reconnect    Reconnect
	Qos          struct {
		PrefetchCount int
		ConsumerCount int
	}
}

type ConsumerContext struct {
	MessageId     string
	CorrelationId string
	Exchange      string
	RoutingKey    string
	Data          []byte
}

type ExchangeType string

type IConsumer interface {
	Configure(builder *ConsumerBuilder)
	Consume(context *ConsumerContext)
}

type Queue struct {
	Name string
	Arg  map[string]interface{}
}

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

type RabbitMQConfig struct {
	Username       string
	Password       string
	Host           string
	Port           string
	VHost          string
	ConnectionName string
	Reconnect      Reconnect
}

type Reconnect struct {
	MaxAttempt int
	Interval   time.Duration
}

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