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

Merge branch 'master' of https://github.com/pacaj2am/tile38 into pacaj2am-master

This commit is contained in:
tidwall 2023-05-06 06:56:00 -07:00
parent 59f4845e19 71fa16a19e
commit 9ea0803ce0
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
internal/endpoint/amqp.go
View File

@ -93,7 +93,7 @@ func (conn *AMQPConn) Send(msg string) error {
); err != nil {
return err
}
if conn.ep.AMQP.Type != "topic" {
if conn.ep.AMQP.Type != "topic" {
// Create queue if queue don't exists
if _, err := channel.QueueDeclare(
conn.ep.AMQP.QueueName,
@ -117,7 +117,6 @@ func (conn *AMQPConn) Send(msg string) error {
return err
}
}
conn.conn = c
conn.channel = channel
}