mirror
/
tile38
mirror of https://github.com/tidwall/tile38.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

amqp: removal of queue and binding creation

This commit is contained in:
Jan Pacák 2021-05-13 00:44:27 +02:00
parent b467c6f1cb
commit 71fa16a19e
1 changed files with 1 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
internal/endpoint/amqp.go
View File

@ -85,30 +85,7 @@ func (conn *AMQPConn) Send(msg string) error {
); err != nil {
return err
}
// Create queue if queue don't exists
if _, err := channel.QueueDeclare(
conn.ep.AMQP.QueueName,
conn.ep.AMQP.Durable,
conn.ep.AMQP.AutoDelete,
false,
conn.ep.AMQP.NoWait,
nil,
); err != nil {
return err
}
// Binding exchange to queue
if err := channel.QueueBind(
conn.ep.AMQP.QueueName,
conn.ep.AMQP.RouteKey,
conn.ep.AMQP.QueueName,
conn.ep.AMQP.NoWait,
nil,
); err != nil {
return err
}
conn.conn = c
conn.channel = channel
}