search

wagslane / go-rabbitmq

A wrapper of streadway/amqp that provides reconnection logic and sane defaults
https://blog.boot.dev/golang/connecting-to-rabbitmq-in-golang-easy/
MIT License
805 stars 128 forks source link

Queue not create #185

Closed brounnoupegreula-7757 closed 2 months ago

brounnoupegreula-7757 commented 2 months ago 
consumer, err := gorabbitmq.NewConsumer(
        rs.connection,
        rs.config.Message.Queue,
        gorabbitmq.WithConsumerOptionsExchangeName(rs.config.Message.Exchange),
        gorabbitmq.WithConsumerOptionsExchangeKind(rs.config.Message.EXchangeType),
        gorabbitmq.WithConsumerOptionsRoutingKey(rs.config.Message.RoutingKey),
        gorabbitmq.WithConsumerOptionsConsumerAutoAck(false),
        gorabbitmq.WithConsumerOptionsExchangeDurable,
        gorabbitmq.WithConsumerOptionsExchangeDeclare,
        gorabbitmq.WithConsumerOptionsQueueDurable,
        gorabbitmq.WithConsumerOptionsQueuePassive,
    )

hi, why queue not create here? i got error not found queue