From ba3473b8196f7106f98c7a1320f0f16221f886f6 Mon Sep 17 00:00:00 2001 From: Adrian Gallagher Date: Fri, 2 Dec 2016 12:13:29 +1100 Subject: [PATCH] Add additional Turnpike parameters. --- poloniexwebsocket.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/poloniexwebsocket.go b/poloniexwebsocket.go index 59e76f47..7a1edcc3 100644 --- a/poloniexwebsocket.go +++ b/poloniexwebsocket.go @@ -133,7 +133,7 @@ func PoloniexOnDepthOrTrade(args []interface{}, kwargs map[string]interface{}) { func (p *Poloniex) WebsocketClient() { for p.Enabled && p.Websocket { - c, err := turnpike.NewWebsocketClient(turnpike.JSON, POLONIEX_WEBSOCKET_ADDRESS, nil) + c, err := turnpike.NewWebsocketClient(turnpike.JSON, POLONIEX_WEBSOCKET_ADDRESS, nil, nil) if err != nil { log.Printf("%s Unable to connect to Websocket. Error: %s\n", p.GetName(), err) continue @@ -155,17 +155,17 @@ func (p *Poloniex) WebsocketClient() { c.ReceiveDone = make(chan bool) - if err := c.Subscribe(POLONIEX_WEBSOCKET_TICKER, PoloniexOnTicker); err != nil { + if err := c.Subscribe(POLONIEX_WEBSOCKET_TICKER, nil, PoloniexOnTicker); err != nil { log.Printf("%s Error subscribing to ticker channel: %s\n", p.GetName(), err) } - if err := c.Subscribe(POLONIEX_WEBSOCKET_TROLLBOX, PoloniexOnTrollbox); err != nil { + if err := c.Subscribe(POLONIEX_WEBSOCKET_TROLLBOX, nil, PoloniexOnTrollbox); err != nil { log.Printf("%s Error subscribing to trollbox channel: %s\n", p.GetName(), err) } for x := range p.EnabledPairs { currency := p.EnabledPairs[x] - if err := c.Subscribe(currency, PoloniexOnDepthOrTrade); err != nil { + if err := c.Subscribe(currency, nil, PoloniexOnDepthOrTrade); err != nil { log.Printf("%s Error subscribing to %s channel: %s\n", p.GetName(), currency, err) } }