gvsafronov/tile38
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

disabled AMQP queue and binding for type topic

Browse Source
This commit is contained in:
uwer 2023-05-03 16:22:37 +10:00
parent dbd565d361
commit c63468a704
1 changed files with 22 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

43
internal/endpoint/amqp.go
View File

@ -93,28 +93,29 @@ func (conn *AMQPConn) Send(msg string) error {
); err != nil { ); err != nil {
return err return err
} }
if conn.ep.AMQP.Type != "topic" {
// 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
}
// Create queue if queue don't exists // Binding exchange to queue
if _, err := channel.QueueDeclare( if err := channel.QueueBind(
conn.ep.AMQP.QueueName, conn.ep.AMQP.QueueName,
conn.ep.AMQP.Durable, conn.ep.AMQP.RouteKey,
conn.ep.AMQP.AutoDelete, conn.ep.AMQP.QueueName,
false, conn.ep.AMQP.NoWait,
conn.ep.AMQP.NoWait, nil,
nil, ); err != nil {
); err != nil { return err
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.conn = c