argument for ack timeouts removed and value taken from configuration
parent
fad11a09e1
commit
2edcac5b66
|
@ -5,7 +5,6 @@ import earth.krakatao.events.KraSocketClientEventInterface;
|
||||||
import earth.krakatao.protocol.KraSocketClientProtocol;
|
import earth.krakatao.protocol.KraSocketClientProtocol;
|
||||||
import java.net.URI;
|
import java.net.URI;
|
||||||
import java.net.URISyntaxException;
|
import java.net.URISyntaxException;
|
||||||
import java.util.List;
|
|
||||||
import java.util.logging.Logger;
|
import java.util.logging.Logger;
|
||||||
import lombok.Getter;
|
import lombok.Getter;
|
||||||
|
|
||||||
|
@ -21,7 +20,7 @@ public class KraSocketClient {
|
||||||
|
|
||||||
public KraSocketClient(KraSocketClientConfig kraSocketClientConfig,
|
public KraSocketClient(KraSocketClientConfig kraSocketClientConfig,
|
||||||
KraSocketClientEventInterface kraSocketClientEventInterface,
|
KraSocketClientEventInterface kraSocketClientEventInterface,
|
||||||
KraSocketClientProtocol kraSocketClientProtocol, List<Long> webSocketAckTimeouts)
|
KraSocketClientProtocol kraSocketClientProtocol)
|
||||||
throws URISyntaxException {
|
throws URISyntaxException {
|
||||||
this.kraSocketClientConfig = kraSocketClientConfig;
|
this.kraSocketClientConfig = kraSocketClientConfig;
|
||||||
|
|
||||||
|
@ -33,6 +32,7 @@ public class KraSocketClient {
|
||||||
+ this.kraSocketClientConfig.getWebSocketPort()
|
+ this.kraSocketClientConfig.getWebSocketPort()
|
||||||
+ "/ws?ak=" + this.kraSocketClientConfig.getWebSocketAccessKey()
|
+ "/ws?ak=" + this.kraSocketClientConfig.getWebSocketAccessKey()
|
||||||
+ "&s=" + this.kraSocketClientConfig.getWebSocketServerName()),
|
+ "&s=" + this.kraSocketClientConfig.getWebSocketServerName()),
|
||||||
this.kraSocketClientEventInitiater, kraSocketClientProtocol, webSocketAckTimeouts);
|
this.kraSocketClientEventInitiater, kraSocketClientProtocol,
|
||||||
|
this.kraSocketClientConfig.getWebSocketAckTimeouts());
|
||||||
}
|
}
|
||||||
}
|
}
|
Loading…
Reference in New Issue