Skip to content

Commit d3262e1

Browse files
author
jim
committed
attempting to improve testnet streaming
1 parent c8d9e7d commit d3262e1

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
lines changed

src/main/java/com/binance/api/client/config/BinanceApiConfig.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -77,6 +77,6 @@ public static String getTestNetBaseUrl() {
7777
* Streaming Spot Test Network base URL.
7878
*/
7979
public static String getStreamTestNetBaseUrl() {
80-
return String.format("wss://%s", TESTNET_DOMAIN);
80+
return String.format("wss://%s/ws", TESTNET_DOMAIN);
8181
}
8282
}

src/main/java/com/binance/api/client/impl/BinanceApiServiceGenerator.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -58,8 +58,8 @@ public static <S> S createService(Class<S> serviceClass, String apiKey, String s
5858
String baseUrl = null;
5959
if (!BinanceApiConfig.useTestnet) { baseUrl = BinanceApiConfig.getApiBaseUrl(); }
6060
else {
61-
baseUrl = BinanceApiConfig.useTestnetStreaming ?
62-
BinanceApiConfig.getStreamTestNetBaseUrl() :
61+
baseUrl = /*BinanceApiConfig.useTestnetStreaming ?
62+
BinanceApiConfig.getStreamTestNetBaseUrl() :*/
6363
BinanceApiConfig.getTestNetBaseUrl();
6464
}
6565

src/main/java/com/binance/api/client/impl/BinanceApiWebSocketClientImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -93,7 +93,7 @@ public void close() {
9393
}
9494

9595
private Closeable createNewWebSocket(String channel, BinanceApiWebSocketListener<?> listener) {
96-
String streamingUrl = String.format("%s/%s", BinanceApiConfig.getStreamApiBaseUrl(), channel);
96+
String streamingUrl = String.format("%s/%s", BinanceApiConfig.useTestnetStreaming?BinanceApiConfig.getStreamTestNetBaseUrl():BinanceApiConfig.getStreamApiBaseUrl(), channel);
9797
Request request = new Request.Builder().url(streamingUrl).build();
9898
final WebSocket webSocket = client.newWebSocket(request, listener);
9999
return () -> {

0 commit comments

Comments
 (0)