Struct RabbitmqBus

messagebus/rabbitmq.go:38–47

RabbitmqBus is MessageBus implementation for RabbitMQ

// RabbitmqBus is MessageBus implementation for RabbitMQ
type RabbitmqBus struct {
	Config Config
	Log    log15.Logger

	conn          *amqp091.Connection
	channel       *amqp091.Channel
	countTimeouts int64
	isClosed      bool
	mu            sync.RWMutex
}

// OptionRabbitmqFunc options for RabbitMQ
type OptionRabbitmqFunc func(n *RabbitmqBus)