You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
90 lines
1.8 KiB
90 lines
1.8 KiB
package rabbitmq
|
|
|
|
import (
|
|
"github.com/wagslane/go-rabbitmq/internal/connectionmanager"
|
|
)
|
|
|
|
func declareQueue(connManager *connectionmanager.ConnectionManager, options QueueOptions) error {
|
|
if !options.Declare {
|
|
return nil
|
|
}
|
|
if options.Passive {
|
|
_, err := connManager.QueueDeclarePassiveSafe(
|
|
options.Name,
|
|
options.Durable,
|
|
options.AutoDelete,
|
|
options.Exclusive,
|
|
options.NoWait,
|
|
tableToAMQPTable(options.Args),
|
|
)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
return nil
|
|
}
|
|
_, err := connManager.QueueDeclareSafe(
|
|
options.Name,
|
|
options.Durable,
|
|
options.AutoDelete,
|
|
options.Exclusive,
|
|
options.NoWait,
|
|
tableToAMQPTable(options.Args),
|
|
)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func declareExchange(connManager *connectionmanager.ConnectionManager, options ExchangeOptions) error {
|
|
if !options.Declare {
|
|
return nil
|
|
}
|
|
if options.Passive {
|
|
err := connManager.ExchangeDeclarePassiveSafe(
|
|
options.Name,
|
|
options.Kind,
|
|
options.Durable,
|
|
options.AutoDelete,
|
|
options.Internal,
|
|
options.NoWait,
|
|
tableToAMQPTable(options.Args),
|
|
)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
return nil
|
|
}
|
|
err := connManager.ExchangeDeclareSafe(
|
|
options.Name,
|
|
options.Kind,
|
|
options.Durable,
|
|
options.AutoDelete,
|
|
options.Internal,
|
|
options.NoWait,
|
|
tableToAMQPTable(options.Args),
|
|
)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func declareBindings(connManager *connectionmanager.ConnectionManager, options ConsumerOptions) error {
|
|
for _, binding := range options.Bindings {
|
|
if !binding.Declare {
|
|
continue
|
|
}
|
|
err := connManager.QueueBindSafe(
|
|
options.QueueOptions.Name,
|
|
binding.RoutingKey,
|
|
options.ExchangeOptions.Name,
|
|
binding.NoWait,
|
|
tableToAMQPTable(binding.Args),
|
|
)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
}
|
|
return nil
|
|
}
|