ClickandJoin
/
go-cnj-helper
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

debugging queue name

alpha v1.0.10
alex 2023-01-07 21:17:39 +01:00
parent 3d630f3d77
commit 316612e97f
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
client.go
View File

@ -239,6 +239,8 @@ func (client *Client) init(conn *amqp.Connection) error {
client.AssignedQueueName = q.Name
log.Println("AssignedQueueName", q.Name)
if client.queueSettings.QueueBindSettings.QueueName != "" {
err = ch.QueueBind(
client.queueSettings.QueueBindSettings.QueueName,