@@ -1035,7 +1035,7 @@ private void doBackup() throws BrokerException {
10351035
10361036 logger .logToAll (Logger .INFO , "Backup persistent store for HA cluster " + clusterID );
10371037
1038- FileStore fileStore = new FileStore (backupDir , false );
1038+ final FileStore fileStore = new FileStore (backupDir , false );
10391039
10401040 // for backup, need to clear the store before storing anything.
10411041 fileStore .clearAll (false );
@@ -1210,12 +1210,11 @@ private void doBackup() throws BrokerException {
12101210 ex .printStackTrace ();
12111211 throw new BrokerException (ex .getMessage ());
12121212 } finally {
1213- if (fileStore != null ) {
1214- try {
1215- fileStore .close ();
1216- } catch (Exception e ) {
1217- e .printStackTrace ();
1218- }
1213+ assert fileStore != null ;
1214+ try {
1215+ fileStore .close ();
1216+ } catch (Exception e ) {
1217+ e .printStackTrace ();
12191218 }
12201219
12211220 StoreManager .releaseStore (true );
@@ -1238,7 +1237,7 @@ private void doRestore() throws BrokerException {
12381237
12391238 logger .logToAll (Logger .INFO , "Restore persistent store for HA cluster " + clusterID + " from backup dir: " + backupDir );
12401239
1241- FileStore fileStore = new FileStore (backupDir , false );
1240+ final FileStore fileStore = new FileStore (backupDir , false );
12421241
12431242 // Brokers table.
12441243 JDBCStore jdbcStore = null ;
@@ -1432,12 +1431,11 @@ private void doRestore() throws BrokerException {
14321431 ex .printStackTrace ();
14331432 throw new BrokerException (ex .getMessage ());
14341433 } finally {
1435- if (fileStore != null ) {
1436- try {
1437- fileStore .close ();
1438- } catch (Exception e ) {
1439- e .printStackTrace ();
1440- }
1434+ assert fileStore != null ;
1435+ try {
1436+ fileStore .close ();
1437+ } catch (Exception e ) {
1438+ e .printStackTrace ();
14411439 }
14421440
14431441 StoreManager .releaseStore (true );
0 commit comments