if(persistenceString == null || persistenceString.equalsIgnoreCase("connection")) {
persistenceType = ClientRequest.PERSIST_CONNECTION;
} else if(persistenceString.equalsIgnoreCase("reboot")) {
persistenceType = ClientRequest.PERSIST_REBOOT;
} else if(persistenceString.equalsIgnoreCase("forever")) {
<BUG>persistenceType = ClientRequest.PERSIST_FOREVER;
} else {</BUG>
throw new MessageInvalidException(ProtocolErrorMessage.ERROR_PARSING_NUMBER, "Error parsing Persistence field: "+persistenceString, identifier);
}
}

if(persistenceString == null || persistenceString.equalsIgnoreCase("connection")) {
persistenceType = ClientRequest.PERSIST_CONNECTION;
} else if(persistenceString.equalsIgnoreCase("reboot")) {
persistenceType = ClientRequest.PERSIST_REBOOT;
} else if(persistenceString.equalsIgnoreCase("forever")) {
persistenceType = ClientRequest.PERSIST_FOREVER;
if(returnType != RETURN_TYPE_DISK) {
throw new MessageInvalidException(ProtocolErrorMessage.NOT_SUPPORTED, "PersistenceType=forever implies ReturnType=disk", identifier);
}
} else {
throw new MessageInvalidException(ProtocolErrorMessage.ERROR_PARSING_NUMBER, "Error parsing Persistence field: "+persistenceString, identifier);
}
}
