private Short version;
private ErrorHandler errorHandler;
- private long maxTimeout = 1000;
+ private long maxTimeout = 8000;
private TimeUnit maxTimeoutUnit = TimeUnit.MILLISECONDS;
private Short highestVersion;
}
@Override
- public synchronized void shake() {
+ public void shake() {
LOG.trace("handshake STARTED");
setActiveXid(20L);
HelloMessage receivedHelloLoc = receivedHello;
*/
protected void postHandshake(Short proposedVersion, Long xid) throws Exception {
// set version
- long maxTimeout = 3000;
version = proposedVersion;
LOG.debug("version set: {}", proposedVersion);