writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
		return
	}

	// Create a map of updated set of rules in request
	updatedRules := make(map[string]lifecycle.Rule, len(bucketLifecycle.Rules))
	for _, rule := range bucketLifecycle.Rules {
		updatedRules[rule.ID] = rule
	}

	// Get list of rules for the bucket from disk
	meta, err := globalBucketMetadataSys.GetConfigFromDisk(ctx, bucket)
	if err != nil {

    
    // Wait for change notification
    Thread.sleep(2000);
    
    // Cache should be invalidated, new listing should include new file
    SmbFile[] updatedFiles = dir.listFiles();
    assertEquals(initialFiles.length + 1, updatedFiles.length);
}
```

## 9. Error Handling

### 9.1 Cache Consistency
```java
public class CacheConsistencyManager {

                    }
                    processParentGroup(user, updatedGroups, updatedRoles, groupId);
                }

                // Update groups/roles
                final String[] finalGroups = updatedGroups.stream().distinct().toArray(n -> new String[n]);
                final String[] finalRoles = updatedRoles.stream().distinct().toArray(n -> new String[n]);
                user.setGroups(finalGroups);