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.
92 lines
1.8 KiB
92 lines
1.8 KiB
package rabbitmq
|
|
|
|
import (
|
|
"github.com/wagslane/go-rabbitmq/internal/channelmanager"
|
|
)
|
|
|
|
func declareQueue(chanManager *channelmanager.ChannelManager, options QueueOptions) error {
|
|
if !options.Declare {
|
|
return nil
|
|
}
|
|
if options.Passive {
|
|
_, err := chanManager.QueueDeclarePassiveSafe(
|
|
options.Name,
|
|
options.Durable,
|
|
options.AutoDelete,
|
|
options.Exclusive,
|
|
options.NoWait,
|
|
tableToAMQPTable(options.Args),
|
|
)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
return nil
|
|
}
|
|
_, err := chanManager.QueueDeclareSafe(
|
|
options.Name,
|
|
options.Durable,
|
|
options.AutoDelete,
|
|
options.Exclusive,
|
|
options.NoWait,
|
|
tableToAMQPTable(options.Args),
|
|
)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func declareExchange(chanManager *channelmanager.ChannelManager, options ExchangeOptions) error {
|
|
if !options.Declare {
|
|
return nil
|
|
}
|
|
if options.Passive {
|
|
err := chanManager.ExchangeDeclarePassiveSafe(
|
|
options.Name,
|
|
options.Kind,
|
|
options.Durable,
|
|
options.AutoDelete,
|
|
options.Internal,
|
|
options.NoWait,
|
|
tableToAMQPTable(options.Args),
|
|
)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
return nil
|
|
}
|
|
err := chanManager.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(chanManager *channelmanager.ChannelManager, options ConsumerOptions) error {
|
|
for _, exchangeOption := range options.ExchangeOptions {
|
|
for _, binding := range exchangeOption.Bindings {
|
|
if !binding.Declare {
|
|
continue
|
|
}
|
|
err := chanManager.QueueBindSafe(
|
|
options.QueueOptions.Name,
|
|
binding.RoutingKey,
|
|
exchangeOption.Name,
|
|
binding.NoWait,
|
|
tableToAMQPTable(binding.Args),
|
|
)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
}
|
|
}
|
|
return nil
|
|
}
|