rabbitmq

type AMQPConsumer struct {
	ExchangeParams
	QueueParams
	QueueBindParams
	ConsumerParams

	IConsumer
}

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

type ClientConfig struct {
	// this callback will be invoked whenever network failure happens or node shuts down
	NetworkErrCallback func(*amqp.Error)
	// note that this interval is taken into account when on reconnecting multiple times in row
	AutoRecoveryInterval time.Duration
	// this callback will be invoked whenever connection retry fails or resource freeing returns error
	// returning value as bool should indicate whether to keep retrying recovery or not
	AutoRecoveryErrCallback func(error) bool
	// this callback will be called if restoring a consumer fails after recovery procedure
	ConsumerAutoRecoveryErrCallback func(AMQPConsumer, error)

	// configurations for setting up dial and new connection
	DialConfig

	PublisherConfirmEnabled bool
	PublisherConfirmNowait  bool

	ConsumerQos          int
	ConsumerPrefetchSize int
	ConsumerGlobal       bool
}

type ConsumerFunc func(ctx context.Context, msg amqp.Delivery)

type ConsumerParams struct {
	RoutingKeys []string
	ConsumerID  string
	AutoAck     bool
	Exclusive   bool
	NoLocal     bool
	Nowait      bool
	Args        amqp.Table
}

type DialConfig struct {
	User       string
	Password   string
	Host       string
	Port       string
	AMQPConfig amqp.Config
}

type ExchangeParams struct {
	Name       string
	Type       string
	Durable    bool
	AutoDelete bool
	Internal   bool
	Nowait     bool
	Args       amqp.Table
	// custom flag
	DeclareExchange bool
}

type IConsumer interface {
	Consume(ctx context.Context, msg amqp.Delivery)
}

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

type QueueBindParams struct {
	Nowait bool
	Args   amqp.Table
}

type QueueParams struct {
	Name       string
	Durable    bool
	AutoDelete bool
	Exclusive  bool
	Nowait     bool
	Args       amqp.Table
}