patch

tyk-gateway.diff

% git diff gateway/rpc_storage_handler.go 
diff --git a/gateway/rpc_storage_handler.go b/gateway/rpc_storage_handler.go
index a4006875..d1cb0c85 100644
--- a/gateway/rpc_storage_handler.go
+++ b/gateway/rpc_storage_handler.go
@@ -786,7 +786,7 @@ func (r *RPCStorageHandler) CheckForKeyspaceChanges(orgId string) {
 
        if len(keys.([]string)) > 0 {
                log.Info("Keyspace changes detected, updating local cache")
-               go r.ProcessKeySpaceChanges(keys.([]string))
+               go r.ProcessKeySpaceChanges(keys.([]string), orgId)
        }
 }
 
@@ -800,7 +800,7 @@ func getSessionAndCreate(keyName string, r *RPCStorageHandler) {
        }
 }
 
-func (r *RPCStorageHandler) ProcessKeySpaceChanges(keys []string) {
+func (r *RPCStorageHandler) ProcessKeySpaceChanges(keys []string, orgID string) {
        keysToReset := map[string]bool{}
        TokensToBeRevoked := map[string]string{}
        ClientsToBeRevoked := map[string]string{}
@@ -874,8 +874,9 @@ func (r *RPCStorageHandler) ProcessKeySpaceChanges(keys []string) {
                                handleDeleteHashedKey(splitKeys[0], "", resetQuota)
                                getSessionAndCreate(splitKeys[0], r)
                        } else {
-                               log.Info("--> removing cached key: ", key)
                                handleDeleteKey(key, "-1", resetQuota)
+                               keyWithOrg := generateToken(orgID, key)
+                               handleDeleteKey(keyWithOrg, "-1", resetQuota)
                                getSessionAndCreate(splitKeys[0], r)
                        }
                        SessionCache.Delete(key)