#11 Xchange dependency updated to latest SNAPSHOT

pom.xml

@@ -70,7 +70,7 @@
     </repositories>
 
     <properties>
-        <xchange.version>4.2.0</xchange.version>
+        <xchange.version>4.2.1-SNAPSHOT</xchange.version>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
         <maven.compiler.source>1.8</maven.compiler.source>

xchange-bitstamp/src/main/java/info/bitrich/xchangestream/bitstamp/BitstampStreamingMarketDataService.java

@@ -2,17 +2,18 @@
 
 import com.fasterxml.jackson.databind.DeserializationFeature;
 import com.fasterxml.jackson.databind.ObjectMapper;
+import info.bitrich.xchangestream.bitstamp.dto.BitstampOrderBook;
 import info.bitrich.xchangestream.bitstamp.dto.BitstampWebSocketTransaction;
 import info.bitrich.xchangestream.core.StreamingMarketDataService;
 import info.bitrich.xchangestream.service.pusher.PusherStreamingService;
 import io.reactivex.Observable;
 import org.knowm.xchange.bitstamp.BitstampAdapters;
-import org.knowm.xchange.bitstamp.dto.marketdata.BitstampOrderBook;
 import org.knowm.xchange.currency.CurrencyPair;
 import org.knowm.xchange.dto.marketdata.OrderBook;
 import org.knowm.xchange.dto.marketdata.Ticker;
 import org.knowm.xchange.dto.marketdata.Trade;
 import org.knowm.xchange.exceptions.NotAvailableFromExchangeException;
+
 import java.util.Date;
 
 public class BitstampStreamingMarketDataService implements StreamingMarketDataService {
@@ -30,10 +31,10 @@ public Observable<OrderBook> getOrderBook(CurrencyPair currencyPair, Object... a
                 .map(s -> {
                     ObjectMapper mapper = new ObjectMapper();
                     mapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
-                    BitstampOrderBook bitstampOrderBook = mapper.readValue(s, BitstampOrderBook.class);
-                    bitstampOrderBook = new BitstampOrderBook(new Date().getTime()/1000L, bitstampOrderBook.getBids(), bitstampOrderBook.getAsks());
+                    BitstampOrderBook orderBook = mapper.readValue(s, BitstampOrderBook.class);
+                    org.knowm.xchange.bitstamp.dto.marketdata.BitstampOrderBook bitstampOrderBook = new org.knowm.xchange.bitstamp.dto.marketdata.BitstampOrderBook(new Date().getTime(), orderBook.getBids(), orderBook.getAsks());
 
-                    return BitstampAdapters.adaptOrderBook(bitstampOrderBook, currencyPair, 1000);
+                    return BitstampAdapters.adaptOrderBook(bitstampOrderBook, currencyPair);
                 });
     }
 

xchange-bitstamp/src/main/java/info/bitrich/xchangestream/bitstamp/dto/BitstampOrderBook.java

@@ -0,0 +1,24 @@
+package info.bitrich.xchangestream.bitstamp.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+import java.math.BigDecimal;
+import java.util.List;
+
+public class BitstampOrderBook {
+    private final List<List<BigDecimal>> bids;
+    private final List<List<BigDecimal>> asks;
+
+    public BitstampOrderBook(@JsonProperty("bids") List<List<BigDecimal>> bids, @JsonProperty("asks") List<List<BigDecimal>> asks) {
+        this.bids = bids;
+        this.asks = asks;
+    }
+
+    public List<List<BigDecimal>> getBids() {
+        return bids;
+    }
+
+    public List<List<BigDecimal>> getAsks() {
+        return asks;
+    }
+}