| 230 | if err != nil { |
| 231 | return nil, fmt.Errorf("%w: %v", ErrClientCreationFailed, err) |
| 232 | } |
| 233 | rx, err = azqueue.NewQueueClientWithNoCredential(p.ep.JoinURL(resName, tokens.Res), nil) |
| 234 | if err != nil { |
| 235 | return nil, fmt.Errorf("%w: %v", ErrClientCreationFailed, err) |
| 236 | } |
| 237 | } else { |
| 238 | tx, rx = p.client.NewQueueClient(resName), p.client.NewQueueClient(reqName) |
| 239 | } |
| 240 | return &queueTransport{connID: connID, txQueue: tx, rxQueue: rx, ep: p.ep, txName: reqName, rxName: resName, cfg: p.cfg, pending: make(map[uint64][]byte)}, nil |
| 241 | } |
| 242 |
nothing calls this directly
no outgoing calls
no test coverage detected