package org.opendaylight.controller.cluster.databroker.actors.dds;
import static akka.pattern.Patterns.ask;
+import static com.google.common.base.Verify.verifyNotNull;
import akka.dispatch.ExecutionContexts;
import akka.dispatch.OnComplete;
}
LOG.debug("Invalidating backend information {}", staleInfo);
- flushCache(staleInfo.getShardName());
+ flushCache(staleInfo.getName());
LOG.trace("Invalidated cache {}", staleInfo);
backends.remove(cookie, existing);
}
}, ExecutionContexts.global());
}
+
+ @Override
+ public String resolveCookieName(Long cookie) {
+ return verifyNotNull(shards.inverse().get(cookie), "Unexpected null cookie: %s", cookie);
+ }
}