From effdb9104633b1f4e23c36713e16b3a8275696dc Mon Sep 17 00:00:00 2001
From: Adrian Gallagher <thrasher@addictionsoftware.com>
Date: Mon, 20 Feb 2017 15:02:19 +1100
Subject: [PATCH] Change Turnpike repo due to upstream issue

---
 .travis.yml          |  2 +-
 poloniexwebsocket.go | 10 +++++-----
 2 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/.travis.yml b/.travis.yml
index 7439df87..772db866 100644
--- a/.travis.yml
+++ b/.travis.yml
@@ -7,7 +7,7 @@ install:
  - go get github.com/gorilla/websocket
  - go get github.com/toorop/go-pusher
  - go get github.com/thrasher-/socketio
- - go get gopkg.in/jcelliott/turnpike.v2
+ - go get github.com/beatgammit/turnpike
  - go get github.com/gorilla/mux
 
 after_success:
diff --git a/poloniexwebsocket.go b/poloniexwebsocket.go
index 7a1edcc3..33e855fe 100644
--- a/poloniexwebsocket.go
+++ b/poloniexwebsocket.go
@@ -4,7 +4,7 @@ import (
 	"log"
 	"strconv"
 
-	"gopkg.in/jcelliott/turnpike.v2"
+	"github.com/beatgammit/turnpike"
 )
 
 const (
@@ -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, nil)
+		c, err := turnpike.NewWebsocketClient(turnpike.JSON, POLONIEX_WEBSOCKET_ADDRESS, 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, nil, PoloniexOnTicker); err != nil {
+		if err := c.Subscribe(POLONIEX_WEBSOCKET_TICKER, PoloniexOnTicker); err != nil {
 			log.Printf("%s Error subscribing to ticker channel: %s\n", p.GetName(), err)
 		}
 
-		if err := c.Subscribe(POLONIEX_WEBSOCKET_TROLLBOX, nil, PoloniexOnTrollbox); err != nil {
+		if err := c.Subscribe(POLONIEX_WEBSOCKET_TROLLBOX, 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, nil, PoloniexOnDepthOrTrade); err != nil {
+			if err := c.Subscribe(currency, PoloniexOnDepthOrTrade); err != nil {
 				log.Printf("%s Error subscribing to %s channel: %s\n", p.GetName(), currency, err)
 			}
 		}