| | |
| | | try |
| | | { |
| | | Thread.sleep(1000); |
| | | rb.start(); |
| | | } catch (InterruptedException ex) |
| | | { |
| | | fail("Error sleeping " + stackTraceToSingleLineString(ex)); |
| | |
| | | { |
| | | // Timeout reached, end with error |
| | | fail("checkConnection: DS " + rb.getServerId() + " is not connected to " |
| | | + "the RS port " + rsPort + " after " + secTimeout + " seconds."); |
| | | + "the RS port " + rsPort + " after " + secTimeout + " seconds."); |
| | | } |
| | | } |
| | | } |
| | |
| | | ArrayList<String> servers = new ArrayList<String>(1); |
| | | servers.add("localhost:" + port); |
| | | broker.start(servers); |
| | | checkConnection(30, broker, port); |
| | | if (timeout != 0) |
| | | broker.setSoTimeout(timeout); |
| | | |
| | |
| | | ArrayList<String> servers = new ArrayList<String>(1); |
| | | servers.add("localhost:" + port); |
| | | broker.start(servers); |
| | | checkConnection(30, broker, port); |
| | | if (timeout != 0) |
| | | broker.setSoTimeout(timeout); |
| | | if (emptyOldChanges) |