when setting timeout infinite, make sure it is connected first
This commit is contained in:
@@ -38,6 +38,9 @@ public class Connection {
|
|||||||
|
|
||||||
public void setTimeoutInfinite() {
|
public void setTimeoutInfinite() {
|
||||||
try {
|
try {
|
||||||
|
if(!isConnected()) {
|
||||||
|
connect();
|
||||||
|
}
|
||||||
socket.setKeepAlive(true);
|
socket.setKeepAlive(true);
|
||||||
socket.setSoTimeout(0);
|
socket.setSoTimeout(0);
|
||||||
} catch (SocketException ex) {
|
} catch (SocketException ex) {
|
||||||
|
|||||||
@@ -33,4 +33,12 @@ public class ConnectionTest extends Assert {
|
|||||||
client.setPort(55665);
|
client.setPort(55665);
|
||||||
client.connect();
|
client.connect();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void connectIfNotConnectedWhenSettingTimeoutInfinite() {
|
||||||
|
client.setHost("localhost");
|
||||||
|
client.setPort(6379);
|
||||||
|
client.setTimeoutInfinite();
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
Reference in New Issue
Block a user