mirror of
https://github.com/ebosas/microservices.git
synced 2024-11-24 08:02:24 +02:00
15 lines
337 B
Go
15 lines
337 B
Go
package rabbit
|
|
|
|
// DeclareTopicExchange declares an exchange of type 'topic'.
|
|
func (conn *Conn) DeclareTopicExchange(name string) error {
|
|
return conn.Channel.ExchangeDeclare(
|
|
name, // name
|
|
"topic", // type
|
|
true, // durable
|
|
false, // auto-deleted
|
|
false, // internal
|
|
false, // no-wait
|
|
nil, // arguments
|
|
)
|
|
}
|