(client *azqueue.ServiceClient, ep *Endpoint, name, sasToken string)
| 65 | if client != nil { |
| 66 | for _, name := range []string{cfg.handshakeEndpoint, cfg.tokenEndpoint} { |
| 67 | if _, err := client.CreateQueue(cfg.ctx, name, nil); err != nil && !queueerror.HasCode(err, queueerror.QueueAlreadyExists) { |
| 68 | return nil, err |
| 69 | } |
| 70 | } |
| 71 | } |
| 72 | |
| 73 | var hSAS, tSAS string |
| 74 | if client == nil { |
| 75 | hSAS, tSAS, _ = ep.ParseSAS(cfg) |
| 76 | } |
| 77 | |
| 78 | hq, err := resolveQueueClient(client, ep, cfg.handshakeEndpoint, hSAS) |
| 79 | if err != nil { |