diff --git a/exchanges/gemini/gemini_websocket.go b/exchanges/gemini/gemini_websocket.go index dd308256368..34d11d36bfe 100644 --- a/exchanges/gemini/gemini_websocket.go +++ b/exchanges/gemini/gemini_websocket.go @@ -103,19 +103,14 @@ func (g *Gemini) Unsubscribe(subs subscription.List) error { } func (g *Gemini) manageSubs(subs subscription.List, op wsSubOp) error { - format, err := g.GetPairFormat(asset.Spot, true) - if err != nil { - return err - } - req := wsSubscribeRequest{ Type: op, Subscriptions: make([]wsSubscriptions, 0, len(subs)), } for _, s := range subs { req.Subscriptions = append(req.Subscriptions, wsSubscriptions{ - Name: s.Channel, - Symbols: s.Pairs.Format(format).Strings(), + Name: s.QualifiedChannel, + Symbols: s.Pairs.Strings(), }) }